Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
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_tFileMap_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 TClassClass ()
 
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)
 
TDrawFeedbackCreateDrawFeedback ()
 
Bool_t CreateMerger (TSlave *sl, Int_t port)
 
TSlaveCreateSlave (const char *url, const char *ord, Int_t perf, const char *image, const char *workdir)
 
TSlaveCreateSubmaster (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)
 
TListFindDataSets (const char *searchString, const char *optStr="")
 
Int_t FindNextFreeMerger ()
 
TSlaveFindSlave (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 TFileCollectionGetDataSet (const char *dataset, const char *optStr="")
 
TMapGetDataSetQuota (const char *optStr="")
 
virtual TMapGetDataSets (const char *uri="", const char *optStr="")
 
static TListGetDataSetSrvMaps (const TString &srvmaps)
 
TListGetEnabledPackages () const
 
TString Getenv (const char *env, const char *ord="0")
 
static const TListGetEnvVars ()
 
TListGetFeedbackList () 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)
 
TListGetInputList ()
 
TMacroGetLastLog ()
 
TListGetListOfActiveSlaves () const
 
TListGetListOfBadSlaves () const
 
TListGetListOfEnabledPackages ()
 
TListGetListOfInactiveSlaves () const
 
TListGetListOfPackages ()
 
virtual TListGetListOfQueries (Option_t *opt="")
 
TListGetListOfSlaveInfos ()
 
TListGetListOfSlaves () const
 
TListGetListOfUniqueSlaves () const
 
TListGetLoadedMacros () const
 
void GetLog (Int_t start=-1, Int_t end=-1)
 
Int_t GetLogLevel () const
 
TMacroGetMacroLog ()
 
TProofMgrGetManager ()
 
const char * GetMaster () const
 
void GetMaxQueries ()
 
TFileCollectionGetMissingFiles (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
 
TObjectGetOutput (const char *name)
 
static TObjectGetOutput (const char *name, TList *out)
 
TListGetOutputList ()
 
TListGetOutputNames ()
 
Int_t GetParallel () const
 
TObjectGetParameter (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)
 
TVirtualProofPlayerGetPlayer () const
 
Int_t GetPort () const
 
TPluginHandlerGetProgressDialog () const
 
EQueryMode GetQueryMode (Option_t *mode=0) const
 
Int_t GetQueryReference (Int_t qry, TString &ref)
 
TQueryResultGetQueryResult (const char *ref=0)
 
TListGetQueryResults ()
 
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 TFileCollectionGetStagingStatusDataSet (const char *dataset)
 
void GetStatistics (Bool_t verbose=kFALSE)
 
Int_t GetStatus () const
 
virtual TTreeGetTreeHeader (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 ()
 
TClassIsA () 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 TVirtualProofPlayerMakePlayer (const char *player=0, TSocket *s=0)
 
void MarkBad (TSlave *wrk, const char *reason=0)
 
void MarkBad (TSocket *s, const char *reason=0)
 
static TProofMgrMgr (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 TProofOpen (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

TMonitorfActiveMonitor
 
TListfActiveSlaves
 
TString fActiveSlavesSaved
 
TMonitorfAllMonitor
 
TMonitorfAllUniqueMonitor
 
TListfAllUniqueSlaves
 
TListfAvailablePackages
 
TListfBadSlaves
 
Long64_t fBytesRead
 
Long64_t fBytesReady
 
TListfChains
 
Int_t fCheckFileStatus
 
std::recursive_mutex fCloseMutex
 
Int_t fCollectTimeout
 
TString fConfDir
 
TString fConfFile
 
Float_t fCpuTime
 
TMonitorfCurrentMonitor
 
TString fDataPoolUrl
 
Bool_t fDataReady
 
Int_t fDrawQueries
 
TDSetfDSet
 
Bool_t fDynamicStartup
 
TListfEnabledPackages
 
TListfEnabledPackagesOnCluster
 
Bool_t fEndMaster
 
TListfFeedback
 
FileMap_t fFileMap
 
Bool_t fFinalizationRunning
 
static TPluginHandlerfgLogViewer
 
static TListfgProofEnvList
 
TString fGroup
 
TString fImage
 
TListfInactiveSlaves
 
TListfInputData
 
TString fInputDataFile
 
TSignalHandlerfIntHandler
 
Bool_t fIsPollingWorkers
 
Bool_t fIsWaiting
 
Int_t fLastAssignedMerger
 
Long64_t fLastPollWorkers_s
 
TListfLoadedMacros
 
TString fLogFileName
 
FILEfLogFileR
 
FILEfLogFileW
 
Int_t fLogLevel
 
Bool_t fLogToWindowOnly
 
TMacro fMacroLog
 
TProofMgrfManager
 
TString fMaster
 
Bool_t fMasterServ
 
Int_t fMaxDrawQueries
 
TProofMergePrg fMergePrg
 
TListfMergers
 
Bool_t fMergersByHost
 
Int_t fMergersCount
 
Bool_t fMergersSet
 
TListfNonUniqueMasters
 
Int_t fNotIdle
 
Int_t fOtherQueries
 
TProofOutputList fOutputList
 
TPackMgrfPackMgr
 
TString fPerfTree
 
TVirtualProofPlayerfPlayer
 
Float_t fPrepTime
 
PrintProgress_t fPrintProgress
 
TPluginHandlerfProgressDialog
 
Bool_t fProgressDialogStarted
 
Int_t fProtocol
 
TListfQueries
 
EQueryMode fQueryMode
 
TStopwatch fQuerySTW
 
Float_t fRealTime
 
TListfRecvMessages
 
Int_t fRedirectNext
 
Bool_t fRedirLog
 
TListfRunningDSets
 
ERunStatus fRunStatus
 
Bool_t fSaveLogToMacro
 
TSelectorfSelector
 
Bool_t fSendGroupView
 list returned by kPROOF_GETSLAVEINFO
 
Int_t fSeqNum
 
TProofMgr::EServType fServType
 
Int_t fSessionID
 
TListfSlaveInfo
 
TListfSlaves
 
Int_t fStatus
 
Bool_t fSync
 
TListfTerminatedSlaveInfos
 
Long64_t fTotalBytes
 
Bool_t fTty
 
TMonitorfUniqueMonitor
 
TListfUniqueSlaves
 
TUrl fUrl
 
Bool_t fValid
 
TListfWaitingSlaves
 
TString fWorkDir
 
Int_t fWorkersToMerge
 
TListfWrksOutputReady
 
R__EXTERN TProofgProof
 
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

Enumerator
kDontBuildOnClient 
kBuildOnSlavesNoWait 
kBuildAll 
kCollectBuildResults 

Definition at line 136 of file TProof.h.

◆ EProofCacheCommands

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

Enumerator
kPurge 
kUnregistered 
kDataset 
kForceClear 

Definition at line 68 of file TProof.h.

◆ EProofDataSetCommands

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

Enumerator
kPerGroup 
kPerUser 

Definition at line 142 of file TProof.h.

◆ EProofWrkListAction

Enumerator
kActivateWorker 
kDeactivateWorker 

Definition at line 132 of file TProof.h.

◆ EQueryMode

Enumerator
kSync 
kAsync 

Definition at line 32 of file TProof.h.

◆ ERegisterOpt

Enumerator
kFailIfExists 
kOverwriteIfExists 
kMergeIfExists 

Definition at line 44 of file TProof.h.

◆ 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

Enumerator
kUsingSessionGui 
kNewInputData 
kIsClient 
kIsMaster 
kIsTopMaster 
kUseProgressDialog 

Definition at line 24 of file TProof.h.

◆ ESubMerger

Enumerator
kOutputSize 
kSendOutput 
kBeMerger 
kMergerDown 
kStopMerging 
kOutputSent 

Definition at line 59 of file TProof.h.

◆ EUploadOpt

Enumerator
kAppend 
kOverwriteDataSet 
kNoOverwriteDataSet 
kOverwriteAllFiles 
kOverwriteNoFiles 
kAskUser 

Definition at line 36 of file TProof.h.

◆ 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.