|
| ~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) |
|