stressProof.cxx File Reference

#include <stdio.h>
#include <stdlib.h>
#include "Getline.h"
#include "TChain.h"
#include "TFile.h"
#include "TFileCollection.h"
#include "TFileInfo.h"
#include "TH1F.h"
#include "TH2F.h"
#include "TList.h"
#include "TMacro.h"
#include "TMap.h"
#include "TMath.h"
#include "TNamed.h"
#include "TParameter.h"
#include "TProof.h"
#include "TProofLog.h"
#include "TProofMgr.h"
#include "TQueryResult.h"
#include "TStopwatch.h"
#include "TString.h"
#include "TSystem.h"
#include "TROOT.h"
#include "../tutorials/proof/getProof.C"

Go to the source code of this file.

Classes
class	ProofTest
class	TTimeOutTimer
struct	PT_Open_Args_t
struct	PT_Packetizer_t
Typedefs
typedef Int_t(*)	ProofTestFun_t (void *)
Functions
void	stressProof (const char *url="proof://localhost:40000", Int_t nwrks=-1, Int_t verbose=1, const char *logfile=0, Bool_t dyn=kFALSE, Bool_t skipds=kTRUE, Int_t test=-1, const char *h1pfx=0)
int	main (int argc, const char *argv[])
Int_t	PutPoint ()
void	PrintStressProgress (Long64_t total, Long64_t processed, Float_t, Long64_t)
void	CleanupSelector (const char *selpath)
void	AssertParallelUnzip ()
Int_t	PT_Open (void *)
Int_t	PT_GetLogs (void *)
Int_t	PT_Simple (void *smg=0)
Int_t	PT_H1Http (void *)
Int_t	PT_H1FileCollection (void *)
Int_t	PT_H1DataSet (void *)
Int_t	PT_H1MultiDataSet (void *)
Int_t	PT_H1MultiDSetEntryList (void *)
Int_t	PT_DataSets (void *)
Int_t	PT_Packages (void *)
Int_t	PT_Event (void *)
Int_t	PT_InputData (void *)
Int_t	PT_H1SimpleAsync (void *arg)
Int_t	PT_AdminFunc (void *arg)
Int_t	PT_PackageArguments (void *)
Int_t	PT_H1AssertFiles (const char *h1src)
Int_t	PT_CheckSimple (TQueryResult *qr, Long64_t nevt, Int_t nhist)
Int_t	PT_CheckH1 (TQueryResult *qr, Int_t irun=0)
Variables
static const char *	urldef = "proof://localhost:40000"
static TString	gtutdir
static TString	gsandbox
static Int_t	gverbose = 1
static TString	glogfile
static Int_t	gpoints = 0
static Int_t	totpoints = 53
static RedirectHandle_t	gRH
static RedirectHandle_t	gRHAdmin
static Double_t	gH1Time = 0
static Double_t	gSimpleTime = 0
static Int_t	gH1Cnt = 0
static Int_t	gSimpleCnt = 0
static TStopwatch	gTimer
static Bool_t	gTimedOut = kFALSE
static Bool_t	gDynamicStartup = kFALSE
static Bool_t	gSkipDataSetTest = kTRUE
static Bool_t	gUseParallelUnzip = kFALSE
static TString	gh1src ("http://root.cern.ch/files/h1")
static Bool_t	gh1ok = kTRUE
static const char *	gh1file [] = { "dstarmb.root", "dstarp1a.root", "dstarp1b.root", "dstarp2.root" }
static TList	gSelectors
static TString	gH1Sel ("$ROOTSYS/tutorials/tree/h1analysis.C")
static TString	gEventSel ("$ROOTSYS/tutorials/proof/ProofEvent.C")
static TString	gSimpleSel ("$ROOTSYS/tutorials/proof/ProofSimple.C")
static TString	gTestsSel ("$ROOTSYS/tutorials/proof/ProofTests.C")
static PT_Packetizer_t	gStd_Old = { "TPacketizer", 0 }

---

Typedef Documentation

typedef Int_t(*) ProofTestFun_t(void *)

Definition at line 345 of file stressProof.cxx.

---

Function Documentation

void AssertParallelUnzip

(

)

Definition at line 331 of file stressProof.cxx.

References gProof, gUseParallelUnzip, and TProof::SetParameter().

Referenced by PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), and PT_H1SimpleAsync().

void CleanupSelector

(

const char *

selpath

)

Definition at line 307 of file stressProof.cxx.

References TSystem::AccessPathName(), TSystem::BaseName(), TSystem::DirName(), TString::Form(), TSystem::GetDirEntry(), gSystem, TSystem::OpenDirectory(), and TSystem::Unlink().

Referenced by stressProof().

int main	(	int	argc,
		const char *	argv[]
	)

Definition at line 164 of file stressProof.cxx.

References TSystem::Exit(), gDynamicStartup, gSkipDataSetTest, gSystem, gUseParallelUnzip, i, kFALSE, kTRUE, stressProof(), test(), urldef, and verbose.

void PrintStressProgress	(	Long64_t	total,
		Long64_t	processed,
		Float_t	,
		Long64_t
	)

Definition at line 286 of file stressProof.cxx.

References fprintf(), glogfile, gRH, gSystem, and TSystem::RedirectOutput().

Referenced by PT_Event(), PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), PT_H1SimpleAsync(), PT_InputData(), PT_PackageArguments(), and PT_Simple().

Int_t PT_AdminFunc

(

void *

arg

)

Definition at line 2098 of file stressProof.cxx.

References TSystem::AccessPathName(), TMacro::AddLine(), TMD5::AsString(), TMacro::Checksum(), TProofMgr::Cp(), TString::Data(), TList::First(), TString::Format(), FileStat_t::fSize, TProofMgr::GetFile(), TMacro::GetLineWith(), TMacro::GetListOfLines(), TProof::GetManager(), TSystem::GetPathInfo(), TCollection::GetSize(), glogfile, gProof, gRH, gRHAdmin, gsandbox, gSystem, gtutdir, TString::Index(), TProof::IsLite(), TProofMgr::Ls(), TSystem::MakeDirectory(), TProofMgr::Md5sum(), TProofMgr::More(), TProofMgr::PutFile(), PutPoint(), TSystem::RedirectOutput(), TList::Remove(), TString::Remove(), SafeDelete, TMacro::SaveSource(), TProofMgr::Stat(), testMore(), and TSystem::Unlink().

Referenced by stressProof().

Int_t PT_CheckH1	(	TQueryResult *	qr,
		Int_t	irun = 0
	)

Definition at line 873 of file stressProof.cxx.

References TMath::Abs(), TQueryResult::GetEntries(), TH1::GetEntries(), TH1::GetMean(), TQueryResult::GetOutputList(), h2, hdmd, Long64_t, out, and PutPoint().

Referenced by PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), and PT_H1SimpleAsync().

Int_t PT_CheckSimple	(	TQueryResult *	qr,
		Long64_t	nevt,
		Int_t	nhist
	)

Definition at line 820 of file stressProof.cxx.

References TMath::Abs(), Form(), TQueryResult::GetEntries(), TQueryResult::GetOutputList(), hist, i, out, PutPoint(), and TMath::Sqrt().

Referenced by PT_H1SimpleAsync(), and PT_Simple().

Int_t PT_DataSets

(

void *

)

Definition at line 1387 of file stressProof.cxx.

References TFileCollection::Add(), TString::Data(), fc, TString::Format(), TProof::GetDataSets(), TObjString::GetName(), TCollection::GetSize(), gh1file, gh1ok, gh1src, gProof, gSkipDataSetTest, i, PT_H1AssertFiles(), PutPoint(), TProof::RegisterDataSet(), TProof::RemoveDataSet(), TProof::ShowDataSets(), TFileCollection::Update(), and TProof::VerifyDataSet().

Referenced by stressProof().

Int_t PT_Event

(

void *

)

Definition at line 1612 of file stressProof.cxx.

References TMath::Abs(), TList::Clear(), TString::Data(), TList::FindObject(), TQueryResult::GetEntries(), TH1::GetEntries(), TH1::GetMean(), TProof::GetOutputList(), TProof::GetQueryResult(), TProof::GetQueryResults(), TH1::GetRMS(), gEventSel, gProof, histo, Long64_t, PrintStressProgress(), TProof::Process(), PutPoint(), TProof::SetPrintProgress(), and TMath::Sqrt().

Referenced by stressProof().

Int_t PT_GetLogs

(

void *

)

Definition at line 1033 of file stressProof.cxx.

References TProofLog::GetListOfLogs(), TProofMgr::GetSessionLogs(), TCollection::GetSize(), TProof::Mgr(), PT_Open_Args_t::nwrks, PutPoint(), and PT_Open_Args_t::url.

Referenced by stressProof().

Int_t PT_H1AssertFiles

(

const char *

h1src

)

Definition at line 763 of file stressProof.cxx.

References TSystem::AccessPathName(), TFile::Cp(), TString::Data(), TString::Format(), gh1file, gh1ok, gh1src, glogfile, gRH, gSystem, gtutdir, i, kTRUE, TSystem::MakeDirectory(), and TSystem::RedirectOutput().

Referenced by PT_DataSets(), PT_H1FileCollection(), PT_H1Http(), and PT_H1SimpleAsync().

Int_t PT_H1DataSet

(

void *

)

Definition at line 1231 of file stressProof.cxx.

References AssertParallelUnzip(), TList::Clear(), TString::Data(), TProof::GetQueryResult(), TProof::GetQueryResults(), gH1Cnt, gH1Sel, gH1Time, gProof, gSkipDataSetTest, gTimer, PrintStressProgress(), TProof::Process(), PT_CheckH1(), PutPoint(), TStopwatch::RealTime(), TProof::SetPrintProgress(), TStopwatch::Start(), and TStopwatch::Stop().

Referenced by stressProof().

Int_t PT_H1FileCollection

(

void *

)

Definition at line 1165 of file stressProof.cxx.

References TFileCollection::Add(), AssertParallelUnzip(), TList::Clear(), TString::Data(), TProof::DeleteParameters(), fc, TString::Format(), TProof::GetQueryResult(), TProof::GetQueryResults(), gH1Cnt, gh1file, gh1ok, gH1Sel, gh1src, gH1Time, gProof, gTimer, i, PrintStressProgress(), TProof::Process(), PT_CheckH1(), PT_H1AssertFiles(), PutPoint(), TStopwatch::RealTime(), TProof::SetParameter(), TProof::SetPrintProgress(), TStopwatch::Start(), TStopwatch::Stop(), and strategy.

Referenced by stressProof().

Int_t PT_H1Http

(

void *

)

Definition at line 1110 of file stressProof.cxx.

References TChain::Add(), AssertParallelUnzip(), chain, TList::Clear(), TString::Data(), TString::Format(), TProof::GetQueryResult(), TProof::GetQueryResults(), gH1Cnt, gh1file, gh1ok, gH1Sel, gh1src, gH1Time, gProof, gTimer, i, PrintStressProgress(), TChain::Process(), PT_CheckH1(), PT_H1AssertFiles(), PutPoint(), TStopwatch::RealTime(), TProof::RemoveChain(), TProof::SetPrintProgress(), TChain::SetProof(), TStopwatch::Start(), and TStopwatch::Stop().

Referenced by stressProof().

Int_t PT_H1MultiDataSet

(

void *

)

Definition at line 1273 of file stressProof.cxx.

References AssertParallelUnzip(), TList::Clear(), TString::Data(), TProof::GetQueryResult(), TProof::GetQueryResults(), gH1Cnt, gH1Sel, gH1Time, gProof, gSkipDataSetTest, gTimer, PrintStressProgress(), TProof::Process(), PT_CheckH1(), PutPoint(), TStopwatch::RealTime(), TProof::SetPrintProgress(), TStopwatch::Start(), and TStopwatch::Stop().

Referenced by stressProof().

Int_t PT_H1MultiDSetEntryList

(

void *

)

Definition at line 1315 of file stressProof.cxx.

References AssertParallelUnzip(), TList::Clear(), TString::Data(), TProof::GetInputList(), TProof::GetQueryResult(), TProof::GetQueryResults(), gH1Cnt, gH1Sel, gH1Time, gProof, gSkipDataSetTest, gSystem, gTimer, o, PrintStressProgress(), TProof::Process(), PT_CheckH1(), PutPoint(), TStopwatch::RealTime(), TList::Remove(), TProof::SetPrintProgress(), TStopwatch::Start(), TStopwatch::Stop(), and TSystem::Unlink().

Referenced by stressProof().

Int_t PT_H1SimpleAsync

(

void *

arg

)

Definition at line 1977 of file stressProof.cxx.

References TFileCollection::Add(), AssertParallelUnzip(), TList::Clear(), TString::Data(), fc, TString::Format(), TNamed::GetName(), TProof::GetQueryResult(), TProof::GetQueryResults(), TQueryResult::GetSelecImp(), TCollection::GetSize(), TNamed::GetTitle(), gH1Cnt, gh1file, gh1ok, gH1Sel, gh1src, gH1Time, gProof, gSimpleCnt, gSimpleSel, gSimpleTime, gSystem, gTimedOut, i, TSystem::InnerLoop(), TProof::IsIdle(), TProof::IsLite(), kFALSE, kIterBackward, Long64_t, TCollection::Print(), PrintStressProgress(), TProof::Process(), PT_CheckH1(), PT_CheckSimple(), PT_H1AssertFiles(), PutPoint(), TProof::Remove(), TProof::Retrieve(), TProof::SetParameter(), TProof::SetPrintProgress(), strategy, and t.

Referenced by stressProof().

Int_t PT_InputData

(

void *

)

Definition at line 1680 of file stressProof.cxx.

References TMath::Abs(), TList::Add(), TProof::AddInput(), TProof::AddInputData(), TList::Clear(), TProof::ClearInputData(), TString::Data(), TH2::FillRandom(), TList::FindObject(), TH1::GetMean(), TProof::GetOutputList(), TProof::GetQueryResult(), TProof::GetQueryResults(), TH1::GetRMS(), glogfile, gProof, gSystem, gTestsSel, h1, h2, TObject::kSingleKey, kTRUE, Long64_t, TFile::Open(), PrintStressProgress(), TProof::Process(), PutPoint(), TProof::SetInputDataFile(), TCollection::SetName(), TCollection::SetOwner(), TProof::SetPrintProgress(), stat, TSystem::Unlink(), and TCollection::Write().

Referenced by stressProof().

Int_t PT_Open

(

void *

)

Definition at line 939 of file stressProof.cxx.

References TSystem::AccessPathName(), TString::Data(), TSystem::DirName(), TString::Form(), TString::Format(), UserGroup_t::fUser, gDynamicStartup, gEnv, TMacro::GetLineWith(), getProof(), TObjString::GetString(), TSystem::GetUid(), TSystem::GetUserInfo(), glogfile, gProof, gRH, gRHAdmin, gsandbox, gSystem, gtutdir, kTRUE, TSystem::mkdir(), PT_Open_Args_t::nwrks, p, TProof::Print(), PutPoint(), TSystem::RedirectOutput(), TEnv::SetValue(), TSystem::TempDirectory(), TString::Tokenize(), and PT_Open_Args_t::url.

Referenced by stressProof().

Int_t PT_PackageArguments

(

void *

)

Definition at line 1797 of file stressProof.cxx.

References TMath::Abs(), TList::Add(), TList::Clear(), TProof::ClearPackage(), TString::Data(), TProof::DeleteParameters(), TProof::EnablePackage(), TSystem::ExpandPathName(), TList::FindObject(), TProof::GetListOfPackages(), TProof::GetOutputList(), TProof::GetQueryResult(), TProof::GetQueryResults(), gProof, gSystem, gTestsSel, Long64_t, PrintStressProgress(), TProof::Process(), PutPoint(), TProof::SetParameter(), TProof::SetPrintProgress(), stat, and TProof::UploadPackage().

Referenced by stressProof().

Int_t PT_Packages

(

void *

)

Definition at line 1531 of file stressProof.cxx.

References TProof::ClearPackage(), TProof::ClearPackages(), TString::Data(), TProof::EnablePackage(), TSystem::ExpandPathName(), TProof::GetListOfEnabledPackages(), TProof::GetListOfPackages(), TCollection::GetSize(), gProof, gSystem, pack(), PutPoint(), and TProof::UploadPackage().

Referenced by stressProof().

Int_t PT_Simple

(

void *

smg = 0

)

Definition at line 1064 of file stressProof.cxx.

References TList::Clear(), TString::Data(), TProof::DeleteParameters(), TProof::GetQueryResult(), TProof::GetQueryResults(), gProof, gSimpleCnt, gSimpleSel, gSimpleTime, gTimer, Long64_t, PrintStressProgress(), TProof::Process(), PT_CheckSimple(), PutPoint(), TStopwatch::RealTime(), TProof::SetParameter(), TProof::SetPrintProgress(), TStopwatch::Start(), and TStopwatch::Stop().

Referenced by stressProof().

Int_t PutPoint

(

)

Definition at line 278 of file stressProof.cxx.

References gpoints.

Referenced by PT_AdminFunc(), PT_CheckH1(), PT_CheckSimple(), PT_DataSets(), PT_Event(), PT_GetLogs(), PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), PT_H1SimpleAsync(), PT_InputData(), PT_Open(), PT_PackageArguments(), PT_Packages(), PT_Simple(), and ProofTest::Run().

void stressProof	(	const char *	url = "proof://localhost:40000",
		Int_t	nwrks = -1,
		Int_t	verbose = 1,
		const char *	logfile = 0,
		Bool_t	dyn = kFALSE,
		Bool_t	skipds = kTRUE,
		Int_t	test = -1,
		const char *	h1pfx = 0
	)

Definition at line 488 of file stressProof.cxx.

References TSystem::AccessPathName(), TList::Add(), TString::BeginsWith(), CleanupSelector(), TProof::Close(), TString::Contains(), TString::Data(), TSystem::DirName(), TSystem::ExpandPathName(), fclose(), TList::FindObject(), flog, fopen, gDynamicStartup, gEnv, TProof::GetCpuTime(), TUrl::GetHost(), Getline(), TNamed::GetName(), TUrl::GetPort(), TProof::GetStatistics(), TROOT::GetSvnBranch(), TROOT::GetSvnRevision(), TNamed::GetTitle(), TROOT::GetVersion(), gEventSel, gh1ok, gH1Sel, gh1src, glogfile, gProof, gROOT, gSelectors, gSimpleSel, gSkipDataSetTest, gStd_Old, gSystem, gTestsSel, gUseParallelUnzip, gverbose, TROOT::IsBatch(), TProof::IsLite(), kFALSE, kFileExists, killXrootdAt(), kTRUE, kWritePermission, PT_AdminFunc(), PT_DataSets(), PT_Event(), PT_GetLogs(), PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), PT_H1SimpleAsync(), PT_InputData(), PT_Open(), PT_PackageArguments(), PT_Packages(), PT_Simple(), TString::ReplaceAll(), TIter::Reset(), sel, TEnv::SetValue(), t, TSystem::TempDirectory(), TSystem::TempFileName(), TSystem::Unlink(), and urldef.

Referenced by main().

---

Variable Documentation

Bool_t gDynamicStartup = kFALSE [static]

Definition at line 142 of file stressProof.cxx.

Referenced by main(), PT_Open(), and stressProof().

TString gEventSel("$ROOTSYS/tutorials/proof/ProofEvent.C") [static]

Referenced by PT_Event(), and stressProof().

Int_t gH1Cnt = 0 [static]

Definition at line 138 of file stressProof.cxx.

Referenced by PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), and PT_H1SimpleAsync().

const char* gh1file[] = { "dstarmb.root", "dstarp1a.root", "dstarp1b.root", "dstarp2.root" } [static]

Definition at line 147 of file stressProof.cxx.

Referenced by PT_DataSets(), PT_H1AssertFiles(), PT_H1FileCollection(), PT_H1Http(), and PT_H1SimpleAsync().

Bool_t gh1ok = kTRUE [static]

Definition at line 146 of file stressProof.cxx.

Referenced by PT_DataSets(), PT_H1AssertFiles(), PT_H1FileCollection(), PT_H1Http(), PT_H1SimpleAsync(), and stressProof().

TString gH1Sel("$ROOTSYS/tutorials/tree/h1analysis.C") [static]

Referenced by PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), PT_H1SimpleAsync(), and stressProof().

TString gh1src("http://root.cern.ch/files/h1") [static]

Referenced by PT_DataSets(), PT_H1AssertFiles(), PT_H1FileCollection(), PT_H1Http(), PT_H1SimpleAsync(), and stressProof().

Double_t gH1Time = 0 [static]

Definition at line 136 of file stressProof.cxx.

Referenced by PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), and PT_H1SimpleAsync().

TString glogfile [static]

Definition at line 131 of file stressProof.cxx.

Referenced by PrintStressProgress(), PT_AdminFunc(), PT_H1AssertFiles(), PT_InputData(), PT_Open(), ProofTest::Run(), and stressProof().

Int_t gpoints = 0 [static]

Definition at line 132 of file stressProof.cxx.

Referenced by PutPoint(), ProofTest::Run(), and TGRegion::TGRegion().

RedirectHandle_t gRH [static]

Definition at line 134 of file stressProof.cxx.

RedirectHandle_t gRHAdmin [static]

Definition at line 135 of file stressProof.cxx.

Referenced by PT_AdminFunc(), and PT_Open().

TString gsandbox [static]

Definition at line 129 of file stressProof.cxx.

Referenced by PT_AdminFunc(), and PT_Open().

TList gSelectors [static]

Definition at line 150 of file stressProof.cxx.

Referenced by stressProof().

Int_t gSimpleCnt = 0 [static]

Definition at line 139 of file stressProof.cxx.

Referenced by PT_H1SimpleAsync(), and PT_Simple().

TString gSimpleSel("$ROOTSYS/tutorials/proof/ProofSimple.C") [static]

Referenced by PT_H1SimpleAsync(), PT_Simple(), and stressProof().

Double_t gSimpleTime = 0 [static]

Definition at line 137 of file stressProof.cxx.

Referenced by PT_H1SimpleAsync(), and PT_Simple().

Bool_t gSkipDataSetTest = kTRUE [static]

Definition at line 143 of file stressProof.cxx.

Referenced by main(), PT_DataSets(), PT_H1DataSet(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), and stressProof().

PT_Packetizer_t gStd_Old = { "TPacketizer", 0 } [static]

Definition at line 485 of file stressProof.cxx.

Referenced by stressProof().

TString gTestsSel("$ROOTSYS/tutorials/proof/ProofTests.C") [static]

Referenced by PT_InputData(), PT_PackageArguments(), and stressProof().

Bool_t gTimedOut = kFALSE [static]

Definition at line 141 of file stressProof.cxx.

Referenced by PT_H1SimpleAsync().

TStopwatch gTimer [static]

Definition at line 140 of file stressProof.cxx.

TString gtutdir [static]

Definition at line 128 of file stressProof.cxx.

Referenced by PT_AdminFunc(), PT_H1AssertFiles(), and PT_Open().

Bool_t gUseParallelUnzip = kFALSE [static]

Definition at line 144 of file stressProof.cxx.

Referenced by AssertParallelUnzip(), main(), and stressProof().

Int_t gverbose = 1 [static]

Definition at line 130 of file stressProof.cxx.

Int_t totpoints = 53 [static]

Definition at line 133 of file stressProof.cxx.

Referenced by ProofTest::Run().

const char* urldef = "proof://localhost:40000" [static]

Definition at line 127 of file stressProof.cxx.

Referenced by main(), and stressProof().

---