TProof.h File Reference

#include "TProofMgr.h"
#include "TProofDebug.h"
#include "TString.h"
#include "TMacro.h"
#include "MessageTypes.h"
#include "TMD5.h"
#include "TRegexp.h"
#include "TSysEvtHandler.h"
#include "TUrl.h"
#include "TProofOutputList.h"
#include "TStopwatch.h"
#include "TVirtualMutex.h"
#include "TPackMgr.h"
#include <map>
#include <mutex>

Include dependency graph for TProof.h:

This graph shows which files directly or indirectly include this file:

Classes
struct	TProof::MD5Mod_t
struct	MD5Mod_t
class	TMergerInfo
class	TProof
	This class controls a Parallel ROOT Facility, PROOF, cluster. More...
class	TProofInputHandler
class	TProofInterruptHandler
class	TProofMergePrg
class	TProofProgressInfo
class	TSlaveInfo

Macros
#define	CANNOTUSE(x)   Info(x,"Not manager: cannot use this method")

Typedefs
typedef std::map< TString, MD5Mod_t >	FileMap_t
typedef void(*	PrintProgress_t) (Long64_t tot, Long64_t proc, Float_t proctime, Long64_t bytes)

Enumerations
enum	EBuildPackageOpt { kDontBuildOnClient = -2 , kBuildOnSlavesNoWait = -1 , kBuildAll = 0 , kCollectBuildResults = 1 }
enum	EProofCacheCommands {   kShowCache = 1 , kClearCache = 2 , kShowPackages = 3 , kClearPackages = 4 ,   kClearPackage = 5 , kBuildPackage = 6 , kLoadPackage = 7 , kShowEnabledPackages = 8 ,   kShowSubCache = 9 , kClearSubCache = 10 , kShowSubPackages = 11 , kDisableSubPackages = 12 ,   kDisableSubPackage = 13 , kBuildSubPackage = 14 , kUnloadPackage = 15 , kDisablePackage = 16 ,   kUnloadPackages = 17 , kDisablePackages = 18 , kListPackages = 19 , kListEnabledPackages = 20 ,   kLoadMacro = 21 }
enum	EProofClearData { kPurge = 0x1 , kUnregistered = 0x2 , kDataset = 0x4 , kForceClear = 0x8 }
enum	EProofDataSetCommands {   kUploadDataSet = 1 , kCheckDataSetName = 2 , kGetDataSets = 3 , kRegisterDataSet = 4 ,   kGetDataSet = 5 , kVerifyDataSet = 6 , kRemoveDataSet = 7 , kMergeDataSet = 8 ,   kShowDataSets = 9 , kGetQuota = 10 , kShowQuota = 11 , kSetDefaultTreeName = 12 ,   kCache = 13 , kRequestStaging = 14 , kStagingStatus = 15 , kCancelStaging = 16 }
enum	EProofShowQuotaOpt { kPerGroup = 0x1 , kPerUser = 0x2 }
enum	EProofWrkListAction { kActivateWorker = 1 , kDeactivateWorker = 2 }
enum	EQueryMode { kSync = 0 , kAsync = 1 }
enum	ERegisterOpt { kFailIfExists = 0 , kOverwriteIfExists = 1 , kMergeIfExists = 2 }
enum	ERunStatus { kRunning = 0 , kStopped = 1 , kAborted = 2 }
enum	ESendFileOpt {   kAscii = 0x0 , kBinary = 0x1 , kForce = 0x2 , kForward = 0x4 ,   kCpBin = 0x8 , kCp = 0x10 }
enum	ESlaves { kAll , kActive , kUnique , kAllUnique }
enum	EStatusBits {   kUsingSessionGui = (1ULL << ( 14 )) , kNewInputData = (1ULL << ( 15 )) , kIsClient = (1ULL << ( 16 )) , kIsMaster = (1ULL << ( 17 )) ,   kIsTopMaster = (1ULL << ( 18 )) , kUseProgressDialog = (1ULL << ( 19 )) }
enum	ESubMerger {   kOutputSize = 1 , kSendOutput = 2 , kBeMerger = 3 , kMergerDown = 4 ,   kStopMerging = 5 , kOutputSent = 6 }
enum	EUploadOpt {   kAppend = 0x1 , kOverwriteDataSet = 0x2 , kNoOverwriteDataSet = 0x4 , kOverwriteAllFiles = 0x8 ,   kOverwriteNoFiles = 0x10 , kAskUser = 0x0 }
enum	EUploadPackageOpt { kUntar = 0x0 , kRemoveOld = 0x1 }
enum	EUrgent {   kLocalInterrupt = -1 , kPing = 0 , kHardInterrupt = 1 , kSoftInterrupt ,   kShutdownInterrupt }

Functions
	~TProof () override
void	Activate (TList *slaves=0)
void	ActivateAsyncInput ()
Int_t	ActivateWorker (const char *ord, Bool_t save=kTRUE)
void	AddChain (TChain *chain)
Int_t	AddDynamicPath (const char *libpath, Bool_t onClient=kFALSE, TList *wrks=0, Bool_t doCollect=kTRUE)
static void	AddEnvVar (const char *name, const char *value)
void	AddFeedback (const char *name)
Int_t	AddIncludePath (const char *incpath, Bool_t onClient=kFALSE, TList *wrks=0, Bool_t doCollect=kTRUE)
void	AddInput (TObject *obj)
void	AddInputData (TObject *obj, Bool_t push=kFALSE)
Int_t	AddWorkers (TList *wrks)
Int_t	Archive (const char *queryref, const char *url=0)
Int_t	Archive (Int_t query, const char *url)
void	AskForOutput (TSlave *sl)
void	AskParallel ()
void	AskStatistics ()
static Int_t	AssertDataSet (TDSet *dset, TList *input, TDataSetManager *mgr, TString &emsg)
static void	AssertMacroPath (const char *macro)
Int_t	AssertPath (const char *path, Bool_t writable)
Int_t	Broadcast (const char *mess, Int_t kind, TList *slaves)
Int_t	Broadcast (const char *mess, Int_t kind=kMESS_STRING, ESlaves list=kActive)
Int_t	Broadcast (const TMessage &mess, ESlaves list=kActive)
Int_t	Broadcast (const TMessage &mess, TList *slaves)
Int_t	Broadcast (Int_t kind, ESlaves list=kActive)
Int_t	Broadcast (Int_t kind, TList *slaves)
Int_t	BroadcastFile (const char *file, Int_t opt, const char *rfile, TList *wrks)
Int_t	BroadcastFile (const char *file, Int_t opt, const char *rfile=0, ESlaves list=kAllUnique)
Int_t	BroadcastGroupPriority (const char *grp, Int_t priority, ESlaves list=kAllUnique)
Int_t	BroadcastGroupPriority (const char *grp, Int_t priority, TList *workers)
Int_t	BroadcastObject (const TObject *obj, Int_t kind, TList *slaves)
Int_t	BroadcastObject (const TObject *obj, Int_t kind=kMESS_OBJECT, ESlaves list=kActive)
Int_t	BroadcastRaw (const void *buffer, Int_t length, ESlaves list=kActive)
Int_t	BroadcastRaw (const void *buffer, Int_t length, TList *slaves)
void	Browse (TBrowser *b) override
Int_t	BuildPackage (const char *package, EBuildPackageOpt opt=kBuildAll, Int_t chkveropt=TPackMgr::kCheckROOT, TList *workers=0)
virtual Bool_t	CancelStagingDataSet (const char *dataset)
void	cd (Int_t id=-1)
Bool_t	CheckFile (const char *file, TSlave *sl, Long_t modtime, Int_t cpopt=(kCp|kCpBin))
static TClass *	Class ()
static const char *	Class_Name ()
static constexpr Version_t	Class_Version ()
void	CleanGDirectory (TList *ol)
Int_t	CleanupSession (const char *sessiontag)
virtual void	ClearCache (const char *file=0)
void	ClearData (UInt_t what=kUnregistered, const char *dsname=0)
void	ClearDataProgress (Int_t r, Int_t t)
virtual void	ClearDataSetCache (const char *dataset=0)
void	ClearFeedback ()
void	ClearInput ()
void	ClearInputData (const char *name)
void	ClearInputData (TObject *obj=0)
Int_t	ClearPackage (const char *package)
Int_t	ClearPackages ()
void	Close (Option_t *option="")
void	CloseProgressDialog ()
Int_t	Collect (const TSlave *sl, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
Int_t	Collect (ESlaves list=kActive, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
Int_t	Collect (TList *slaves, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
Int_t	Collect (TMonitor *mon, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
Int_t	CollectInputFrom (TSocket *s, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
TDrawFeedback *	CreateDrawFeedback ()
Bool_t	CreateMerger (TSlave *sl, Int_t port)
TSlave *	CreateSlave (const char *url, const char *ord, Int_t perf, const char *image, const char *workdir)
TSlave *	CreateSubmaster (const char *url, const char *ord, const char *image, const char *msd, Int_t nwk=1)
void	DataSetStatus (const char *msg, Bool_t status, Int_t done, Int_t total)
void	DeActivateAsyncInput ()
Int_t	DeactivateWorker (const char *ord, Bool_t save=kTRUE)
static const char *	DeclFileName ()
static void	DelEnvVar (const char *name)
void	DeleteDrawFeedback (TDrawFeedback *f)
void	DeleteParameters (const char *wildcard)
void	Detach (Option_t *opt="")
void	DisableGoAsyn ()
Int_t	DisablePackage (const char *package)
Int_t	DisablePackages ()
Int_t	DownloadPackage (const char *par, const char *dstdir=0)
Long64_t	DrawSelect (const char *dsetname, const char *varexp, const char *selection="", Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0, TObject *enl=0)
virtual Long64_t	DrawSelect (TDSet *dset, const char *varexp, const char *selection="", Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
virtual Int_t	Echo (const char *str)
virtual Int_t	Echo (const TObject *obj)
Int_t	EnablePackage (const char *package, Bool_t notOnClient=kFALSE, TList *workers=0)
Int_t	EnablePackage (const char *package, const char *loadopts, Bool_t notOnClient=kFALSE, TList *workers=0)
Int_t	EnablePackage (const char *package, TList *loadopts, Bool_t notOnClient=kFALSE, TList *workers=0)
Int_t	Exec (const char *cmd, Bool_t plusMaster=kFALSE)
Int_t	Exec (const char *cmd, const char *ord, Bool_t logtomacro=kFALSE)
Int_t	Exec (const char *cmd, ESlaves list, Bool_t plusMaster)
virtual Bool_t	ExistsDataSet (const char *dataset)
void	Feedback (TList *objs)
void	FinalizationDone ()
Long64_t	Finalize (const char *queryref, Bool_t force=kFALSE)
Long64_t	Finalize (Int_t query=-1, Bool_t force=kFALSE)
TList *	FindDataSets (const char *searchString, const char *optStr="")
Int_t	FindNextFreeMerger ()
TSlave *	FindSlave (TSocket *s) const
virtual void	FindUniqueSlaves ()
Int_t	GetActiveMergersCount ()
Long64_t	GetBytesRead () const
Int_t	GetClientProtocol () const
const char *	GetConfDir () const
const char *	GetConfFile () const
Float_t	GetCpuTime () const
const char *	GetDataPoolUrl () const
virtual TFileCollection *	GetDataSet (const char *dataset, const char *optStr="")
TMap *	GetDataSetQuota (const char *optStr="")
virtual TMap *	GetDataSets (const char *uri="", const char *optStr="")
static TList *	GetDataSetSrvMaps (const TString &srvmaps)
TList *	GetEnabledPackages () const
TString	Getenv (const char *env, const char *ord="0")
static const TList *	GetEnvVars ()
TList *	GetFeedbackList () const
static Bool_t	GetFileInCmd (const char *cmd, TString &fn)
const char *	GetGroup () const
const char *	GetImage () const
static Int_t	GetInputData (TList *input, const char *cachedir, TString &emsg)
TList *	GetInputList ()
TMacro *	GetLastLog ()
TList *	GetListOfActiveSlaves () const
TList *	GetListOfBadSlaves () const
TList *	GetListOfEnabledPackages ()
TList *	GetListOfInactiveSlaves () const
TList *	GetListOfPackages ()
virtual TList *	GetListOfQueries (Option_t *opt="")
TList *	GetListOfSlaveInfos ()
TList *	GetListOfSlaves () const
TList *	GetListOfUniqueSlaves () const
TList *	GetLoadedMacros () const
void	GetLog (Int_t start=-1, Int_t end=-1)
Int_t	GetLogLevel () const
TMacro *	GetMacroLog ()
TProofMgr *	GetManager ()
const char *	GetMaster () const
void	GetMaxQueries ()
TFileCollection *	GetMissingFiles (TQueryResult *qr=0)
Int_t	GetNumberOfActiveSlaves () const
Int_t	GetNumberOfBadSlaves () const
Int_t	GetNumberOfDrawQueries ()
Int_t	GetNumberOfInactiveSlaves () const
Int_t	GetNumberOfQueries ()
Int_t	GetNumberOfSlaves () const
Int_t	GetNumberOfUniqueSlaves () const
TObject *	GetOutput (const char *name)
static TObject *	GetOutput (const char *name, TList *out)
TList *	GetOutputList ()
TList *	GetOutputNames ()
Int_t	GetParallel () const
TObject *	GetParameter (const char *par) const
static Int_t	GetParameter (TCollection *c, const char *par, Double_t &value)
static Int_t	GetParameter (TCollection *c, const char *par, Int_t &value)
static Int_t	GetParameter (TCollection *c, const char *par, Long64_t &value)
static Int_t	GetParameter (TCollection *c, const char *par, Long_t &value)
static Int_t	GetParameter (TCollection *c, const char *par, TString &value)
TVirtualProofPlayer *	GetPlayer () const
Int_t	GetPort () const
TPluginHandler *	GetProgressDialog () const
EQueryMode	GetQueryMode (Option_t *mode=0) const
Int_t	GetQueryReference (Int_t qry, TString &ref)
TQueryResult *	GetQueryResult (const char *ref=0)
TList *	GetQueryResults ()
Int_t	GetRC (const char *RCenv, Double_t &env, const char *ord="0")
Int_t	GetRC (const char *RCenv, Int_t &env, const char *ord="0")
Int_t	GetRC (const char *RCenv, TString &env, const char *ord="0")
Float_t	GetRealTime () const
Int_t	GetRemoteProtocol () const
ERunStatus	GetRunStatus () const
Int_t	GetSandbox (TString &sb, Bool_t assert=kFALSE, const char *rc=0)
Int_t	GetSeqNum () const
Int_t	GetSessionID () const
const char *	GetSessionTag () const
virtual TFileCollection *	GetStagingStatusDataSet (const char *dataset)
void	GetStatistics (Bool_t verbose=kFALSE)
Int_t	GetStatus () const
virtual TTree *	GetTreeHeader (TDSet *tdset)
const char *	GetUrl ()
const char *	GetUser () const
const char *	GetWorkDir () const
void	GoAsynchronous ()
Int_t	GoMoreParallel (Int_t nWorkersToAdd)
Int_t	GoParallel (Int_t nodes, Bool_t accept=kFALSE, Bool_t random=kFALSE)
Int_t	HandleInputMessage (TSlave *wrk, TMessage *m, Bool_t deactonfail=kFALSE)
void	HandleLibIncPath (const char *what, Bool_t add, const char *dirs)
Int_t	HandleOutputOptions (TString &opt, TString &target, Int_t action)
void	HandleSubmerger (TMessage *mess, TSlave *sl)
Int_t	Init (const char *masterurl, const char *conffile, const char *confdir, Int_t loglevel, const char *alias=0)
void	InitMembers ()
void	Interrupt (EUrgent type, ESlaves list=kActive)
void	InterruptCurrentMonitor ()
TClass *	IsA () const override
Bool_t	IsDataReady (Long64_t &totalbytes, Long64_t &bytesready)
Bool_t	IsEndMaster () const
Bool_t	IsFolder () const override
Bool_t	IsIdle () const
Bool_t	IsLite () const
Bool_t	IsMaster () const
Bool_t	IsParallel () const
Bool_t	IsProofd () const
Bool_t	IsSync () const
Bool_t	IsTty () const
Bool_t	IsValid () const
Bool_t	IsWaiting () const
virtual Int_t	Load (const char *macro, Bool_t notOnClient=kFALSE, Bool_t uniqueOnly=kTRUE, TList *wrks=0)
Int_t	LoadPackage (const char *package, Bool_t notOnClient=kFALSE, TList *loadopts=0, TList *workers=0)
void	LogMessage (const char *msg, Bool_t all)
static void	LogViewer (const char *url=0, Int_t sessionidx=0)
virtual TVirtualProofPlayer *	MakePlayer (const char *player=0, TSocket *s=0)
void	MarkBad (TSlave *wrk, const char *reason=0)
void	MarkBad (TSocket *s, const char *reason=0)
static TProofMgr *	Mgr (const char *url)
Int_t	ModifyWorkerLists (const char *ord, Bool_t add, Bool_t save)
void	NotifyLogMsg (const char *msg, const char *sfx="\n")
static TProof *	Open (const char *url=0, const char *conffile=0, const char *confdir=0, Int_t loglevel=0)
void	operator= (const TProof &)
void	ParseConfigField (const char *config)
Int_t	Ping ()
Int_t	Ping (ESlaves list)
virtual Int_t	PollForNewWorkers ()
void	PrepareInputDataFile (TString &dataFile)
void	Print (Option_t *option="") const override
void	PrintProgress (Long64_t total, Long64_t processed, Float_t procTime=-1., Long64_t bytesread=-1)
virtual Long64_t	Process (const char *dsetname, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0, TObject *enl=0)
virtual Long64_t	Process (const char *dsetname, TSelector *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0, TObject *enl=0)
virtual Long64_t	Process (const char *selector, Long64_t nentries, Option_t *option="")
virtual Long64_t	Process (TDSet *dset, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
virtual Long64_t	Process (TDSet *dset, TSelector *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
virtual Long64_t	Process (TFileCollection *fc, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
virtual Long64_t	Process (TFileCollection *fc, TSelector *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
virtual Long64_t	Process (TSelector *selector, Long64_t nentries, Option_t *option="")
void	Progress (Long64_t total, Long64_t processed)
void	Progress (Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
void	Progress (Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti, Int_t actw, Int_t tses, Float_t eses)
Bool_t	Prompt (const char *p)
void	PutLog (TQueryResult *qr)
void	QueryResultReady (const char *ref)
TProof TNamed, TQObject	R__DEPRECATED (6, 38, "Legacy interactive distributed processing engine. Use RDataFrame instead.")
void	RecvLogFile (TSocket *s, Int_t size)
void	RedirectWorker (TSocket *s, TSlave *sl, Int_t output_size)
virtual Bool_t	RegisterDataSet (const char *name, TFileCollection *dataset, const char *optStr="")
void	ReleaseMonitor (TMonitor *mon)
Int_t	Remove (const char *queryref, Bool_t all=kFALSE)
Int_t	Remove (Int_t query, Bool_t all=kFALSE)
void	RemoveChain (TChain *chain)
virtual Int_t	RemoveDataSet (const char *dataset, const char *optStr="")
Int_t	RemoveDynamicPath (const char *libpath, Bool_t onClient=kFALSE)
void	RemoveFeedback (const char *name)
Int_t	RemoveIncludePath (const char *incpath, Bool_t onClient=kFALSE)
Int_t	RemoveWorkers (TList *wrks)
virtual Bool_t	RequestStagingDataSet (const char *dataset)
static void	Reset (const char *url, Bool_t hard=kFALSE)
static void	ResetEnvVars ()
void	ResetMergePrg ()
void	ResetMergers ()
void	ResetProgressDialog (const char *sel, Int_t sz, Long64_t fst, Long64_t ent)
void	ResetProgressDialogStatus ()
Int_t	RestoreActiveList ()
Int_t	Retrieve (const char *queryref, const char *path=0)
Int_t	Retrieve (Int_t query, const char *path=0)
void	SaveActiveList ()
static Int_t	SaveInputData (TQueryResult *qr, const char *cachedir, TString &emsg)
Int_t	SavePerfTree (const char *pf=0, const char *qref=0)
virtual void	SaveWorkerInfo ()
Int_t	SendCommand (const char *cmd, ESlaves list=kActive)
Int_t	SendCurrentState (ESlaves list=kActive)
Int_t	SendCurrentState (TList *list)
void	SendDataSetStatus (const char *msg, UInt_t n, UInt_t tot, Bool_t st)
Int_t	SendFile (const char *file, Int_t opt=(kBinary|kForward|kCp|kCpBin), const char *rfile=0, TSlave *sl=0)
Int_t	SendGroupView ()
Bool_t	SendingLogToWindow () const
Int_t	SendInitialState ()
static Int_t	SendInputData (TQueryResult *qr, TProof *p, TString &emsg)
virtual void	SendInputDataFile ()
void	SendLogToWindow (Bool_t mode)
Int_t	SendObject (const TObject *obj, ESlaves list=kActive)
Int_t	SendPrint (Option_t *option="")
void	SetActive (Bool_t=kTRUE)
virtual void	SetAlias (const char *alias="")
void	SetDataPoolUrl (const char *url)
virtual Int_t	SetDataSetTreeName (const char *dataset, const char *treename)
void	SetDrawFeedbackOption (TDrawFeedback *f, Option_t *opt)
void	SetDSet (TDSet *dset)
void	SetFeedback (TString &opt, TString &optfb, Int_t action)
void	SetInputDataFile (const char *datafile)
void	SetLogLevel (Int_t level, UInt_t mask=TProofDebug::kAll)
void	SetManager (TProofMgr *mgr)
void	SetMaxDrawQueries (Int_t max)
void	SetMonitor (TMonitor *mon=0, Bool_t on=kTRUE)
Int_t	SetParallel (Int_t nodes=-1, Bool_t random=kFALSE)
Int_t	SetParallelSilent (Int_t nodes, Bool_t random=kFALSE)
void	SetParameter (const char *par, const char *value)
void	SetParameter (const char *par, Double_t value)
void	SetParameter (const char *par, Int_t value)
void	SetParameter (const char *par, Long64_t value)
void	SetParameter (const char *par, Long_t value)
void	SetPerfTree (const char *pf="perftree.root", Bool_t withWrks=kFALSE)
void	SetPlayer (TVirtualProofPlayer *player)
void	SetPrintProgress (PrintProgress_t pp)
void	SetProgressDialog (Bool_t on=kTRUE)
void	SetQueryMode (EQueryMode mode)
void	SetRealTimeLog (Bool_t on=kTRUE)
void	SetRunStatus (ERunStatus rst)
void	SetupWorkersEnv (TList *wrks, Bool_t increasingpool=kFALSE)
virtual void	ShowCache (Bool_t all=kFALSE)
virtual void	ShowData ()
void	ShowDataSet (const char *dataset="", const char *opt="filter:SsCc")
virtual void	ShowDataSetCache (const char *dataset=0)
void	ShowDataSetQuota (Option_t *opt=0)
virtual void	ShowDataSets (const char *uri="", const char *optStr="")
void	ShowEnabledPackages (Bool_t all=kFALSE)
void	ShowFeedback () const
void	ShowLog (const char *queryref)
void	ShowLog (Int_t qry=-1)
void	ShowMissingFiles (TQueryResult *qr=0)
void	ShowPackages (Bool_t all=kFALSE, Bool_t redirlog=kFALSE)
void	ShowParameters (const char *wildcard="PROOF_*") const
void	ShowQueries (Option_t *opt="")
virtual void	ShowStagingStatusDataSet (const char *dataset, const char *optStr="filter:SsCc")
static void *	SlaveStartupThread (void *arg)
virtual Bool_t	StartSlaves (Bool_t attach=kFALSE)
void	StartupMessage (const char *msg, Bool_t status, Int_t done, Int_t total)
void	StopProcess (Bool_t abort, Int_t timeout=-1)
void	Streamer (TBuffer &) override
void	StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
static void	SystemCmd (const char *cmd, Int_t fdout)
void	TerminateWorker (const char *ord)
void	TerminateWorker (TSlave *wrk)
void	Touch ()
	TProof ()
	TProof (const char *masterurl, const char *conffile=kPROOF_ConfFile, const char *confdir=kPROOF_ConfDir, Int_t loglevel=0, const char *alias=0, TProofMgr *mgr=0)
	TProof (const TProof &)
Int_t	UnloadPackage (const char *package)
Int_t	UnloadPackages ()
void	UpdateDialog ()
Int_t	UploadDataSet (const char *, const char *, const char *=0, Int_t=0, TList *=0)
Int_t	UploadDataSet (const char *, TList *, const char *=0, Int_t=0, TList *=0)
Int_t	UploadDataSetFromFile (const char *, const char *, const char *=0, Int_t=0, TList *=0)
Int_t	UploadPackage (const char *par, EUploadPackageOpt opt=kUntar, TList *workers=0)
Bool_t	UseDynamicStartup () const
virtual void	ValidateDSet (TDSet *dset)
virtual Int_t	VerifyDataSet (const char *dataset, const char *optStr="")
Int_t	VerifyDataSetParallel (const char *uri, const char *optStr)

Variables
TMonitor *	fActiveMonitor
TList *	fActiveSlaves
TString	fActiveSlavesSaved
TMonitor *	fAllMonitor
TMonitor *	fAllUniqueMonitor
TList *	fAllUniqueSlaves
TList *	fAvailablePackages
TList *	fBadSlaves
Long64_t	fBytesRead
Long64_t	fBytesReady
TList *	fChains
Int_t	fCheckFileStatus
std::recursive_mutex	fCloseMutex
Int_t	fCollectTimeout
TString	fConfDir
TString	fConfFile
Float_t	fCpuTime
TMonitor *	fCurrentMonitor
TString	fDataPoolUrl
Bool_t	fDataReady
Int_t	fDrawQueries
TDSet *	fDSet
Bool_t	fDynamicStartup
TList *	fEnabledPackages
TList *	fEnabledPackagesOnCluster
Bool_t	fEndMaster
TList *	fFeedback
FileMap_t	fFileMap
Bool_t	fFinalizationRunning
static TPluginHandler *	fgLogViewer
static TList *	fgProofEnvList
TString	fGroup
TString	fImage
TList *	fInactiveSlaves
TList *	fInputData
TString	fInputDataFile
TSignalHandler *	fIntHandler
Bool_t	fIsPollingWorkers
Bool_t	fIsWaiting
Int_t	fLastAssignedMerger
Long64_t	fLastPollWorkers_s
TList *	fLoadedMacros
TString	fLogFileName
FILE *	fLogFileR
FILE *	fLogFileW
Int_t	fLogLevel
Bool_t	fLogToWindowOnly
TMacro	fMacroLog
TProofMgr *	fManager
TString	fMaster
Bool_t	fMasterServ
Int_t	fMaxDrawQueries
TProofMergePrg	fMergePrg
TList *	fMergers
Bool_t	fMergersByHost
Int_t	fMergersCount
Bool_t	fMergersSet
TList *	fNonUniqueMasters
Int_t	fNotIdle
Int_t	fOtherQueries
TProofOutputList	fOutputList
TPackMgr *	fPackMgr
TString	fPerfTree
TVirtualProofPlayer *	fPlayer
Float_t	fPrepTime
PrintProgress_t	fPrintProgress
TPluginHandler *	fProgressDialog
Bool_t	fProgressDialogStarted
Int_t	fProtocol
TList *	fQueries
EQueryMode	fQueryMode
TStopwatch	fQuerySTW
Float_t	fRealTime
TList *	fRecvMessages
Int_t	fRedirectNext
Bool_t	fRedirLog
TList *	fRunningDSets
ERunStatus	fRunStatus
Bool_t	fSaveLogToMacro
TSelector *	fSelector
Bool_t	fSendGroupView
	list returned by kPROOF_GETSLAVEINFO
Int_t	fSeqNum
TProofMgr::EServType	fServType
Int_t	fSessionID
TList *	fSlaveInfo
TList *	fSlaves
Int_t	fStatus
Bool_t	fSync
TList *	fTerminatedSlaveInfos
Long64_t	fTotalBytes
Bool_t	fTty
TMonitor *	fUniqueMonitor
TList *	fUniqueSlaves
TUrl	fUrl
Bool_t	fValid
TList *	fWaitingSlaves
TString	fWorkDir
Int_t	fWorkersToMerge
TList *	fWrksOutputReady
R__EXTERN TProof *	gProof
const char *const	kCP = "/bin/cp -fp"
const char *const	kGUNZIP = "gunzip"
const char *const	kLS = "/bin/ls -l"
const char *const	kPROOF_CacheDir = "cache"
const char *const	kPROOF_CacheLockFile = "proof-cache-lock-"
const char *const	kPROOF_ConfDir = "/usr/local/root"
const char *const	kPROOF_ConfFile = "proof.conf"
const char *const	kPROOF_DataDir = "data"
const char *const	kPROOF_DataSetDir = "datasets"
const Long64_t	kPROOF_DynWrkPollInt_s = 10
const char *const	kPROOF_InputDataFile = "inputdata.root"
const char *const	kPROOF_MissingFiles = "MissingFiles"
const char *const	kPROOF_PackageLockFile = "proof-package-lock-"
const char *const	kPROOF_PackDir = "packages"
const char *const	kPROOF_PackDownloadDir = "downloaded"
const Int_t	kPROOF_Port = 1093
const Int_t	kPROOF_Protocol = 37
const char *const	kPROOF_QueryDir = "queries"
const char *const	kPROOF_QueryLockFile = "proof-query-lock-"
const char *const	kPROOF_TerminateWorker = "+++ terminating +++"
const char *const	kPROOF_WorkDir = ".proof"
const char *const	kPROOF_WorkerIdleTO = "+++ idle-timeout +++"
const char *const	kRM = "/bin/rm -rf"
const char *const	kUNTAR = "%s -c %s/%s | (cd %s; tar xf -)"
const char *const	kUNTAR2 = "%s -c %s | (cd %s; tar xf -)"
const char *const	kUNTAR3 = "%s -c %s | (tar xf -)"

Macro Definition Documentation

CANNOTUSE

#define CANNOTUSE

(

x

)

Info(x,"Not manager: cannot use this method")

Definition at line 44 of file TProof.h.

Typedef Documentation

FileMap_t

typedef std::map<TString, MD5Mod_t> FileMap_t

private

Definition at line 184 of file TProof.h.

PrintProgress_t

typedef void(* PrintProgress_t) (Long64_t tot, Long64_t proc, Float_t proctime, Long64_t bytes)

Definition at line 158 of file TProof.h.

Enumeration Type Documentation

EBuildPackageOpt

enum EBuildPackageOpt

private

Enumerator
kDontBuildOnClient
kBuildOnSlavesNoWait
kBuildAll
kCollectBuildResults

Definition at line 136 of file TProof.h.

EProofCacheCommands

enum EProofCacheCommands

private

Enumerator
kShowCache
kClearCache
kShowPackages
kClearPackages
kClearPackage
kBuildPackage
kLoadPackage
kShowEnabledPackages
kShowSubCache
kClearSubCache
kShowSubPackages
kDisableSubPackages
kDisableSubPackage
kBuildSubPackage
kUnloadPackage
kDisablePackage
kUnloadPackages
kDisablePackages
kListPackages
kListEnabledPackages
kLoadMacro

Definition at line 83 of file TProof.h.

EProofClearData

enum EProofClearData

Enumerator
kPurge
kUnregistered
kDataset
kForceClear

Definition at line 68 of file TProof.h.

EProofDataSetCommands

enum EProofDataSetCommands

private

Enumerator
kUploadDataSet
kCheckDataSetName
kGetDataSets
kRegisterDataSet
kGetDataSet
kVerifyDataSet
kRemoveDataSet
kMergeDataSet
kShowDataSets
kGetQuota
kShowQuota
kSetDefaultTreeName
kCache
kRequestStaging
kStagingStatus
kCancelStaging

Definition at line 106 of file TProof.h.

EProofShowQuotaOpt

enum EProofShowQuotaOpt

private

Enumerator
kPerGroup
kPerUser

Definition at line 142 of file TProof.h.

EProofWrkListAction

enum EProofWrkListAction

private

Enumerator
kActivateWorker
kDeactivateWorker

Definition at line 132 of file TProof.h.

EQueryMode

enum EQueryMode

Enumerator
kSync
kAsync

Definition at line 32 of file TProof.h.

ERegisterOpt

enum ERegisterOpt

Enumerator
kFailIfExists
kOverwriteIfExists
kMergeIfExists

Definition at line 44 of file TProof.h.

ERunStatus

enum ERunStatus

Enumerator
kRunning
kStopped
kAborted

Definition at line 53 of file TProof.h.

ESendFileOpt

enum ESendFileOpt

private

Enumerator
kAscii
kBinary
kForce
kForward
kCpBin
kCp

Definition at line 124 of file TProof.h.

ESlaves

enum ESlaves

protected

Enumerator
kAll
kActive
kUnique
kAllUnique

Definition at line 247 of file TProof.h.

EStatusBits

enum EStatusBits

Enumerator
kUsingSessionGui
kNewInputData
kIsClient
kIsMaster
kIsTopMaster
kUseProgressDialog

Definition at line 24 of file TProof.h.

ESubMerger

enum ESubMerger

Enumerator
kOutputSize
kSendOutput
kBeMerger
kMergerDown
kStopMerging
kOutputSent

Definition at line 59 of file TProof.h.

EUploadOpt

enum EUploadOpt

Enumerator
kAppend
kOverwriteDataSet
kNoOverwriteDataSet
kOverwriteAllFiles
kOverwriteNoFiles
kAskUser

Definition at line 36 of file TProof.h.

EUploadPackageOpt

enum EUploadPackageOpt

Enumerator
kUntar
kRemoveOld

Definition at line 49 of file TProof.h.

EUrgent

enum EUrgent

private

Enumerator
kLocalInterrupt
kPing
kHardInterrupt
kSoftInterrupt
kShutdownInterrupt

Definition at line 76 of file TProof.h.

Function Documentation

~TProof()

R__DEPRECATED::~TProof ( )

override

Activate()

void R__DEPRECATED::Activate ( TList * slaves = 0 )

private

ActivateAsyncInput()

void R__DEPRECATED::ActivateAsyncInput ( )

private

ActivateWorker()

Int_t R__DEPRECATED::ActivateWorker	(	const char *	ord,
		Bool_t	save = kTRUE )

AddChain()

void R__DEPRECATED::AddChain

(

TChain *

chain

)

AddDynamicPath()

Int_t R__DEPRECATED::AddDynamicPath	(	const char *	libpath,
		Bool_t	onClient = kFALSE,
		TList *	wrks = 0,
		Bool_t	doCollect = kTRUE )

AddEnvVar()

static void R__DEPRECATED::AddEnvVar ( const char * name, const char * value )

static

AddFeedback()

void R__DEPRECATED::AddFeedback

(

const char *

name

)

AddIncludePath()

Int_t R__DEPRECATED::AddIncludePath	(	const char *	incpath,
		Bool_t	onClient = kFALSE,
		TList *	wrks = 0,
		Bool_t	doCollect = kTRUE )

AddInput()

void R__DEPRECATED::AddInput

(

TObject *

obj

)

AddInputData()

void R__DEPRECATED::AddInputData	(	TObject *	obj,
		Bool_t	push = kFALSE )

AddWorkers()

Int_t R__DEPRECATED::AddWorkers ( TList * wrks )

protected

Archive() [1/2]

Int_t R__DEPRECATED::Archive	(	const char *	queryref,
		const char *	url = 0 )

Archive() [2/2]

Int_t R__DEPRECATED::Archive	(	Int_t	query,
		const char *	url )

AskForOutput()

void R__DEPRECATED::AskForOutput ( TSlave * sl )

private

AskParallel()

void R__DEPRECATED::AskParallel ( )

private

AskStatistics()

void R__DEPRECATED::AskStatistics ( )

private

AssertDataSet()

static Int_t R__DEPRECATED::AssertDataSet ( TDSet * dset, TList * input, TDataSetManager * mgr, TString & emsg )

staticprotected

AssertMacroPath()

static void R__DEPRECATED::AssertMacroPath ( const char * macro )

staticprotected

AssertPath()

Int_t R__DEPRECATED::AssertPath ( const char * path, Bool_t writable )

protected

Broadcast() [1/6]

Int_t R__DEPRECATED::Broadcast ( const char * mess, Int_t kind, TList * slaves )

private

Broadcast() [2/6]

Int_t R__DEPRECATED::Broadcast ( const char * mess, Int_t kind = kMESS_STRING, ESlaves list = kActive )

private

Broadcast() [3/6]

Int_t R__DEPRECATED::Broadcast ( const TMessage & mess, ESlaves list = kActive )

private

Broadcast() [4/6]

Int_t R__DEPRECATED::Broadcast ( const TMessage & mess, TList * slaves )

private

Broadcast() [5/6]

Int_t R__DEPRECATED::Broadcast ( Int_t kind, ESlaves list = kActive )

private

Definition at line 317 of file TProof.h.

Broadcast() [6/6]

Int_t R__DEPRECATED::Broadcast ( Int_t kind, TList * slaves )

private

Definition at line 316 of file TProof.h.

BroadcastFile() [1/2]

Int_t R__DEPRECATED::BroadcastFile ( const char * file, Int_t opt, const char * rfile, TList * wrks )

private

BroadcastFile() [2/2]

Int_t R__DEPRECATED::BroadcastFile ( const char * file, Int_t opt, const char * rfile = 0, ESlaves list = kAllUnique )

private

BroadcastGroupPriority() [1/2]

Int_t R__DEPRECATED::BroadcastGroupPriority ( const char * grp, Int_t priority, ESlaves list = kAllUnique )

private

BroadcastGroupPriority() [2/2]

Int_t R__DEPRECATED::BroadcastGroupPriority ( const char * grp, Int_t priority, TList * workers )

private

BroadcastObject() [1/2]

Int_t R__DEPRECATED::BroadcastObject ( const TObject * obj, Int_t kind, TList * slaves )

private

BroadcastObject() [2/2]

Int_t R__DEPRECATED::BroadcastObject ( const TObject * obj, Int_t kind = kMESS_OBJECT, ESlaves list = kActive )

private

BroadcastRaw() [1/2]

Int_t R__DEPRECATED::BroadcastRaw ( const void * buffer, Int_t length, ESlaves list = kActive )

private

BroadcastRaw() [2/2]

Int_t R__DEPRECATED::BroadcastRaw ( const void * buffer, Int_t length, TList * slaves )

private

Browse()

void R__DEPRECATED::Browse ( TBrowser * b )

override

BuildPackage()

Int_t R__DEPRECATED::BuildPackage ( const char * package, EBuildPackageOpt opt = kBuildAll, Int_t chkveropt = TPackMgr::kCheckROOT, TList * workers = 0 )

private

CancelStagingDataSet()

virtual Bool_t R__DEPRECATED::CancelStagingDataSet ( const char * dataset )

virtual

cd()

void R__DEPRECATED::cd

(

Int_t

id = -1

)

CheckFile()

Bool_t R__DEPRECATED::CheckFile ( const char * file, TSlave * sl, Long_t modtime, Int_t cpopt = (kCp|kCpBin) )

private

Class()

static TClass * R__DEPRECATED::Class ( )

static

Returns

TClass describing this class

Definition at line 29 of file Class.C.

Class_Name()

static const char * R__DEPRECATED::Class_Name ( )

static

Returns

Name of this class

Class_Version()

static constexpr Version_t R__DEPRECATED::Class_Version ( )

staticconstexpr

Returns

Version of this class

Definition at line 756 of file TProof.h.

CleanGDirectory()

void R__DEPRECATED::CleanGDirectory ( TList * ol )

private

CleanupSession()

Int_t R__DEPRECATED::CleanupSession

(

const char *

sessiontag

)

ClearCache()

virtual void R__DEPRECATED::ClearCache ( const char * file = 0 )

virtual

ClearData()

void R__DEPRECATED::ClearData	(	UInt_t	what = kUnregistered,
		const char *	dsname = 0 )

ClearDataProgress()

void R__DEPRECATED::ClearDataProgress ( Int_t r, Int_t t )

private

ClearDataSetCache()

virtual void R__DEPRECATED::ClearDataSetCache ( const char * dataset = 0 )

virtual

ClearFeedback()

void R__DEPRECATED::ClearFeedback

(

)

ClearInput()

void R__DEPRECATED::ClearInput

(

)

ClearInputData() [1/2]

void R__DEPRECATED::ClearInputData

(

const char *

name

)

ClearInputData() [2/2]

void R__DEPRECATED::ClearInputData

(

TObject *

obj = 0

)

ClearPackage()

Int_t R__DEPRECATED::ClearPackage

(

const char *

package

)

ClearPackages()

Int_t R__DEPRECATED::ClearPackages

(

)

Close()

void R__DEPRECATED::Close

(

Option_t *

option = ""

)

CloseProgressDialog()

void R__DEPRECATED::CloseProgressDialog

(

)

Collect() [1/4]

Int_t R__DEPRECATED::Collect ( const TSlave * sl, Long_t timeout = -1, Int_t endtype = -1, Bool_t deactonfail = kFALSE )

private

Collect() [2/4]

Int_t R__DEPRECATED::Collect ( ESlaves list = kActive, Long_t timeout = -1, Int_t endtype = -1, Bool_t deactonfail = kFALSE )

protected

Collect() [3/4]

Int_t R__DEPRECATED::Collect ( TList * slaves, Long_t timeout = -1, Int_t endtype = -1, Bool_t deactonfail = kFALSE )

protected

Collect() [4/4]

Int_t R__DEPRECATED::Collect ( TMonitor * mon, Long_t timeout = -1, Int_t endtype = -1, Bool_t deactonfail = kFALSE )

private

CollectInputFrom()

Int_t R__DEPRECATED::CollectInputFrom ( TSocket * s, Int_t endtype = -1, Bool_t deactonfail = kFALSE )

private

CreateDrawFeedback()

TDrawFeedback * R__DEPRECATED::CreateDrawFeedback

(

)

CreateMerger()

Bool_t R__DEPRECATED::CreateMerger ( TSlave * sl, Int_t port )

private

CreateSlave()

TSlave * R__DEPRECATED::CreateSlave ( const char * url, const char * ord, Int_t perf, const char * image, const char * workdir )

protected

CreateSubmaster()

TSlave * R__DEPRECATED::CreateSubmaster ( const char * url, const char * ord, const char * image, const char * msd, Int_t nwk = 1 )

protected

DataSetStatus()

void R__DEPRECATED::DataSetStatus	(	const char *	msg,
		Bool_t	status,
		Int_t	done,
		Int_t	total )

DeActivateAsyncInput()

void R__DEPRECATED::DeActivateAsyncInput ( )

private

DeactivateWorker()

Int_t R__DEPRECATED::DeactivateWorker	(	const char *	ord,
		Bool_t	save = kTRUE )

DeclFileName()

static const char * R__DEPRECATED::DeclFileName ( )

static

Returns

Name of the file containing the class declaration

Definition at line 756 of file TProof.h.

DelEnvVar()

static void R__DEPRECATED::DelEnvVar ( const char * name )

static

DeleteDrawFeedback()

void R__DEPRECATED::DeleteDrawFeedback

(

TDrawFeedback *

f

)

DeleteParameters()

void R__DEPRECATED::DeleteParameters

(

const char *

wildcard

)

Detach()

void R__DEPRECATED::Detach

(

Option_t *

opt = ""

)

DisableGoAsyn()

void R__DEPRECATED::DisableGoAsyn

(

)

DisablePackage()

Int_t R__DEPRECATED::DisablePackage ( const char * package )

private

DisablePackages()

Int_t R__DEPRECATED::DisablePackages ( )

private

DownloadPackage()

Int_t R__DEPRECATED::DownloadPackage	(	const char *	par,
		const char *	dstdir = 0 )

DrawSelect() [1/2]

Long64_t R__DEPRECATED::DrawSelect	(	const char *	dsetname,
		const char *	varexp,
		const char *	selection = "",
		Option_t *	option = "",
		Long64_t	nentries = -1,
		Long64_t	firstentry = 0,
		TObject *	enl = 0 )

DrawSelect() [2/2]

virtual Long64_t R__DEPRECATED::DrawSelect ( TDSet * dset, const char * varexp, const char * selection = "", Option_t * option = "", Long64_t nentries = -1, Long64_t firstentry = 0 )

virtual

Echo() [1/2]

virtual Int_t R__DEPRECATED::Echo ( const char * str )

virtual

Echo() [2/2]

virtual Int_t R__DEPRECATED::Echo ( const TObject * obj )

virtual

EnablePackage() [1/3]

Int_t R__DEPRECATED::EnablePackage	(	const char *	package,
		Bool_t	notOnClient = kFALSE,
		TList *	workers = 0 )

EnablePackage() [2/3]

Int_t R__DEPRECATED::EnablePackage	(	const char *	package,
		const char *	loadopts,
		Bool_t	notOnClient = kFALSE,
		TList *	workers = 0 )

EnablePackage() [3/3]

Int_t R__DEPRECATED::EnablePackage	(	const char *	package,
		TList *	loadopts,
		Bool_t	notOnClient = kFALSE,
		TList *	workers = 0 )

Exec() [1/3]

Int_t R__DEPRECATED::Exec	(	const char *	cmd,
		Bool_t	plusMaster = kFALSE )

Exec() [2/3]

Int_t R__DEPRECATED::Exec	(	const char *	cmd,
		const char *	ord,
		Bool_t	logtomacro = kFALSE )

Exec() [3/3]

Int_t R__DEPRECATED::Exec ( const char * cmd, ESlaves list, Bool_t plusMaster )

private

ExistsDataSet()

virtual Bool_t R__DEPRECATED::ExistsDataSet ( const char * dataset )

virtual

Feedback()

void R__DEPRECATED::Feedback

(

TList *

objs

)

FinalizationDone()

void R__DEPRECATED::FinalizationDone ( )

private

Definition at line 377 of file TProof.h.

Finalize() [1/2]

Long64_t R__DEPRECATED::Finalize	(	const char *	queryref,
		Bool_t	force = kFALSE )

Finalize() [2/2]

Long64_t R__DEPRECATED::Finalize	(	Int_t	query = -1,
		Bool_t	force = kFALSE )

FindDataSets()

TList * R__DEPRECATED::FindDataSets	(	const char *	searchString,
		const char *	optStr = "" )

FindNextFreeMerger()

Int_t R__DEPRECATED::FindNextFreeMerger ( )

private

FindSlave()

TSlave * R__DEPRECATED::FindSlave ( TSocket * s ) const

private

FindUniqueSlaves()

virtual void R__DEPRECATED::FindUniqueSlaves ( )

privatevirtual

GetActiveMergersCount()

Int_t R__DEPRECATED::GetActiveMergersCount ( )

private

GetBytesRead()

Long64_t R__DEPRECATED::GetBytesRead

(

)

const

Definition at line 612 of file TProof.h.

GetClientProtocol()

Int_t R__DEPRECATED::GetClientProtocol

(

)

const

Definition at line 597 of file TProof.h.

GetConfDir()

const char * R__DEPRECATED::GetConfDir

(

)

const

Definition at line 587 of file TProof.h.

GetConfFile()

const char * R__DEPRECATED::GetConfFile

(

)

const

Definition at line 588 of file TProof.h.

GetCpuTime()

Float_t R__DEPRECATED::GetCpuTime

(

)

const

Definition at line 614 of file TProof.h.

GetDataPoolUrl()

const char * R__DEPRECATED::GetDataPoolUrl

(

)

const

Definition at line 726 of file TProof.h.

GetDataSet()

virtual TFileCollection * R__DEPRECATED::GetDataSet ( const char * dataset, const char * optStr = "" )

virtual

GetDataSetQuota()

TMap * R__DEPRECATED::GetDataSetQuota

(

const char *

optStr = ""

)

GetDataSets()

virtual TMap * R__DEPRECATED::GetDataSets ( const char * uri = "", const char * optStr = "" )

virtual

GetDataSetSrvMaps()

static TList * R__DEPRECATED::GetDataSetSrvMaps ( const TString & srvmaps )

staticprivate

GetEnabledPackages()

TList * R__DEPRECATED::GetEnabledPackages ( ) const

protected

Definition at line 418 of file TProof.h.

Getenv()

TString R__DEPRECATED::Getenv	(	const char *	env,
		const char *	ord = "0" )

GetEnvVars()

static const TList * R__DEPRECATED::GetEnvVars ( )

static

GetFeedbackList()

TList * R__DEPRECATED::GetFeedbackList

(

)

const

GetFileInCmd()

static Bool_t R__DEPRECATED::GetFileInCmd ( const char * cmd, TString & fn )

staticprotected

GetGroup()

const char * R__DEPRECATED::GetGroup

(

)

const

Definition at line 590 of file TProof.h.

GetImage()

const char * R__DEPRECATED::GetImage

(

)

const

Definition at line 593 of file TProof.h.

GetInputData()

static Int_t R__DEPRECATED::GetInputData ( TList * input, const char * cachedir, TString & emsg )

staticprotected

GetInputList()

TList * R__DEPRECATED::GetInputList

(

)

GetLastLog()

TMacro * R__DEPRECATED::GetLastLog

(

)

GetListOfActiveSlaves()

TList * R__DEPRECATED::GetListOfActiveSlaves ( ) const

protected

Definition at line 406 of file TProof.h.

GetListOfBadSlaves()

TList * R__DEPRECATED::GetListOfBadSlaves ( ) const

private

Definition at line 340 of file TProof.h.

GetListOfEnabledPackages()

TList * R__DEPRECATED::GetListOfEnabledPackages

(

)

GetListOfInactiveSlaves()

TList * R__DEPRECATED::GetListOfInactiveSlaves ( ) const

private

Definition at line 338 of file TProof.h.

GetListOfPackages()

TList * R__DEPRECATED::GetListOfPackages

(

)

GetListOfQueries()

virtual TList * R__DEPRECATED::GetListOfQueries ( Option_t * opt = "" )

virtual

GetListOfSlaveInfos()

TList * R__DEPRECATED::GetListOfSlaveInfos

(

)

GetListOfSlaves()

TList * R__DEPRECATED::GetListOfSlaves ( ) const

private

Definition at line 337 of file TProof.h.

GetListOfUniqueSlaves()

TList * R__DEPRECATED::GetListOfUniqueSlaves ( ) const

private

Definition at line 339 of file TProof.h.

GetLoadedMacros()

TList * R__DEPRECATED::GetLoadedMacros

(

)

const

Definition at line 627 of file TProof.h.

GetLog()

void R__DEPRECATED::GetLog	(	Int_t	start = -1,
		Int_t	end = -1 )

GetLogLevel()

Int_t R__DEPRECATED::GetLogLevel

(

)

const

Definition at line 599 of file TProof.h.

GetMacroLog()

TMacro * R__DEPRECATED::GetMacroLog

(

)

Definition at line 702 of file TProof.h.

GetManager()

TProofMgr * R__DEPRECATED::GetManager

(

)

Definition at line 720 of file TProof.h.

GetMaster()

const char * R__DEPRECATED::GetMaster

(

)

const

Definition at line 586 of file TProof.h.

GetMaxQueries()

void R__DEPRECATED::GetMaxQueries

(

)

GetMissingFiles()

TFileCollection * R__DEPRECATED::GetMissingFiles

(

TQueryResult *

qr = 0

)

GetNumberOfActiveSlaves()

Int_t R__DEPRECATED::GetNumberOfActiveSlaves ( ) const

private

GetNumberOfBadSlaves()

Int_t R__DEPRECATED::GetNumberOfBadSlaves ( ) const

private

GetNumberOfDrawQueries()

Int_t R__DEPRECATED::GetNumberOfDrawQueries

(

)

Definition at line 662 of file TProof.h.

GetNumberOfInactiveSlaves()

Int_t R__DEPRECATED::GetNumberOfInactiveSlaves ( ) const

private

GetNumberOfQueries()

Int_t R__DEPRECATED::GetNumberOfQueries

(

)

GetNumberOfSlaves()

Int_t R__DEPRECATED::GetNumberOfSlaves ( ) const

private

GetNumberOfUniqueSlaves()

Int_t R__DEPRECATED::GetNumberOfUniqueSlaves ( ) const

private

GetOutput() [1/2]

TObject * R__DEPRECATED::GetOutput

(

const char *

name

)

GetOutput() [2/2]

static TObject * R__DEPRECATED::GetOutput ( const char * name, TList * out )

static

GetOutputList()

TList * R__DEPRECATED::GetOutputList

(

)

GetOutputNames()

TList * R__DEPRECATED::GetOutputNames

(

)

GetParallel()

Int_t R__DEPRECATED::GetParallel

(

)

const

GetParameter() [1/6]

TObject * R__DEPRECATED::GetParameter

(

const char *

par

)

const

GetParameter() [2/6]

static Int_t R__DEPRECATED::GetParameter ( TCollection * c, const char * par, Double_t & value )

static

GetParameter() [3/6]

static Int_t R__DEPRECATED::GetParameter ( TCollection * c, const char * par, Int_t & value )

static

GetParameter() [4/6]

static Int_t R__DEPRECATED::GetParameter ( TCollection * c, const char * par, Long64_t & value )

static

GetParameter() [5/6]

static Int_t R__DEPRECATED::GetParameter ( TCollection * c, const char * par, Long_t & value )

static

GetParameter() [6/6]

static Int_t R__DEPRECATED::GetParameter ( TCollection * c, const char * par, TString & value )

static

GetPlayer()

TVirtualProofPlayer * R__DEPRECATED::GetPlayer ( ) const

protected

Definition at line 399 of file TProof.h.

GetPort()

Int_t R__DEPRECATED::GetPort

(

)

const

Definition at line 595 of file TProof.h.

GetProgressDialog()

TPluginHandler * R__DEPRECATED::GetProgressDialog ( ) const

protected

Definition at line 425 of file TProof.h.

GetQueryMode()

EQueryMode R__DEPRECATED::GetQueryMode

(

Option_t *

mode = 0

)

const

GetQueryReference()

Int_t R__DEPRECATED::GetQueryReference ( Int_t qry, TString & ref )

private

GetQueryResult()

TQueryResult * R__DEPRECATED::GetQueryResult

(

const char *

ref = 0

)

GetQueryResults()

TList * R__DEPRECATED::GetQueryResults

(

)

GetRC() [1/3]

Int_t R__DEPRECATED::GetRC	(	const char *	RCenv,
		Double_t &	env,
		const char *	ord = "0" )

GetRC() [2/3]

Int_t R__DEPRECATED::GetRC	(	const char *	RCenv,
		Int_t &	env,
		const char *	ord = "0" )

GetRC() [3/3]

Int_t R__DEPRECATED::GetRC	(	const char *	RCenv,
		TString &	env,
		const char *	ord = "0" )

GetRealTime()

Float_t R__DEPRECATED::GetRealTime

(

)

const

Definition at line 613 of file TProof.h.

GetRemoteProtocol()

Int_t R__DEPRECATED::GetRemoteProtocol

(

)

const

Definition at line 596 of file TProof.h.

GetRunStatus()

ERunStatus R__DEPRECATED::GetRunStatus

(

)

const

Definition at line 626 of file TProof.h.

GetSandbox()

Int_t R__DEPRECATED::GetSandbox ( TString & sb, Bool_t assert = kFALSE, const char * rc = 0 )

protected

GetSeqNum()

Int_t R__DEPRECATED::GetSeqNum

(

)

const

Definition at line 601 of file TProof.h.

GetSessionID()

Int_t R__DEPRECATED::GetSessionID

(

)

const

Definition at line 602 of file TProof.h.

GetSessionTag()

const char * R__DEPRECATED::GetSessionTag

(

)

const

Definition at line 592 of file TProof.h.

GetStagingStatusDataSet()

virtual TFileCollection * R__DEPRECATED::GetStagingStatusDataSet ( const char * dataset )

virtual

GetStatistics()

void R__DEPRECATED::GetStatistics

(

Bool_t

verbose = kFALSE

)

GetStatus()

Int_t R__DEPRECATED::GetStatus

(

)

const

Definition at line 598 of file TProof.h.

GetTreeHeader()

virtual TTree * R__DEPRECATED::GetTreeHeader ( TDSet * tdset )

virtual

GetUrl()

const char * R__DEPRECATED::GetUrl

(

)

Definition at line 594 of file TProof.h.

GetUser()

const char * R__DEPRECATED::GetUser

(

)

const

Definition at line 589 of file TProof.h.

GetWorkDir()

const char * R__DEPRECATED::GetWorkDir

(

)

const

Definition at line 591 of file TProof.h.

GoAsynchronous()

void R__DEPRECATED::GoAsynchronous

(

)

GoMoreParallel()

Int_t R__DEPRECATED::GoMoreParallel ( Int_t nWorkersToAdd )

private

GoParallel()

Int_t R__DEPRECATED::GoParallel ( Int_t nodes, Bool_t accept = kFALSE, Bool_t random = kFALSE )

private

HandleInputMessage()

Int_t R__DEPRECATED::HandleInputMessage ( TSlave * wrk, TMessage * m, Bool_t deactonfail = kFALSE )

private

HandleLibIncPath()

void R__DEPRECATED::HandleLibIncPath ( const char * what, Bool_t add, const char * dirs )

protected

HandleOutputOptions()

Int_t R__DEPRECATED::HandleOutputOptions ( TString & opt, TString & target, Int_t action )

protected

HandleSubmerger()

void R__DEPRECATED::HandleSubmerger ( TMessage * mess, TSlave * sl )

private

Init()

Int_t R__DEPRECATED::Init ( const char * masterurl, const char * conffile, const char * confdir, Int_t loglevel, const char * alias = 0 )

protected

InitMembers()

void R__DEPRECATED::InitMembers ( )

protected

Interrupt()

void R__DEPRECATED::Interrupt ( EUrgent type, ESlaves list = kActive )

private

InterruptCurrentMonitor()

void R__DEPRECATED::InterruptCurrentMonitor ( )

private

IsA()

TClass * R__DEPRECATED::IsA ( ) const

override

Returns

TClass describing current object

Definition at line 756 of file TProof.h.

IsDataReady()

Bool_t R__DEPRECATED::IsDataReady	(	Long64_t &	totalbytes,
		Long64_t &	bytesready )

IsEndMaster()

Bool_t R__DEPRECATED::IsEndMaster ( ) const

private

Definition at line 347 of file TProof.h.

IsFolder()

Bool_t R__DEPRECATED::IsFolder ( ) const

override

Definition at line 618 of file TProof.h.

IsIdle()

Bool_t R__DEPRECATED::IsIdle

(

)

const

Definition at line 623 of file TProof.h.

IsLite()

Bool_t R__DEPRECATED::IsLite

(

)

const

Definition at line 616 of file TProof.h.

IsMaster()

Bool_t R__DEPRECATED::IsMaster

(

)

const

Definition at line 619 of file TProof.h.

IsParallel()

Bool_t R__DEPRECATED::IsParallel

(

)

const

Definition at line 622 of file TProof.h.

IsProofd()

Bool_t R__DEPRECATED::IsProofd

(

)

const

Definition at line 617 of file TProof.h.

IsSync()

Bool_t R__DEPRECATED::IsSync ( ) const

private

Definition at line 352 of file TProof.h.

IsTty()

Bool_t R__DEPRECATED::IsTty

(

)

const

Definition at line 621 of file TProof.h.

IsValid()

Bool_t R__DEPRECATED::IsValid

(

)

const

Definition at line 620 of file TProof.h.

IsWaiting()

Bool_t R__DEPRECATED::IsWaiting

(

)

const

Definition at line 624 of file TProof.h.

Load()

virtual Int_t R__DEPRECATED::Load ( const char * macro, Bool_t notOnClient = kFALSE, Bool_t uniqueOnly = kTRUE, TList * wrks = 0 )

virtual

LoadPackage()

Int_t R__DEPRECATED::LoadPackage ( const char * package, Bool_t notOnClient = kFALSE, TList * loadopts = 0, TList * workers = 0 )

private

LogMessage()

void R__DEPRECATED::LogMessage	(	const char *	msg,
		Bool_t	all )

LogViewer()

static void R__DEPRECATED::LogViewer ( const char * url = 0, Int_t sessionidx = 0 )

static

MakePlayer()

virtual TVirtualProofPlayer * R__DEPRECATED::MakePlayer ( const char * player = 0, TSocket * s = 0 )

protectedvirtual

MarkBad() [1/2]

void R__DEPRECATED::MarkBad ( TSlave * wrk, const char * reason = 0 )

private

MarkBad() [2/2]

void R__DEPRECATED::MarkBad ( TSocket * s, const char * reason = 0 )

private

Mgr()

static TProofMgr * R__DEPRECATED::Mgr ( const char * url )

static

ModifyWorkerLists()

Int_t R__DEPRECATED::ModifyWorkerLists ( const char * ord, Bool_t add, Bool_t save )

private

NotifyLogMsg()

void R__DEPRECATED::NotifyLogMsg ( const char * msg, const char * sfx = "\n" )

private

Open()

static TProof * R__DEPRECATED::Open ( const char * url = 0, const char * conffile = 0, const char * confdir = 0, Int_t loglevel = 0 )

static

operator=()

void R__DEPRECATED::operator= ( const TProof & )

private

ParseConfigField()

void R__DEPRECATED::ParseConfigField ( const char * config )

private

Ping() [1/2]

Int_t R__DEPRECATED::Ping

(

)

Ping() [2/2]

Int_t R__DEPRECATED::Ping ( ESlaves list )

private

PollForNewWorkers()

virtual Int_t R__DEPRECATED::PollForNewWorkers ( )

protectedvirtual

PrepareInputDataFile()

void R__DEPRECATED::PrepareInputDataFile ( TString & dataFile )

protected

Print()

void R__DEPRECATED::Print ( Option_t * option = "" ) const

override

PrintProgress()

void R__DEPRECATED::PrintProgress ( Long64_t total, Long64_t processed, Float_t procTime = -1., Long64_t bytesread = -1 )

private

Process() [1/8]

virtual Long64_t R__DEPRECATED::Process ( const char * dsetname, const char * selector, Option_t * option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TObject * enl = 0 )

overridevirtual

Definition at line 78 of file TProofLite.h.

Process() [2/8]

virtual Long64_t R__DEPRECATED::Process ( const char * dsetname, TSelector * selector, Option_t * option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TObject * enl = 0 )

overridevirtual

Definition at line 90 of file TProofLite.h.

Process() [3/8]

virtual Long64_t R__DEPRECATED::Process ( const char * selector, Long64_t nentries, Option_t * option = "" )

overridevirtual

Definition at line 81 of file TProofLite.h.

Process() [4/8]

virtual Long64_t R__DEPRECATED::Process ( TDSet * dset, const char * selector, Option_t * option = "", Long64_t nentries = -1, Long64_t firstentry = 0 )

virtual

Process() [5/8]

virtual Long64_t R__DEPRECATED::Process ( TDSet * dset, TSelector * selector, Option_t * option = "", Long64_t nentries = -1, Long64_t firstentry = 0 )

overridevirtual

Definition at line 84 of file TProofLite.h.

Process() [6/8]

virtual Long64_t R__DEPRECATED::Process ( TFileCollection * fc, const char * selector, Option_t * option = "", Long64_t nentries = -1, Long64_t firstentry = 0 )

overridevirtual

Definition at line 75 of file TProofLite.h.

Process() [7/8]

virtual Long64_t R__DEPRECATED::Process ( TFileCollection * fc, TSelector * selector, Option_t * option = "", Long64_t nentries = -1, Long64_t firstentry = 0 )

overridevirtual

Definition at line 87 of file TProofLite.h.

Process() [8/8]

virtual Long64_t R__DEPRECATED::Process ( TSelector * selector, Long64_t nentries, Option_t * option = "" )

overridevirtual

Definition at line 93 of file TProofLite.h.

Progress() [1/3]

void R__DEPRECATED::Progress	(	Long64_t	total,
		Long64_t	processed )

Progress() [2/3]

void R__DEPRECATED::Progress	(	Long64_t	total,
		Long64_t	processed,
		Long64_t	bytesread,
		Float_t	initTime,
		Float_t	procTime,
		Float_t	evtrti,
		Float_t	mbrti )

Progress() [3/3]

void R__DEPRECATED::Progress	(	Long64_t	total,
		Long64_t	processed,
		Long64_t	bytesread,
		Float_t	initTime,
		Float_t	procTime,
		Float_t	evtrti,
		Float_t	mbrti,
		Int_t	actw,
		Int_t	tses,
		Float_t	eses )

Prompt()

Bool_t R__DEPRECATED::Prompt ( const char * p )

private

PutLog()

void R__DEPRECATED::PutLog

(

TQueryResult *

qr

)

QueryResultReady()

void R__DEPRECATED::QueryResultReady

(

const char *

ref

)

R__DEPRECATED()

TProof TNamed, TQObject R__DEPRECATED	(	6	,
		38	,
		"Legacy interactive distributed processing engine. Use RDataFrame instead."	)

RecvLogFile()

void R__DEPRECATED::RecvLogFile ( TSocket * s, Int_t size )

private

RedirectWorker()

void R__DEPRECATED::RedirectWorker ( TSocket * s, TSlave * sl, Int_t output_size )

private

RegisterDataSet()

virtual Bool_t R__DEPRECATED::RegisterDataSet ( const char * name, TFileCollection * dataset, const char * optStr = "" )

virtual

ReleaseMonitor()

void R__DEPRECATED::ReleaseMonitor ( TMonitor * mon )

private

Remove() [1/2]

Int_t R__DEPRECATED::Remove	(	const char *	queryref,
		Bool_t	all = kFALSE )

Remove() [2/2]

Int_t R__DEPRECATED::Remove	(	Int_t	query,
		Bool_t	all = kFALSE )

RemoveChain()

void R__DEPRECATED::RemoveChain

(

TChain *

chain

)

RemoveDataSet()

virtual Int_t R__DEPRECATED::RemoveDataSet ( const char * dataset, const char * optStr = "" )

virtual

RemoveDynamicPath()

Int_t R__DEPRECATED::RemoveDynamicPath	(	const char *	libpath,
		Bool_t	onClient = kFALSE )

RemoveFeedback()

void R__DEPRECATED::RemoveFeedback

(

const char *

name

)

RemoveIncludePath()

Int_t R__DEPRECATED::RemoveIncludePath	(	const char *	incpath,
		Bool_t	onClient = kFALSE )

RemoveWorkers()

Int_t R__DEPRECATED::RemoveWorkers ( TList * wrks )

protected

RequestStagingDataSet()

virtual Bool_t R__DEPRECATED::RequestStagingDataSet ( const char * dataset )

virtual

Reset()

static void R__DEPRECATED::Reset ( const char * url, Bool_t hard = kFALSE )

static

ResetEnvVars()

static void R__DEPRECATED::ResetEnvVars ( )

static

ResetMergePrg()

void R__DEPRECATED::ResetMergePrg ( )

private

ResetMergers()

void R__DEPRECATED::ResetMergers ( )

private

Definition at line 374 of file TProof.h.

ResetProgressDialog()

void R__DEPRECATED::ResetProgressDialog	(	const char *	sel,
		Int_t	sz,
		Long64_t	fst,
		Long64_t	ent )

ResetProgressDialogStatus()

void R__DEPRECATED::ResetProgressDialogStatus

(

)

Definition at line 704 of file TProof.h.

RestoreActiveList()

Int_t R__DEPRECATED::RestoreActiveList ( )

private

Retrieve() [1/2]

Int_t R__DEPRECATED::Retrieve	(	const char *	queryref,
		const char *	path = 0 )

Retrieve() [2/2]

Int_t R__DEPRECATED::Retrieve	(	Int_t	query,
		const char *	path = 0 )

SaveActiveList()

void R__DEPRECATED::SaveActiveList ( )

private

SaveInputData()

static Int_t R__DEPRECATED::SaveInputData ( TQueryResult * qr, const char * cachedir, TString & emsg )

staticprotected

SavePerfTree()

Int_t R__DEPRECATED::SavePerfTree	(	const char *	pf = 0,
		const char *	qref = 0 )

SaveWorkerInfo()

virtual void R__DEPRECATED::SaveWorkerInfo ( )

protectedvirtual

SendCommand()

Int_t R__DEPRECATED::SendCommand ( const char * cmd, ESlaves list = kActive )

private

SendCurrentState() [1/2]

Int_t R__DEPRECATED::SendCurrentState ( ESlaves list = kActive )

private

SendCurrentState() [2/2]

Int_t R__DEPRECATED::SendCurrentState ( TList * list )

private

SendDataSetStatus()

void R__DEPRECATED::SendDataSetStatus	(	const char *	msg,
		UInt_t	n,
		UInt_t	tot,
		Bool_t	st )

SendFile()

Int_t R__DEPRECATED::SendFile ( const char * file, Int_t opt = (kBinary|kForward|kCp|kCpBin), const char * rfile = 0, TSlave * sl = 0 )

protected

SendGroupView()

Int_t R__DEPRECATED::SendGroupView ( )

private

SendingLogToWindow()

Bool_t R__DEPRECATED::SendingLogToWindow

(

)

const

Definition at line 699 of file TProof.h.

SendInitialState()

Int_t R__DEPRECATED::SendInitialState ( )

private

SendInputData()

static Int_t R__DEPRECATED::SendInputData ( TQueryResult * qr, TProof * p, TString & emsg )

staticprotected

SendInputDataFile()

virtual void R__DEPRECATED::SendInputDataFile ( )

protectedvirtual

SendLogToWindow()

void R__DEPRECATED::SendLogToWindow

(

Bool_t

mode

)

Definition at line 700 of file TProof.h.

SendObject()

Int_t R__DEPRECATED::SendObject ( const TObject * obj, ESlaves list = kActive )

private

SendPrint()

Int_t R__DEPRECATED::SendPrint ( Option_t * option = "" )

private

SetActive()

void R__DEPRECATED::SetActive

(

Bool_t

= kTRUE

)

Definition at line 671 of file TProof.h.

SetAlias()

virtual void R__DEPRECATED::SetAlias ( const char * alias = "" )

virtual

SetDataPoolUrl()

void R__DEPRECATED::SetDataPoolUrl

(

const char *

url

)

Definition at line 727 of file TProof.h.

SetDataSetTreeName()

virtual Int_t R__DEPRECATED::SetDataSetTreeName ( const char * dataset, const char * treename )

virtual

SetDrawFeedbackOption()

void R__DEPRECATED::SetDrawFeedbackOption	(	TDrawFeedback *	f,
		Option_t *	opt )

SetDSet()

void R__DEPRECATED::SetDSet ( TDSet * dset )

protected

Definition at line 420 of file TProof.h.

SetFeedback()

void R__DEPRECATED::SetFeedback ( TString & opt, TString & optfb, Int_t action )

protected

SetInputDataFile()

void R__DEPRECATED::SetInputDataFile

(

const char *

datafile

)

SetLogLevel()

void R__DEPRECATED::SetLogLevel	(	Int_t	level,
		UInt_t	mask = TProofDebug::kAll )

SetManager()

void R__DEPRECATED::SetManager

(

TProofMgr *

mgr

)

SetMaxDrawQueries()

void R__DEPRECATED::SetMaxDrawQueries

(

Int_t

max

)

SetMonitor()

void R__DEPRECATED::SetMonitor ( TMonitor * mon = 0, Bool_t on = kTRUE )

private

SetParallel()

Int_t R__DEPRECATED::SetParallel	(	Int_t	nodes = -1,
		Bool_t	random = kFALSE )

SetParallelSilent()

Int_t R__DEPRECATED::SetParallelSilent ( Int_t nodes, Bool_t random = kFALSE )

private

SetParameter() [1/5]

void R__DEPRECATED::SetParameter	(	const char *	par,
		const char *	value )

SetParameter() [2/5]

void R__DEPRECATED::SetParameter	(	const char *	par,
		Double_t	value )

SetParameter() [3/5]

void R__DEPRECATED::SetParameter	(	const char *	par,
		Int_t	value )

SetParameter() [4/5]

void R__DEPRECATED::SetParameter	(	const char *	par,
		Long64_t	value )

SetParameter() [5/5]

void R__DEPRECATED::SetParameter	(	const char *	par,
		Long_t	value )

SetPerfTree()

void R__DEPRECATED::SetPerfTree	(	const char *	pf = "perftree.root",
		Bool_t	withWrks = kFALSE )

SetPlayer()

void R__DEPRECATED::SetPlayer ( TVirtualProofPlayer * player )

protected

SetPrintProgress()

void R__DEPRECATED::SetPrintProgress

(

PrintProgress_t

pp

)

Definition at line 729 of file TProof.h.

SetProgressDialog()

void R__DEPRECATED::SetProgressDialog

(

Bool_t

on = kTRUE

)

SetQueryMode()

void R__DEPRECATED::SetQueryMode

(

EQueryMode

mode

)

SetRealTimeLog()

void R__DEPRECATED::SetRealTimeLog

(

Bool_t

on = kTRUE

)

SetRunStatus()

void R__DEPRECATED::SetRunStatus ( ERunStatus rst )

private

Definition at line 355 of file TProof.h.

SetupWorkersEnv()

void R__DEPRECATED::SetupWorkersEnv ( TList * wrks, Bool_t increasingpool = kFALSE )

protected

ShowCache()

virtual void R__DEPRECATED::ShowCache ( Bool_t all = kFALSE )

virtual

ShowData()

virtual void R__DEPRECATED::ShowData ( )

virtual

ShowDataSet()

void R__DEPRECATED::ShowDataSet	(	const char *	dataset = "",
		const char *	opt = "filter:SsCc" )

ShowDataSetCache()

virtual void R__DEPRECATED::ShowDataSetCache ( const char * dataset = 0 )

virtual

ShowDataSetQuota()

void R__DEPRECATED::ShowDataSetQuota

(

Option_t *

opt = 0

)

ShowDataSets()

virtual void R__DEPRECATED::ShowDataSets ( const char * uri = "", const char * optStr = "" )

virtual

ShowEnabledPackages()

void R__DEPRECATED::ShowEnabledPackages

(

Bool_t

all = kFALSE

)

ShowFeedback()

void R__DEPRECATED::ShowFeedback

(

)

const

ShowLog() [1/2]

void R__DEPRECATED::ShowLog

(

const char *

queryref

)

ShowLog() [2/2]

void R__DEPRECATED::ShowLog

(

Int_t

qry = -1

)

ShowMissingFiles()

void R__DEPRECATED::ShowMissingFiles

(

TQueryResult *

qr = 0

)

ShowPackages()

void R__DEPRECATED::ShowPackages	(	Bool_t	all = kFALSE,
		Bool_t	redirlog = kFALSE )

ShowParameters()

void R__DEPRECATED::ShowParameters

(

const char *

wildcard = "PROOF_*"

)

const

ShowQueries()

void R__DEPRECATED::ShowQueries

(

Option_t *

opt = ""

)

ShowStagingStatusDataSet()

virtual void R__DEPRECATED::ShowStagingStatusDataSet ( const char * dataset, const char * optStr = "filter:SsCc" )

virtual

SlaveStartupThread()

static void * R__DEPRECATED::SlaveStartupThread ( void * arg )

staticprotected

StartSlaves()

virtual Bool_t R__DEPRECATED::StartSlaves ( Bool_t attach = kFALSE )

protectedvirtual

StartupMessage()

void R__DEPRECATED::StartupMessage	(	const char *	msg,
		Bool_t	status,
		Int_t	done,
		Int_t	total )

StopProcess()

void R__DEPRECATED::StopProcess	(	Bool_t	abort,
		Int_t	timeout = -1 )

Streamer()

void R__DEPRECATED::Streamer ( TBuffer & )

override

StreamerNVirtual()

void R__DEPRECATED::StreamerNVirtual

(

TBuffer &

ClassDef_StreamerNVirtual_b

)

Definition at line 756 of file TProof.h.

SystemCmd()

static void R__DEPRECATED::SystemCmd ( const char * cmd, Int_t fdout )

staticprotected

TerminateWorker() [1/2]

void R__DEPRECATED::TerminateWorker ( const char * ord )

private

TerminateWorker() [2/2]

void R__DEPRECATED::TerminateWorker ( TSlave * wrk )

private

Touch()

void R__DEPRECATED::Touch

(

)

TProof() [1/3]

R__DEPRECATED::TProof ( )

protected

Definition at line 35 of file TProofOutputFile.h.

TProof() [2/3]

R__DEPRECATED::TProof	(	const char *	masterurl,
		const char *	conffile = kPROOF_ConfFile,
		const char *	confdir = kPROOF_ConfDir,
		Int_t	loglevel = 0,
		const char *	alias = 0,
		TProofMgr *	mgr = 0 )

TProof() [3/3]

R__DEPRECATED::TProof ( const TProof & )

private

UnloadPackage()

Int_t R__DEPRECATED::UnloadPackage ( const char * package )

private

UnloadPackages()

Int_t R__DEPRECATED::UnloadPackages ( )

private

UpdateDialog()

void R__DEPRECATED::UpdateDialog ( )

protected

UploadDataSet() [1/2]

Int_t R__DEPRECATED::UploadDataSet	(	const char *	,
		const char *	,
		const char *	= 0,
		Int_t	= 0,
		TList *	= 0 )

UploadDataSet() [2/2]

Int_t R__DEPRECATED::UploadDataSet	(	const char *	,
		TList *	,
		const char *	= 0,
		Int_t	= 0,
		TList *	= 0 )

UploadDataSetFromFile()

Int_t R__DEPRECATED::UploadDataSetFromFile	(	const char *	,
		const char *	,
		const char *	= 0,
		Int_t	= 0,
		TList *	= 0 )

UploadPackage()

Int_t R__DEPRECATED::UploadPackage	(	const char *	par,
		EUploadPackageOpt	opt = kUntar,
		TList *	workers = 0 )

UseDynamicStartup()

Bool_t R__DEPRECATED::UseDynamicStartup

(

)

const

Definition at line 604 of file TProof.h.

ValidateDSet()

virtual void R__DEPRECATED::ValidateDSet ( TDSet * dset )

protectedvirtual

VerifyDataSet()

virtual Int_t R__DEPRECATED::VerifyDataSet ( const char * dataset, const char * optStr = "" )

virtual

VerifyDataSetParallel()

Int_t R__DEPRECATED::VerifyDataSetParallel ( const char * uri, const char * optStr )

protected

Variable Documentation

fActiveMonitor

TMonitor* fActiveMonitor

private

Definition at line 167 of file TProof.h.

fActiveSlaves

TList* fActiveSlaves

private

Definition at line 160 of file TProof.h.

fActiveSlavesSaved

TString fActiveSlavesSaved

private

Definition at line 161 of file TProof.h.

fAllMonitor

TMonitor* fAllMonitor

protected

Definition at line 258 of file TProof.h.

fAllUniqueMonitor

TMonitor* fAllUniqueMonitor

private

Definition at line 169 of file TProof.h.

fAllUniqueSlaves

TList* fAllUniqueSlaves

private

Definition at line 165 of file TProof.h.

fAvailablePackages

TList* fAvailablePackages

protected

Definition at line 262 of file TProof.h.

fBadSlaves

TList* fBadSlaves

protected

Definition at line 257 of file TProof.h.

fBytesRead

Long64_t fBytesRead

private

Definition at line 171 of file TProof.h.

fBytesReady

Long64_t fBytesReady

protected

Definition at line 260 of file TProof.h.

fChains

TList* fChains

private

Definition at line 179 of file TProof.h.

fCheckFileStatus

Int_t fCheckFileStatus

private

Definition at line 154 of file TProof.h.

fCloseMutex

std::recursive_mutex fCloseMutex

private

Definition at line 225 of file TProof.h.

fCollectTimeout

Int_t fCollectTimeout

protected

Definition at line 266 of file TProof.h.

fConfDir

TString fConfDir

protected

Definition at line 252 of file TProof.h.

fConfFile

TString fConfFile

protected

Definition at line 251 of file TProof.h.

fCpuTime

Float_t fCpuTime

private

Definition at line 173 of file TProof.h.

fCurrentMonitor

TMonitor* fCurrentMonitor

private

Definition at line 170 of file TProof.h.

fDataPoolUrl

TString fDataPoolUrl

protected

Definition at line 268 of file TProof.h.

fDataReady

Bool_t fDataReady

protected

Definition at line 259 of file TProof.h.

fDrawQueries

Int_t fDrawQueries

private

Definition at line 207 of file TProof.h.

fDSet

TDSet* fDSet

private

Definition at line 186 of file TProof.h.

fDynamicStartup

Bool_t fDynamicStartup

protected

Definition at line 272 of file TProof.h.

fEnabledPackages

TList* fEnabledPackages

protected

Definition at line 263 of file TProof.h.

fEnabledPackagesOnCluster

TList* fEnabledPackagesOnCluster

private

Definition at line 216 of file TProof.h.

fEndMaster

Bool_t fEndMaster

private

Definition at line 213 of file TProof.h.

fFeedback

TList* fFeedback

private

Definition at line 178 of file TProof.h.

fFileMap

FileMap_t fFileMap

private

Definition at line 185 of file TProof.h.

fFinalizationRunning

Bool_t fFinalizationRunning

private

Definition at line 237 of file TProof.h.

fgLogViewer

TPluginHandler* fgLogViewer

staticprivate

Definition at line 244 of file TProof.h.

fgProofEnvList

TList* fgProofEnvList

staticprivate

Definition at line 228 of file TProof.h.

fGroup

TString fGroup

private

Definition at line 151 of file TProof.h.

fImage

TString fImage

protected

Definition at line 253 of file TProof.h.

fInactiveSlaves

TList* fInactiveSlaves

private

Definition at line 163 of file TProof.h.

fInputData

TList* fInputData

private

Definition at line 218 of file TProof.h.

fInputDataFile

TString fInputDataFile

private

Definition at line 219 of file TProof.h.

fIntHandler

TSignalHandler* fIntHandler

private

Definition at line 174 of file TProof.h.

fIsPollingWorkers

Bool_t fIsPollingWorkers

private

Definition at line 158 of file TProof.h.

fIsWaiting

Bool_t fIsWaiting

private

Definition at line 191 of file TProof.h.

fLastAssignedMerger

Int_t fLastAssignedMerger

private

Definition at line 235 of file TProof.h.

fLastPollWorkers_s

Long64_t fLastPollWorkers_s

private

Definition at line 159 of file TProof.h.

fLoadedMacros

TList* fLoadedMacros

private

Definition at line 227 of file TProof.h.

fLogFileName

TString fLogFileName

private

Definition at line 194 of file TProof.h.

fLogFileR

FILE* fLogFileR

private

Definition at line 196 of file TProof.h.

fLogFileW

FILE* fLogFileW

private

Definition at line 195 of file TProof.h.

fLogLevel

Int_t fLogLevel

private

Definition at line 152 of file TProof.h.

fLogToWindowOnly

Bool_t fLogToWindowOnly

private

Definition at line 197 of file TProof.h.

fMacroLog

TMacro fMacroLog

private

Definition at line 200 of file TProof.h.

fManager

TProofMgr* fManager

protected

Definition at line 270 of file TProof.h.

fMaster

TString fMaster

private

Definition at line 149 of file TProof.h.

fMasterServ

Bool_t fMasterServ

protected

Definition at line 249 of file TProof.h.

fMaxDrawQueries

Int_t fMaxDrawQueries

private

Definition at line 208 of file TProof.h.

fMergePrg

TProofMergePrg fMergePrg

private

Definition at line 202 of file TProof.h.

fMergers

TList* fMergers

private

Definition at line 236 of file TProof.h.

fMergersByHost

Bool_t fMergersByHost

private

Definition at line 232 of file TProof.h.

fMergersCount

Int_t fMergersCount

private

Definition at line 233 of file TProof.h.

fMergersSet

Bool_t fMergersSet

private

Definition at line 231 of file TProof.h.

fNonUniqueMasters

TList* fNonUniqueMasters

private

Definition at line 166 of file TProof.h.

fNotIdle

Int_t fNotIdle

private

Definition at line 188 of file TProof.h.

fOtherQueries

Int_t fOtherQueries

private

Definition at line 206 of file TProof.h.

fOutputList

TProofOutputList fOutputList

private

Definition at line 221 of file TProof.h.

fPackMgr

TPackMgr* fPackMgr

private

Definition at line 215 of file TProof.h.

fPerfTree

TString fPerfTree

private

Definition at line 240 of file TProof.h.

fPlayer

TVirtualProofPlayer* fPlayer

private

Definition at line 177 of file TProof.h.

fPrepTime

Float_t fPrepTime

protected

Definition at line 277 of file TProof.h.

fPrintProgress

PrintProgress_t fPrintProgress

private

Definition at line 223 of file TProof.h.

fProgressDialog

TPluginHandler* fProgressDialog

private

Definition at line 175 of file TProof.h.

fProgressDialogStarted

Bool_t fProgressDialogStarted

private

Definition at line 176 of file TProof.h.

fProtocol

Int_t fProtocol

protected

Definition at line 254 of file TProof.h.

fQueries

TList* fQueries

private

Definition at line 205 of file TProof.h.

fQueryMode

EQueryMode fQueryMode

protected

Definition at line 271 of file TProof.h.

fQuerySTW

TStopwatch fQuerySTW

protected

Definition at line 276 of file TProof.h.

fRealTime

Float_t fRealTime

private

Definition at line 172 of file TProof.h.

fRecvMessages

TList* fRecvMessages

private

Definition at line 155 of file TProof.h.

fRedirectNext

Int_t fRedirectNext

private

Definition at line 238 of file TProof.h.

fRedirLog

Bool_t fRedirLog

private

Definition at line 193 of file TProof.h.

fRunningDSets

TList* fRunningDSets

protected

Definition at line 264 of file TProof.h.

fRunStatus

ERunStatus fRunStatus

private

Definition at line 190 of file TProof.h.

fSaveLogToMacro

Bool_t fSaveLogToMacro

private

Definition at line 199 of file TProof.h.

fSelector

TSelector* fSelector

protected

Definition at line 274 of file TProof.h.

fSendGroupView

Bool_t fSendGroupView

private

list returned by kPROOF_GETSLAVEINFO

Definition at line 157 of file TProof.h.

fSeqNum

Int_t fSeqNum

private

Definition at line 209 of file TProof.h.

fServType

TProofMgr::EServType fServType

protected

Definition at line 269 of file TProof.h.

fSessionID

Int_t fSessionID

private

Definition at line 211 of file TProof.h.

fSlaveInfo

TList* fSlaveInfo

private

Definition at line 156 of file TProof.h.

fSlaves

TList* fSlaves

protected

Definition at line 255 of file TProof.h.

fStatus

Int_t fStatus

private

Definition at line 153 of file TProof.h.

fSync

Bool_t fSync

private

Definition at line 189 of file TProof.h.

fTerminatedSlaveInfos

TList* fTerminatedSlaveInfos

protected

Definition at line 256 of file TProof.h.

fTotalBytes

Long64_t fTotalBytes

protected

Definition at line 261 of file TProof.h.

fTty

Bool_t fTty

private

Definition at line 148 of file TProof.h.

fUniqueMonitor

TMonitor* fUniqueMonitor

private

Definition at line 168 of file TProof.h.

fUniqueSlaves

TList* fUniqueSlaves

private

Definition at line 164 of file TProof.h.

fUrl

TUrl fUrl

protected

Definition at line 250 of file TProof.h.

fValid

Bool_t fValid

private

Definition at line 147 of file TProof.h.

fWaitingSlaves

TList* fWaitingSlaves

private

Definition at line 204 of file TProof.h.

fWorkDir

TString fWorkDir

private

Definition at line 150 of file TProof.h.

fWorkersToMerge

Int_t fWorkersToMerge

private

Definition at line 234 of file TProof.h.

fWrksOutputReady

TList* fWrksOutputReady

private

Definition at line 242 of file TProof.h.

gProof

R__EXTERN TProof* gProof

Definition at line 1077 of file TProof.h.

kCP

const char* const kCP = "/bin/cp -fp"

Definition at line 141 of file TProof.h.

kGUNZIP

const char* const kGUNZIP = "gunzip"

Definition at line 147 of file TProof.h.

kLS

const char* const kLS = "/bin/ls -l"

Definition at line 143 of file TProof.h.

kPROOF_CacheDir

const char* const kPROOF_CacheDir = "cache"

Definition at line 125 of file TProof.h.

kPROOF_CacheLockFile

const char* const kPROOF_CacheLockFile = "proof-cache-lock-"

Definition at line 131 of file TProof.h.

kPROOF_ConfDir

const char* const kPROOF_ConfDir = "/usr/local/root"

Definition at line 123 of file TProof.h.

kPROOF_ConfFile

const char* const kPROOF_ConfFile = "proof.conf"

Definition at line 122 of file TProof.h.

kPROOF_DataDir

const char* const kPROOF_DataDir = "data"

Definition at line 130 of file TProof.h.

kPROOF_DataSetDir

const char* const kPROOF_DataSetDir = "datasets"

Definition at line 129 of file TProof.h.

kPROOF_DynWrkPollInt_s

const Long64_t kPROOF_DynWrkPollInt_s = 10

Definition at line 138 of file TProof.h.

kPROOF_InputDataFile

const char* const kPROOF_InputDataFile = "inputdata.root"

Definition at line 136 of file TProof.h.

kPROOF_MissingFiles

const char* const kPROOF_MissingFiles = "MissingFiles"

Definition at line 137 of file TProof.h.

kPROOF_PackageLockFile

const char* const kPROOF_PackageLockFile = "proof-package-lock-"

Definition at line 132 of file TProof.h.

kPROOF_PackDir

const char* const kPROOF_PackDir = "packages"

Definition at line 126 of file TProof.h.

kPROOF_PackDownloadDir

const char* const kPROOF_PackDownloadDir = "downloaded"

Definition at line 127 of file TProof.h.

kPROOF_Port

const Int_t kPROOF_Port = 1093

Definition at line 121 of file TProof.h.

kPROOF_Protocol

const Int_t kPROOF_Protocol = 37

Definition at line 120 of file TProof.h.

kPROOF_QueryDir

const char* const kPROOF_QueryDir = "queries"

Definition at line 128 of file TProof.h.

kPROOF_QueryLockFile

const char* const kPROOF_QueryLockFile = "proof-query-lock-"

Definition at line 133 of file TProof.h.

kPROOF_TerminateWorker

const char* const kPROOF_TerminateWorker = "+++ terminating +++"

Definition at line 134 of file TProof.h.

kPROOF_WorkDir

const char* const kPROOF_WorkDir = ".proof"

Definition at line 124 of file TProof.h.

kPROOF_WorkerIdleTO

const char* const kPROOF_WorkerIdleTO = "+++ idle-timeout +++"

Definition at line 135 of file TProof.h.

kRM

const char* const kRM = "/bin/rm -rf"

Definition at line 142 of file TProof.h.

kUNTAR

const char* const kUNTAR = "%s -c %s/%s | (cd %s; tar xf -)"

Definition at line 144 of file TProof.h.

kUNTAR2

const char* const kUNTAR2 = "%s -c %s | (cd %s; tar xf -)"

Definition at line 145 of file TProof.h.

kUNTAR3

const char* const kUNTAR3 = "%s -c %s | (tar xf -)"

Definition at line 146 of file TProof.h.