Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
TProof Class Reference

This class controls a Parallel ROOT Facility, PROOF, cluster.

It fires the worker servers, it keeps track of how many workers are running, it keeps track of the workers running status, it broadcasts messages to all workers, it collects results, etc.

Definition at line 316 of file TProof.h.

Classes

struct  MD5Mod_t
 

Public Types

enum  EProofClearData { kPurge = 0x1 , kUnregistered = 0x2 , kDataset = 0x4 , kForceClear = 0x8 }
 
enum  EQueryMode { kSync = 0 , kAsync = 1 }
 
enum  ERegisterOpt { kFailIfExists = 0 , kOverwriteIfExists = 1 , kMergeIfExists = 2 }
 
enum  ERunStatus { kRunning = 0 , kStopped = 1 , kAborted = 2 }
 
enum  EStatusBits {
  kUsingSessionGui = BIT(14) , kNewInputData = BIT(15) , kIsClient = BIT(16) , kIsMaster = BIT(17) ,
  kIsTopMaster = BIT(18) , kUseProgressDialog = BIT(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 }
 
- Public Types inherited from TObject
enum  {
  kIsOnHeap = 0x01000000 , kNotDeleted = 0x02000000 , kZombie = 0x04000000 , kInconsistent = 0x08000000 ,
  kBitMask = 0x00ffffff
}
 
enum  { kSingleKey = BIT(0) , kOverwrite = BIT(1) , kWriteDelete = BIT(2) }
 
enum  EDeprecatedStatusBits { kObjInCanvas = BIT(3) }
 
enum  EStatusBits {
  kCanDelete = BIT(0) , kMustCleanup = BIT(3) , kIsReferenced = BIT(4) , kHasUUID = BIT(5) ,
  kCannotPick = BIT(6) , kNoContextMenu = BIT(8) , kInvalidObject = BIT(13)
}
 

Public Member Functions

 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)
 Create a PROOF environment.
 
virtual ~TProof ()
 Clean up PROOF environment.
 
Int_t ActivateWorker (const char *ord, Bool_t save=kTRUE)
 Make sure that the worker identified by the ordinal number 'ord' is in the active list.
 
void AddChain (TChain *chain)
 Add chain to data set.
 
Int_t AddDynamicPath (const char *libpath, Bool_t onClient=kFALSE, TList *wrks=0, Bool_t doCollect=kTRUE)
 Add 'libpath' to the lib path search.
 
void AddFeedback (const char *name)
 Add object to feedback list.
 
Int_t AddIncludePath (const char *incpath, Bool_t onClient=kFALSE, TList *wrks=0, Bool_t doCollect=kTRUE)
 Add 'incpath' to the inc path search.
 
void AddInput (TObject *obj)
 Add objects that might be needed during the processing of the selector (see Process()).
 
void AddInputData (TObject *obj, Bool_t push=kFALSE)
 Add data objects that might be needed during the processing of the selector (see Process()).
 
Int_t Archive (const char *queryref, const char *url=0)
 Send archive request for the query specified by ref.
 
Int_t Archive (Int_t query, const char *url)
 Send archive request for the qry-th query in fQueries.
 
void Browse (TBrowser *b)
 Build the PROOF's structure in the browser.
 
virtual Bool_t CancelStagingDataSet (const char *dataset)
 Cancels a dataset staging request.
 
void cd (Int_t id=-1)
 Set session with 'id' the default one.
 
Int_t CleanupSession (const char *sessiontag)
 Send cleanup request for the session specified by tag.
 
virtual void ClearCache (const char *file=0)
 Remove file from all file caches.
 
void ClearData (UInt_t what=kUnregistered, const char *dsname=0)
 Remove files for the data directory.
 
virtual void ClearDataSetCache (const char *dataset=0)
 Clear the content of the dataset cache, if any (matching 'dataset', if defined).
 
void ClearFeedback ()
 Clear feedback list.
 
void ClearInput ()
 Clear input object list.
 
void ClearInputData (const char *name)
 Remove obj 'name' form the input data list;.
 
void ClearInputData (TObject *obj=0)
 Remove obj form the input data list; if obj is null (default), clear the input data info.
 
Int_t ClearPackage (const char *package)
 Remove a specific package.
 
Int_t ClearPackages ()
 Remove all packages.
 
void Close (Option_t *option="")
 Close all open slave servers.
 
void CloseProgressDialog ()
 Close progress dialog.
 
TDrawFeedbackCreateDrawFeedback ()
 Draw feedback creation proxy.
 
void DataSetStatus (const char *msg, Bool_t status, Int_t done, Int_t total)
 Send dataset preparation status.
 
Int_t DeactivateWorker (const char *ord, Bool_t save=kTRUE)
 Remove the worker identified by the ordinal number 'ord' from the the active list.
 
void DeleteDrawFeedback (TDrawFeedback *f)
 Delete draw feedback object.
 
void DeleteParameters (const char *wildcard)
 Delete the input list parameters specified by a wildcard (e.g.
 
void Detach (Option_t *opt="")
 Detach this instance to its proofserv.
 
void DisableGoAsyn ()
 Signal to disable related switches.
 
Int_t DownloadPackage (const char *par, const char *dstdir=0)
 Download a PROOF archive (PAR file) from the master package repository.
 
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)
 Execute the specified drawing action on a data set which is stored on the master with name 'dsetname'.
 
virtual Long64_t DrawSelect (TDSet *dset, const char *varexp, const char *selection="", Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
 Execute the specified drawing action on a data set (TDSet).
 
virtual Int_t Echo (const char *str)
 Sends a string to master and workers and expect them to echo it back to the client via a message.
 
virtual Int_t Echo (const TObject *obj)
 Sends an object to master and workers and expect them to send back a message with the output of its TObject::Print().
 
Int_t EnablePackage (const char *package, Bool_t notOnClient=kFALSE, TList *workers=0)
 Enable specified package.
 
Int_t EnablePackage (const char *package, const char *loadopts, Bool_t notOnClient=kFALSE, TList *workers=0)
 Enable specified package.
 
Int_t EnablePackage (const char *package, TList *loadopts, Bool_t notOnClient=kFALSE, TList *workers=0)
 Enable specified package.
 
Int_t Exec (const char *cmd, Bool_t plusMaster=kFALSE)
 Send command to be executed on the PROOF master and/or slaves.
 
Int_t Exec (const char *cmd, const char *ord, Bool_t logtomacro=kFALSE)
 Send command to be executed on node of ordinal 'ord' (use "0" for master).
 
virtual Bool_t ExistsDataSet (const char *dataset)
 Returns kTRUE if 'dataset' exists, kFALSE otherwise.
 
void Feedback (TList *objs)
 Get list of feedback objects.
 
Long64_t Finalize (const char *queryref, Bool_t force=kFALSE)
 Finalize query with reference ref.
 
Long64_t Finalize (Int_t query=-1, Bool_t force=kFALSE)
 Finalize the qry-th query in fQueries.
 
TListFindDataSets (const char *searchString, const char *optStr="")
 Find datasets, returns in a TList all found datasets.
 
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="")
 Get a list of TFileInfo objects describing the files of the specified dataset.
 
TMapGetDataSetQuota (const char *optStr="")
 returns a map of the quotas of all groups
 
virtual TMapGetDataSets (const char *uri="", const char *optStr="")
 Lists all datasets that match given uri.
 
TString Getenv (const char *env, const char *ord="0")
 Get value of environment variable 'env' on node 'ord'.
 
TListGetFeedbackList () const
 Return feedback list.
 
const char * GetGroup () const
 
const char * GetImage () const
 
TListGetInputList ()
 Get input list.
 
TMacroGetLastLog ()
 Fill a TMacro with the log lines since the last reading (fLogFileR) Return (TMacro *)0 if no line was logged.
 
TListGetListOfEnabledPackages ()
 Get from the master the list of names of the packages enabled.
 
TListGetListOfPackages ()
 Get from the master the list of names of the packages available.
 
virtual TListGetListOfQueries (Option_t *opt="")
 Ask the master for the list of queries.
 
TListGetListOfSlaveInfos ()
 Returns list of TSlaveInfo's. In case of error return 0.
 
TListGetLoadedMacros () const
 
void GetLog (Int_t start=-1, Int_t end=-1)
 Ask for remote logs in the range [start, end].
 
Int_t GetLogLevel () const
 
TMacroGetMacroLog ()
 
TProofMgrGetManager ()
 
const char * GetMaster () const
 
void GetMaxQueries ()
 Get max number of queries whose full results are kept in the remote sandbox.
 
TFileCollectionGetMissingFiles (TQueryResult *qr=0)
 Get a TFileCollection with the files missing in the query described by 'qr' or the last query if qr is null (default).
 
Int_t GetNumberOfDrawQueries ()
 
Int_t GetNumberOfQueries ()
 Number of queries processed by this session.
 
TObjectGetOutput (const char *name)
 Get specified object that has been produced during the processing (see Process()).
 
TListGetOutputList ()
 Get list with all object created during processing (see Process()).
 
TListGetOutputNames ()
 FIXME: to be written.
 
Int_t GetParallel () const
 Returns number of slaves active in parallel mode.
 
TObjectGetParameter (const char *par) const
 Get specified parameter.
 
Int_t GetPort () const
 
EQueryMode GetQueryMode (Option_t *mode=0) const
 Find out the query mode based on the current setting and 'mode'.
 
TQueryResultGetQueryResult (const char *ref=0)
 Return pointer to the full TQueryResult instance owned by the player and referenced by 'ref'.
 
TListGetQueryResults ()
 Return pointer to the list of query results in the player.
 
Int_t GetRC (const char *RCenv, Double_t &env, const char *ord="0")
 Get into 'env' the value of double RC env variable 'rcenv' on node 'ord'.
 
Int_t GetRC (const char *RCenv, Int_t &env, const char *ord="0")
 Get into 'env' the value of integer RC env variable 'rcenv' on node 'ord'.
 
Int_t GetRC (const char *RCenv, TString &env, const char *ord="0")
 Get into 'env' the value of string RC env variable 'rcenv' on node 'ord'.
 
Float_t GetRealTime () const
 
Int_t GetRemoteProtocol () const
 
ERunStatus GetRunStatus () const
 
Int_t GetSeqNum () const
 
Int_t GetSessionID () const
 
const char * GetSessionTag () const
 
virtual TFileCollectionGetStagingStatusDataSet (const char *dataset)
 Obtains a TFileCollection showing the staging status of the specified dataset.
 
void GetStatistics (Bool_t verbose=kFALSE)
 Get statistics about CPU time, real time and bytes read.
 
Int_t GetStatus () const
 
virtual TTreeGetTreeHeader (TDSet *tdset)
 Creates a tree header (a tree with nonexisting files) object for the DataSet.
 
const char * GetUrl ()
 
const char * GetUser () const
 
const char * GetWorkDir () const
 
void GoAsynchronous ()
 Send GOASYNC message to the master.
 
Bool_t IsDataReady (Long64_t &totalbytes, Long64_t &bytesready)
 See if the data is ready to be analyzed.
 
Bool_t IsFolder () const
 Returns kTRUE in case object contains browsable objects (like containers or lists of other objects).
 
Bool_t IsIdle () const
 
Bool_t IsLite () const
 
Bool_t IsMaster () const
 
Bool_t IsParallel () const
 
Bool_t IsProofd () 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)
 Load the specified macro on master, workers and, if notOnClient is kFALSE, on the client.
 
void LogMessage (const char *msg, Bool_t all)
 Log a message into the appropriate window by emitting a signal.
 
Int_t Ping ()
 Ping PROOF. Returns 1 if master server responded.
 
virtual void Print (Option_t *option="") const
 Print status of PROOF cluster.
 
virtual Long64_t Process (const char *dsetname, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0, TObject *enl=0)
 Process a dataset which is stored on the master with name 'dsetname'.
 
virtual Long64_t Process (const char *dsetname, TSelector *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0, TObject *enl=0)
 Process with name of dataset and TSelector object.
 
virtual Long64_t Process (const char *selector, Long64_t nentries, Option_t *option="")
 Generic (non-data based) selector processing: the Process() method of the specified selector (.C) or TSelector object is called 'n' times.
 
virtual Long64_t Process (TDSet *dset, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
 Process a data set (TDSet) using the specified selector (.C) file or Tselector object Entry- or event-lists should be set in the data set object using TDSet::SetEntryList.
 
virtual Long64_t Process (TDSet *dset, TSelector *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
 Process a data set (TDSet) using the specified selector object.
 
virtual Long64_t Process (TFileCollection *fc, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
 Process a data set (TFileCollection) using the specified selector (.C) file or TSelector object.
 
virtual Long64_t Process (TFileCollection *fc, TSelector *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
 Process a data set (TFileCollection) using the specified selector object The default tree is analyzed (i.e.
 
virtual Long64_t Process (TSelector *selector, Long64_t nentries, Option_t *option="")
 Generic (non-data based) selector processing: the Process() method of the specified selector is called 'n' times.
 
void Progress (Long64_t total, Long64_t processed)
 Get query progress information.
 
void Progress (Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
 Get query progress information.
 
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)
 Get query progress information.
 
void PutLog (TQueryResult *qr)
 Display log of query pq into the log window frame.
 
void QueryResultReady (const char *ref)
 Notify availability of a query result.
 
virtual Bool_t RegisterDataSet (const char *name, TFileCollection *dataset, const char *optStr="")
 Register the 'dataSet' on the cluster under the current user, group and the given 'dataSetName'.
 
Int_t Remove (const char *queryref, Bool_t all=kFALSE)
 Send remove request for the query specified by ref.
 
Int_t Remove (Int_t query, Bool_t all=kFALSE)
 Send remove request for the qry-th query in fQueries.
 
void RemoveChain (TChain *chain)
 Remove chain from data set.
 
virtual Int_t RemoveDataSet (const char *dataset, const char *optStr="")
 Remove the specified dataset from the PROOF cluster.
 
Int_t RemoveDynamicPath (const char *libpath, Bool_t onClient=kFALSE)
 Remove 'libpath' from the lib path search.
 
void RemoveFeedback (const char *name)
 Remove object from feedback list.
 
Int_t RemoveIncludePath (const char *incpath, Bool_t onClient=kFALSE)
 Remove 'incpath' from the inc path search.
 
virtual Bool_t RequestStagingDataSet (const char *dataset)
 Allows users to request staging of a particular dataset.
 
void ResetProgressDialog (const char *sel, Int_t sz, Long64_t fst, Long64_t ent)
 Reset progress dialog.
 
void ResetProgressDialogStatus ()
 
Int_t Retrieve (const char *queryref, const char *path=0)
 Send retrieve request for the query specified by ref.
 
Int_t Retrieve (Int_t query, const char *path=0)
 Send retrieve request for the qry-th query in fQueries.
 
Int_t SavePerfTree (const char *pf=0, const char *qref=0)
 Save performance information from TPerfStats to file 'pf'.
 
void SendDataSetStatus (const char *msg, UInt_t n, UInt_t tot, Bool_t st)
 Send or notify data set status.
 
Bool_t SendingLogToWindow () const
 
void SendLogToWindow (Bool_t mode)
 
void SetActive (Bool_t=kTRUE)
 
virtual void SetAlias (const char *alias="")
 Set an alias for this session.
 
void SetDataPoolUrl (const char *url)
 
virtual Int_t SetDataSetTreeName (const char *dataset, const char *treename)
 Set/Change the name of the default tree.
 
void SetDrawFeedbackOption (TDrawFeedback *f, Option_t *opt)
 Set draw feedback option.
 
void SetInputDataFile (const char *datafile)
 Set the file to be used to optimally distribute the input data objects.
 
void SetLogLevel (Int_t level, UInt_t mask=TProofDebug::kAll)
 Set server logging level.
 
void SetManager (TProofMgr *mgr)
 Set manager and schedule its destruction after this for clean operations.
 
void SetMaxDrawQueries (Int_t max)
 Set max number of draw queries whose results are saved.
 
Int_t SetParallel (Int_t nodes=-1, Bool_t random=kFALSE)
 Tell PROOF how many slaves to use in parallel.
 
void SetParameter (const char *par, const char *value)
 Set input list parameter.
 
void SetParameter (const char *par, Double_t value)
 Set an input list parameter.
 
void SetParameter (const char *par, Int_t value)
 Set an input list parameter.
 
void SetParameter (const char *par, Long64_t value)
 Set an input list parameter.
 
void SetParameter (const char *par, Long_t value)
 Set an input list parameter.
 
void SetPerfTree (const char *pf="perftree.root", Bool_t withWrks=kFALSE)
 Enable/Disable saving of the performance tree.
 
void SetPrintProgress (PrintProgress_t pp)
 
void SetProgressDialog (Bool_t on=kTRUE)
 Enable/Disable the graphic progress dialog.
 
void SetQueryMode (EQueryMode mode)
 Change query running mode to the one specified by 'mode'.
 
void SetRealTimeLog (Bool_t on=kTRUE)
 Switch ON/OFF the real-time logging facility.
 
virtual void ShowCache (Bool_t all=kFALSE)
 List contents of file cache.
 
virtual void ShowData ()
 List contents of the data directory in the sandbox.
 
void ShowDataSet (const char *dataset="", const char *opt="filter:SsCc")
 display meta-info for given dataset usi
 
virtual void ShowDataSetCache (const char *dataset=0)
 Display the content of the dataset cache, if any (matching 'dataset', if defined).
 
void ShowDataSetQuota (Option_t *opt=0)
 shows the quota and usage of all groups if opt contains "U" shows also distribution of usage on user-level
 
virtual void ShowDataSets (const char *uri="", const char *optStr="")
 Shows datasets in locations that match the uri.
 
void ShowEnabledPackages (Bool_t all=kFALSE)
 List which packages are enabled.
 
void ShowFeedback () const
 Show items in feedback list.
 
void ShowLog (const char *queryref)
 Display on screen the content of the temporary log file for query in reference.
 
void ShowLog (Int_t qry=-1)
 Display on screen the content of the temporary log file.
 
void ShowMissingFiles (TQueryResult *qr=0)
 Show information about missing files during query described by 'qr' or the last query if qr is null (default).
 
void ShowPackages (Bool_t all=kFALSE, Bool_t redirlog=kFALSE)
 List contents of package directory.
 
void ShowParameters (const char *wildcard="PROOF_*") const
 Show the input list parameters specified by the wildcard.
 
void ShowQueries (Option_t *opt="")
 Ask the master for the list of queries.
 
virtual void ShowStagingStatusDataSet (const char *dataset, const char *optStr="filter:SsCc")
 Like GetStagingStatusDataSet, but displays results immediately.
 
void StartupMessage (const char *msg, Bool_t status, Int_t done, Int_t total)
 Send startup message.
 
void StopProcess (Bool_t abort, Int_t timeout=-1)
 Send STOPPROCESS message to master and workers.
 
void Touch ()
 Ping PROOF slaves. Returns the number of slaves that responded.
 
Int_t UploadDataSet (const char *, const char *, const char *=0, Int_t=0, TList *=0)
 *** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp.
 
Int_t UploadDataSet (const char *, TList *, const char *=0, Int_t=0, TList *=0)
 *** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp.
 
Int_t UploadDataSetFromFile (const char *, const char *, const char *=0, Int_t=0, TList *=0)
 *** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp.
 
Int_t UploadPackage (const char *par, EUploadPackageOpt opt=kUntar, TList *workers=0)
 Upload a PROOF archive (PAR file).
 
Bool_t UseDynamicStartup () const
 
virtual Int_t VerifyDataSet (const char *dataset, const char *optStr="")
 Verify if all files in the specified dataset are available.
 
- Public Member Functions inherited from TNamed
 TNamed ()
 
 TNamed (const char *name, const char *title)
 
 TNamed (const TNamed &named)
 TNamed copy ctor.
 
 TNamed (const TString &name, const TString &title)
 
virtual ~TNamed ()
 TNamed destructor.
 
virtual void Clear (Option_t *option="")
 Set name and title to empty strings ("").
 
virtual TObjectClone (const char *newname="") const
 Make a clone of an object using the Streamer facility.
 
virtual Int_t Compare (const TObject *obj) const
 Compare two TNamed objects.
 
virtual void Copy (TObject &named) const
 Copy this to obj.
 
virtual void FillBuffer (char *&buffer)
 Encode TNamed into output buffer.
 
virtual const char * GetName () const
 Returns name of object.
 
virtual const char * GetTitle () const
 Returns title of object.
 
virtual ULong_t Hash () const
 Return hash value for this object.
 
virtual Bool_t IsSortable () const
 
virtual void ls (Option_t *option="") const
 List TNamed name and title.
 
TNamedoperator= (const TNamed &rhs)
 TNamed assignment operator.
 
virtual void SetName (const char *name)
 Set the name of the TNamed.
 
virtual void SetNameTitle (const char *name, const char *title)
 Set all the TNamed parameters (name and title).
 
virtual void SetTitle (const char *title="")
 Set the title of the TNamed.
 
virtual Int_t Sizeof () const
 Return size of the TNamed part of the TObject.
 
- Public Member Functions inherited from TObject
 TObject ()
 TObject constructor.
 
 TObject (const TObject &object)
 TObject copy ctor.
 
virtual ~TObject ()
 TObject destructor.
 
void AbstractMethod (const char *method) const
 Use this method to implement an "abstract" method that you don't want to leave purely abstract.
 
virtual void AppendPad (Option_t *option="")
 Append graphics object to current pad.
 
ULong_t CheckedHash ()
 Check and record whether this class has a consistent Hash/RecursiveRemove setup (*) and then return the regular Hash value for this object.
 
virtual const char * ClassName () const
 Returns name of class to which the object belongs.
 
virtual void Delete (Option_t *option="")
 Delete this object.
 
virtual Int_t DistancetoPrimitive (Int_t px, Int_t py)
 Computes distance from point (px,py) to the object.
 
virtual void Draw (Option_t *option="")
 Default Draw method for all objects.
 
virtual void DrawClass () const
 Draw class inheritance tree of the class to which this object belongs.
 
virtual TObjectDrawClone (Option_t *option="") const
 Draw a clone of this object in the current selected pad for instance with: gROOT->SetSelectedPad(gPad).
 
virtual void Dump () const
 Dump contents of object on stdout.
 
virtual void Error (const char *method, const char *msgfmt,...) const
 Issue error message.
 
virtual void Execute (const char *method, const char *params, Int_t *error=0)
 Execute method on this object with the given parameter string, e.g.
 
virtual void Execute (TMethod *method, TObjArray *params, Int_t *error=0)
 Execute method on this object with parameters stored in the TObjArray.
 
virtual void ExecuteEvent (Int_t event, Int_t px, Int_t py)
 Execute action corresponding to an event at (px,py).
 
virtual void Fatal (const char *method, const char *msgfmt,...) const
 Issue fatal error message.
 
virtual TObjectFindObject (const char *name) const
 Must be redefined in derived classes.
 
virtual TObjectFindObject (const TObject *obj) const
 Must be redefined in derived classes.
 
virtual Option_tGetDrawOption () const
 Get option used by the graphics system to draw this object.
 
virtual const char * GetIconName () const
 Returns mime type name of object.
 
virtual char * GetObjectInfo (Int_t px, Int_t py) const
 Returns string containing info about the object at position (px,py).
 
virtual Option_tGetOption () const
 
virtual UInt_t GetUniqueID () const
 Return the unique object id.
 
virtual Bool_t HandleTimer (TTimer *timer)
 Execute action in response of a timer timing out.
 
Bool_t HasInconsistentHash () const
 Return true is the type of this object is known to have an inconsistent setup for Hash and RecursiveRemove (i.e.
 
virtual void Info (const char *method, const char *msgfmt,...) const
 Issue info message.
 
virtual Bool_t InheritsFrom (const char *classname) const
 Returns kTRUE if object inherits from class "classname".
 
virtual Bool_t InheritsFrom (const TClass *cl) const
 Returns kTRUE if object inherits from TClass cl.
 
virtual void Inspect () const
 Dump contents of this object in a graphics canvas.
 
void InvertBit (UInt_t f)
 
virtual Bool_t IsEqual (const TObject *obj) const
 Default equal comparison (objects are equal if they have the same address in memory).
 
R__ALWAYS_INLINE Bool_t IsOnHeap () const
 
R__ALWAYS_INLINE Bool_t IsZombie () const
 
void MayNotUse (const char *method) const
 Use this method to signal that a method (defined in a base class) may not be called in a derived class (in principle against good design since a child class should not provide less functionality than its parent, however, sometimes it is necessary).
 
virtual Bool_t Notify ()
 This method must be overridden to handle object notification.
 
void Obsolete (const char *method, const char *asOfVers, const char *removedFromVers) const
 Use this method to declare a method obsolete.
 
void operator delete (void *ptr)
 Operator delete.
 
void operator delete[] (void *ptr)
 Operator delete [].
 
voidoperator new (size_t sz)
 
voidoperator new (size_t sz, void *vp)
 
voidoperator new[] (size_t sz)
 
voidoperator new[] (size_t sz, void *vp)
 
TObjectoperator= (const TObject &rhs)
 TObject assignment operator.
 
virtual void Paint (Option_t *option="")
 This method must be overridden if a class wants to paint itself.
 
virtual void Pop ()
 Pop on object drawn in a pad to the top of the display list.
 
virtual Int_t Read (const char *name)
 Read contents of object with specified name from the current directory.
 
virtual void RecursiveRemove (TObject *obj)
 Recursively remove this object from a list.
 
void ResetBit (UInt_t f)
 
virtual void SaveAs (const char *filename="", Option_t *option="") const
 Save this object in the file specified by filename.
 
virtual void SavePrimitive (std::ostream &out, Option_t *option="")
 Save a primitive as a C++ statement(s) on output stream "out".
 
void SetBit (UInt_t f)
 
void SetBit (UInt_t f, Bool_t set)
 Set or unset the user status bits as specified in f.
 
virtual void SetDrawOption (Option_t *option="")
 Set drawing option for object.
 
virtual void SetUniqueID (UInt_t uid)
 Set the unique object id.
 
virtual void SysError (const char *method, const char *msgfmt,...) const
 Issue system error message.
 
R__ALWAYS_INLINE Bool_t TestBit (UInt_t f) const
 
Int_t TestBits (UInt_t f) const
 
virtual void UseCurrentStyle ()
 Set current style settings in this object This function is called when either TCanvas::UseCurrentStyle or TROOT::ForceStyle have been invoked.
 
virtual void Warning (const char *method, const char *msgfmt,...) const
 Issue warning message.
 
virtual Int_t Write (const char *name=0, Int_t option=0, Int_t bufsize=0)
 Write this object to the current directory.
 
virtual Int_t Write (const char *name=0, Int_t option=0, Int_t bufsize=0) const
 Write this object to the current directory.
 
- Public Member Functions inherited from TQObject
 TQObject ()
 TQObject Constructor.
 
virtual ~TQObject ()
 TQObject Destructor.
 
Bool_t AreSignalsBlocked () const
 
Bool_t BlockSignals (Bool_t b)
 
virtual void ChangedBy (const char *method)
 
void CollectClassSignalLists (TList &list, TClass *cls)
 Collect class signal lists from class cls and all its base-classes.
 
Bool_t Connect (const char *signal, const char *receiver_class, void *receiver, const char *slot)
 Non-static method is used to connect from the signal of this object to the receiver slot.
 
virtual void Connected (const char *)
 
virtual void Destroyed ()
 
Bool_t Disconnect (const char *signal=0, void *receiver=0, const char *slot=0)
 Disconnects signal of this object from slot of receiver.
 
virtual void Disconnected (const char *)
 
void Emit (const char *signal)
 Activate signal without args.
 
template<typename T >
void Emit (const char *signal, const T &arg)
 Activate signal with single parameter.
 
template<typename... T>
void EmitVA (const char *signal_name, Int_t, const T &... params)
 Emit a signal with a varying number of arguments.
 
TListGetListOfClassSignals () const
 Returns pointer to list of signals of this class.
 
TListGetListOfConnections () const
 
TListGetListOfSignals () const
 
virtual Bool_t HasConnection (const char *signal_name) const
 Return true if there is any object connected to this signal.
 
virtual void HighPriority (const char *signal_name, const char *slot_name=0)
 
virtual void LowPriority (const char *signal_name, const char *slot_name=0)
 
virtual void Message (const char *msg)
 
virtual Int_t NumberOfConnections () const
 Return number of connections for this object.
 
virtual Int_t NumberOfSignals () const
 Return number of signals for this object.
 

Static Public Member Functions

static void AddEnvVar (const char *name, const char *value)
 Add an variable to the list of environment variables passed to proofserv on the master and slaves.
 
static void DelEnvVar (const char *name)
 Remove an variable from the list of environment variables passed to proofserv on the master and slaves.
 
static const TListGetEnvVars ()
 Get environemnt variables.
 
static TObjectGetOutput (const char *name, TList *out)
 Find object 'name' in list 'out' or in the files specified in there.
 
static Int_t GetParameter (TCollection *c, const char *par, Double_t &value)
 Get the value from the specified parameter from the specified collection.
 
static Int_t GetParameter (TCollection *c, const char *par, Int_t &value)
 Get the value from the specified parameter from the specified collection.
 
static Int_t GetParameter (TCollection *c, const char *par, Long64_t &value)
 Get the value from the specified parameter from the specified collection.
 
static Int_t GetParameter (TCollection *c, const char *par, Long_t &value)
 Get the value from the specified parameter from the specified collection.
 
static Int_t GetParameter (TCollection *c, const char *par, TString &value)
 Get the value from the specified parameter from the specified collection.
 
static void LogViewer (const char *url=0, Int_t sessionidx=0)
 Start the log viewer window usign the plugin manager.
 
static TProofMgrMgr (const char *url)
 Get instance of the effective manager for 'url' Return 0 on failure.
 
static TProofOpen (const char *url=0, const char *conffile=0, const char *confdir=0, Int_t loglevel=0)
 Start a PROOF session on a specific cluster.
 
static void Reset (const char *url, Bool_t hard=kFALSE)
 Wrapper around TProofMgr::Reset(...).
 
static void ResetEnvVars ()
 Clear the list of environment variables passed to proofserv on the master and slaves.
 
- Static Public Member Functions inherited from TObject
static Long_t GetDtorOnly ()
 Return destructor only flag.
 
static Bool_t GetObjectStat ()
 Get status of object stat flag.
 
static void SetDtorOnly (void *obj)
 Set destructor only flag.
 
static void SetObjectStat (Bool_t stat)
 Turn on/off tracking of objects in the TObjectTable.
 
- Static Public Member Functions inherited from TQObject
static Bool_t AreAllSignalsBlocked ()
 Returns true if all signals are blocked.
 
static Bool_t BlockAllSignals (Bool_t b)
 Block or unblock all signals. Returns the previous block status.
 
static Bool_t Connect (const char *sender_class, const char *signal, const char *receiver_class, void *receiver, const char *slot)
 This method allows to make a connection from any object of the same class to a single slot.
 
static Bool_t Connect (TQObject *sender, const char *signal, const char *receiver_class, void *receiver, const char *slot)
 Create connection between sender and receiver.
 
static Bool_t Disconnect (const char *class_name, const char *signal, void *receiver=0, const char *slot=0)
 Disconnects "class signal".
 
static Bool_t Disconnect (TQObject *sender, const char *signal=0, void *receiver=0, const char *slot=0)
 Disconnects signal in object sender from slot_method in object receiver.
 

Protected Types

enum  ESlaves { kAll , kActive , kUnique , kAllUnique }
 
- Protected Types inherited from TObject
enum  { kOnlyPrepStep = BIT(3) }
 

Protected Member Functions

 TProof ()
 Protected constructor to be used by classes deriving from TProof (they have to call Init themselves and override StartSlaves appropriately).
 
Int_t AddWorkers (TList *wrks)
 Works on the master node only.
 
Int_t AssertPath (const char *path, Bool_t writable)
 Make sure that 'path' exists; if 'writable' is kTRUE, make also sure that the path is writable.
 
Int_t Collect (ESlaves list=kActive, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
 Collect responses from the slave servers.
 
Int_t Collect (TList *slaves, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
 Collect responses from the slave servers.
 
TSlaveCreateSlave (const char *url, const char *ord, Int_t perf, const char *image, const char *workdir)
 Create a new TSlave of type TSlave::kSlave.
 
TSlaveCreateSubmaster (const char *url, const char *ord, const char *image, const char *msd, Int_t nwk=1)
 Create a new TSlave of type TSlave::kMaster.
 
TListGetEnabledPackages () const
 
TListGetListOfActiveSlaves () const
 
TVirtualProofPlayerGetPlayer () const
 
TPluginHandlerGetProgressDialog () const
 
Int_t GetSandbox (TString &sb, Bool_t assert=kFALSE, const char *rc=0)
 Set the sandbox path from ' Proof.Sandbox' or the alternative var 'rc'.
 
void HandleLibIncPath (const char *what, Bool_t add, const char *dirs)
 Handle lib, inc search paths modification request.
 
Int_t HandleOutputOptions (TString &opt, TString &target, Int_t action)
 Extract from opt information about output handling settings.
 
Int_t Init (const char *masterurl, const char *conffile, const char *confdir, Int_t loglevel, const char *alias=0)
 Start the PROOF environment.
 
void InitMembers ()
 Default initializations.
 
virtual TVirtualProofPlayerMakePlayer (const char *player=0, TSocket *s=0)
 Construct a TProofPlayer object.
 
virtual Int_t PollForNewWorkers ()
 Asks the PROOF Serv for new workers in Dynamic Startup mode and activates them.
 
void PrepareInputDataFile (TString &dataFile)
 Prepare the file with the input data objects to be sent the master; the objects are taken from the dedicated list and / or the specified file.
 
Int_t RemoveWorkers (TList *wrks)
 Used for shuting down the workres after a query is finished.
 
virtual void SaveWorkerInfo ()
 Save information about the worker set in the file .workers in the working dir.
 
Int_t SendFile (const char *file, Int_t opt=(kBinary|kForward|kCp|kCpBin), const char *rfile=0, TSlave *sl=0)
 Send a file to master or slave servers.
 
virtual void SendInputDataFile ()
 Send the input data objects to the master; the objects are taken from the dedicated list and / or the specified file.
 
void SetDSet (TDSet *dset)
 
void SetFeedback (TString &opt, TString &optfb, Int_t action)
 Extract from opt in optfb information about wanted feedback settings.
 
void SetPlayer (TVirtualProofPlayer *player)
 Set a new PROOF player.
 
void SetupWorkersEnv (TList *wrks, Bool_t increasingpool=kFALSE)
 Set up packages, loaded macros, include and lib paths ...
 
virtual Bool_t StartSlaves (Bool_t attach=kFALSE)
 Start up PROOF slaves.
 
void UpdateDialog ()
 Final update of the progress dialog.
 
virtual void ValidateDSet (TDSet *dset)
 Validate a TDSet.
 
Int_t VerifyDataSetParallel (const char *uri, const char *optStr)
 Internal function for parallel dataset verification used TProof::VerifyDataSet and TProofLite::VerifyDataSet.
 
- Protected Member Functions inherited from TObject
virtual void DoError (int level, const char *location, const char *fmt, va_list va) const
 Interface to ErrorHandler (protected).
 
void MakeZombie ()
 
- Protected Member Functions inherited from TQObject
virtual voidGetSender ()
 
virtual const char * GetSenderClassName () const
 

Static Protected Member Functions

static Int_t AssertDataSet (TDSet *dset, TList *input, TDataSetManager *mgr, TString &emsg)
 Make sure that dataset is in the form to be processed.
 
static void AssertMacroPath (const char *macro)
 Make sure that the directory path contained by macro is in the macro path.
 
static Bool_t GetFileInCmd (const char *cmd, TString &fn)
 Static method to extract the filename (if any) form a CINT command.
 
static Int_t GetInputData (TList *input, const char *cachedir, TString &emsg)
 Get the input data from the file defined in the input list.
 
static Int_t SaveInputData (TQueryResult *qr, const char *cachedir, TString &emsg)
 Save input data file from 'cachedir' into the sandbox or create a the file with input data objects.
 
static Int_t SendInputData (TQueryResult *qr, TProof *p, TString &emsg)
 Send the input data file to the workers.
 
static voidSlaveStartupThread (void *arg)
 
static void SystemCmd (const char *cmd, Int_t fdout)
 Exec system command 'cmd'. If fdout > -1, append the output to fdout.
 
- Static Protected Member Functions inherited from TQObject
static Int_t CheckConnectArgs (TQObject *sender, TClass *sender_class, const char *signal, TClass *receiver_class, const char *slot)
 Checking of consistency of sender/receiver methods/arguments.
 
static TString CompressName (const char *method_name)
 Removes "const" words and blanks from full (with prototype) method name and resolve any typedefs in the method signature.
 
static Bool_t ConnectToClass (const char *sender_class, const char *signal, TClass *receiver_class, void *receiver, const char *slot)
 This method allows to make connection from any object of the same class to the receiver object.
 
static Bool_t ConnectToClass (TQObject *sender, const char *signal, TClass *receiver_class, void *receiver, const char *slot)
 Create connection between sender and receiver.
 

Protected Attributes

TMonitorfAllMonitor
 
TListfAvailablePackages
 
TListfBadSlaves
 
Long64_t fBytesReady
 
Int_t fCollectTimeout
 
TString fConfDir
 
TString fConfFile
 
TString fDataPoolUrl
 
Bool_t fDataReady
 
Bool_t fDynamicStartup
 
TListfEnabledPackages
 
TString fImage
 
TProofMgrfManager
 
Bool_t fMasterServ
 
Float_t fPrepTime
 
Int_t fProtocol
 
EQueryMode fQueryMode
 
TStopwatch fQuerySTW
 
TListfRunningDSets
 
TSelectorfSelector
 
TProofMgr::EServType fServType
 
TListfSlaves
 
TListfTerminatedSlaveInfos
 
Long64_t fTotalBytes
 
TUrl fUrl
 
- Protected Attributes inherited from TNamed
TString fName
 
TString fTitle
 
- Protected Attributes inherited from TQObject
TListfListOfConnections
 list of signals from this object
 
TListfListOfSignals
 
Bool_t fSignalsBlocked
 list of connections to this object
 

Private Types

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  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  ESendFileOpt {
  kAscii = 0x0 , kBinary = 0x1 , kForce = 0x2 , kForward = 0x4 ,
  kCpBin = 0x8 , kCp = 0x10
}
 
enum  EUrgent {
  kLocalInterrupt = -1 , kPing = 0 , kHardInterrupt = 1 , kSoftInterrupt ,
  kShutdownInterrupt
}
 
typedef std::map< TString, MD5Mod_tFileMap_t
 

Private Member Functions

 TProof (const TProof &)
 
void Activate (TList *slaves=0)
 Activate slave server list.
 
void ActivateAsyncInput ()
 Activate the a-sync input handler.
 
void AskForOutput (TSlave *sl)
 Master asks for output from worker sl.
 
void AskParallel ()
 Ask the for the number of parallel slaves.
 
void AskStatistics ()
 Ask the for the statistics of the slaves.
 
Int_t Broadcast (const char *mess, Int_t kind, TList *slaves)
 Broadcast a character string buffer to all slaves in the specified list.
 
Int_t Broadcast (const char *mess, Int_t kind=kMESS_STRING, ESlaves list=kActive)
 Broadcast a character string buffer to all slaves in the specified list (either all slaves or only the active slaves).
 
Int_t Broadcast (const TMessage &mess, ESlaves list=kActive)
 Broadcast a message to all slaves in the specified list (either all slaves or only the active slaves).
 
Int_t Broadcast (const TMessage &mess, TList *slaves)
 Broadcast a message to all slaves in the specified list.
 
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)
 Broadcast file to all workers in the specified list.
 
Int_t BroadcastFile (const char *file, Int_t opt, const char *rfile=0, ESlaves list=kAllUnique)
 Broadcast file to all workers in the specified list.
 
Int_t BroadcastGroupPriority (const char *grp, Int_t priority, ESlaves list=kAllUnique)
 Broadcast the group priority to all workers in the specified list.
 
Int_t BroadcastGroupPriority (const char *grp, Int_t priority, TList *workers)
 Broadcast the group priority to all workers in the specified list.
 
Int_t BroadcastObject (const TObject *obj, Int_t kind, TList *slaves)
 Broadcast an object to all slaves in the specified list.
 
Int_t BroadcastObject (const TObject *obj, Int_t kind=kMESS_OBJECT, ESlaves list=kActive)
 Broadcast an object to all slaves in the specified list.
 
Int_t BroadcastRaw (const void *buffer, Int_t length, ESlaves list=kActive)
 Broadcast a raw buffer of specified length to all slaves in the specified list.
 
Int_t BroadcastRaw (const void *buffer, Int_t length, TList *slaves)
 Broadcast a raw buffer of specified length to all slaves in the specified list.
 
Int_t BuildPackage (const char *package, EBuildPackageOpt opt=kBuildAll, Int_t chkveropt=TPackMgr::kCheckROOT, TList *workers=0)
 Build specified package.
 
Bool_t CheckFile (const char *file, TSlave *sl, Long_t modtime, Int_t cpopt=(kCp|kCpBin))
 Check if a file needs to be send to the slave.
 
void CleanGDirectory (TList *ol)
 Remove links to objects in list 'ol' from gDirectory.
 
void ClearDataProgress (Int_t r, Int_t t)
 Progress bar for clear data.
 
Int_t Collect (const TSlave *sl, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
 Collect responses from slave sl.
 
Int_t Collect (TMonitor *mon, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
 Collect responses from the slave servers.
 
Int_t CollectInputFrom (TSocket *s, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
 Collect and analyze available input from socket s.
 
Bool_t CreateMerger (TSlave *sl, Int_t port)
 Create a new merger.
 
void DeActivateAsyncInput ()
 De-activate a-sync input handler.
 
Int_t DisablePackage (const char *package)
 Remove a specific package.
 
Int_t DisablePackages ()
 Remove all packages.
 
Int_t Exec (const char *cmd, ESlaves list, Bool_t plusMaster)
 Send command to be executed on the PROOF master and/or slaves.
 
void FinalizationDone ()
 
Int_t FindNextFreeMerger ()
 Return a merger, which is both active and still accepts some workers to be assigned to it.
 
TSlaveFindSlave (TSocket *s) const
 Find slave that has TSocket s. Returns 0 in case slave is not found.
 
virtual void FindUniqueSlaves ()
 Add to the fUniqueSlave list the active slaves that have a unique (user) file system image.
 
Int_t GetActiveMergersCount ()
 Get the active mergers count.
 
TListGetListOfBadSlaves () const
 
TListGetListOfInactiveSlaves () const
 
TListGetListOfSlaves () const
 
TListGetListOfUniqueSlaves () const
 
Int_t GetNumberOfActiveSlaves () const
 Return number of active slaves, i.e.
 
Int_t GetNumberOfBadSlaves () const
 Return number of bad slaves.
 
Int_t GetNumberOfInactiveSlaves () const
 Return number of inactive slaves, i.e.
 
Int_t GetNumberOfSlaves () const
 Return number of slaves as described in the config file.
 
Int_t GetNumberOfUniqueSlaves () const
 Return number of unique slaves, i.e.
 
Int_t GetQueryReference (Int_t qry, TString &ref)
 Get reference for the qry-th query in fQueries (as displayed by ShowQueries).
 
Int_t GoMoreParallel (Int_t nWorkersToAdd)
 Add nWorkersToAdd workers to current list of workers.
 
Int_t GoParallel (Int_t nodes, Bool_t accept=kFALSE, Bool_t random=kFALSE)
 Go in parallel mode with at most "nodes" slaves.
 
Int_t HandleInputMessage (TSlave *wrk, TMessage *m, Bool_t deactonfail=kFALSE)
 Analyze the received message.
 
void HandleSubmerger (TMessage *mess, TSlave *sl)
 Process a message of type kPROOF_SUBMERGER.
 
void Interrupt (EUrgent type, ESlaves list=kActive)
 Send interrupt to master or slave servers.
 
void InterruptCurrentMonitor ()
 If in active in a monitor set ready state.
 
Bool_t IsEndMaster () const
 
Bool_t IsSync () const
 
Int_t LoadPackage (const char *package, Bool_t notOnClient=kFALSE, TList *loadopts=0, TList *workers=0)
 Load specified package.
 
void MarkBad (TSlave *wrk, const char *reason=0)
 Add a bad slave server to the bad slave list and remove it from the active list and from the two monitor objects.
 
void MarkBad (TSocket *s, const char *reason=0)
 Add slave with socket s to the bad slave list and remove if from the active list and from the two monitor objects.
 
Int_t ModifyWorkerLists (const char *ord, Bool_t add, Bool_t save)
 Modify the worker active/inactive list by making the worker identified by the ordinal number 'ord' active (add == TRUE) or inactive (add == FALSE).
 
void NotifyLogMsg (const char *msg, const char *sfx="\n")
 Notify locally 'msg' to the appropriate units (file, stdout, window) If defined, 'sfx' is added after 'msg' (typically a line-feed);.
 
void operator= (const TProof &)
 
void ParseConfigField (const char *config)
 The config file field may contain special instructions which need to be parsed at the beginning, e.g.
 
Int_t Ping (ESlaves list)
 Ping PROOF slaves. Returns the number of slaves that responded.
 
void PrintProgress (Long64_t total, Long64_t processed, Float_t procTime=-1., Long64_t bytesread=-1)
 Print a progress bar on stderr. Used in batch mode.
 
Bool_t Prompt (const char *p)
 Prompt the question 'p' requiring an answer y,Y,n,N Return kTRUE is the answer was y or Y, kFALSE in all other cases.
 
void RecvLogFile (TSocket *s, Int_t size)
 Receive the log file of the slave with socket s.
 
void RedirectWorker (TSocket *s, TSlave *sl, Int_t output_size)
 Redirect output of worker sl to some merger.
 
void ReleaseMonitor (TMonitor *mon)
 Release the used monitor to be used, making sure to delete newly created monitors.
 
void ResetMergePrg ()
 Reset the merge progress notificator.
 
void ResetMergers ()
 
Int_t RestoreActiveList ()
 Restore saved list of active workers.
 
void SaveActiveList ()
 Save current list of active workers.
 
Int_t SendCommand (const char *cmd, ESlaves list=kActive)
 Send command to be executed on the PROOF master and/or slaves.
 
Int_t SendCurrentState (ESlaves list=kActive)
 Transfer the current state of the master to the active slave servers.
 
Int_t SendCurrentState (TList *list)
 Transfer the current state of the master to the active slave servers.
 
Int_t SendGroupView ()
 Send to all active slaves servers the current slave group size and their unique id.
 
Int_t SendInitialState ()
 Transfer the initial (i.e.
 
Int_t SendObject (const TObject *obj, ESlaves list=kActive)
 Send object to master or slave servers.
 
Int_t SendPrint (Option_t *option="")
 Send print command to master server.
 
void SetMonitor (TMonitor *mon=0, Bool_t on=kTRUE)
 Activate (on == TRUE) or deactivate (on == FALSE) all sockets monitored by 'mon'.
 
Int_t SetParallelSilent (Int_t nodes, Bool_t random=kFALSE)
 Tell PROOF how many slaves to use in parallel.
 
void SetRunStatus (ERunStatus rst)
 
void TerminateWorker (const char *ord)
 Ask an active worker 'ord' to terminate, i.e. to shutdown.
 
void TerminateWorker (TSlave *wrk)
 Ask an active worker 'wrk' to terminate, i.e. to shutdown.
 
Int_t UnloadPackage (const char *package)
 Unload specified package.
 
Int_t UnloadPackages ()
 Unload all packages.
 

Static Private Member Functions

static TListGetDataSetSrvMaps (const TString &srvmaps)
 

Private Attributes

TMonitorfActiveMonitor
 
TListfActiveSlaves
 
TString fActiveSlavesSaved
 
TMonitorfAllUniqueMonitor
 
TListfAllUniqueSlaves
 
Long64_t fBytesRead
 
TListfChains
 
Int_t fCheckFileStatus
 
std::recursive_mutex fCloseMutex
 
Float_t fCpuTime
 
TMonitorfCurrentMonitor
 
Int_t fDrawQueries
 
TDSetfDSet
 
TListfEnabledPackagesOnCluster
 
Bool_t fEndMaster
 
TListfFeedback
 
FileMap_t fFileMap
 
Bool_t fFinalizationRunning
 
TString fGroup
 
TListfInactiveSlaves
 
TListfInputData
 
TString fInputDataFile
 
TSignalHandlerfIntHandler
 
Bool_t fIsPollingWorkers
 
Bool_t fIsWaiting
 
Int_t fLastAssignedMerger
 
Long64_t fLastPollWorkers_s
 
TListfLoadedMacros
 
TString fLogFileName
 
FILE * fLogFileR
 
FILE * fLogFileW
 
Int_t fLogLevel
 
Bool_t fLogToWindowOnly
 
TMacro fMacroLog
 
TString fMaster
 
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
 
PrintProgress_t fPrintProgress
 
TPluginHandlerfProgressDialog
 
Bool_t fProgressDialogStarted
 
TListfQueries
 
Float_t fRealTime
 
TListfRecvMessages
 
Int_t fRedirectNext
 
Bool_t fRedirLog
 
ERunStatus fRunStatus
 
Bool_t fSaveLogToMacro
 
Bool_t fSendGroupView
 list returned by kPROOF_GETSLAVEINFO
 
Int_t fSeqNum
 
Int_t fSessionID
 
TListfSlaveInfo
 
Int_t fStatus
 
Bool_t fSync
 
Bool_t fTty
 
TMonitorfUniqueMonitor
 
TListfUniqueSlaves
 
Bool_t fValid
 
TListfWaitingSlaves
 
TString fWorkDir
 
Int_t fWorkersToMerge
 
TListfWrksOutputReady
 

Static Private Attributes

static TPluginHandlerfgLogViewer = 0
 
static TListfgProofEnvList = 0
 

Friends

class TDataSetManager
 
class TPacketizer
 
class TPacketizerAdaptive
 
class TPacketizerDev
 
class TProofInputHandler
 
class TProofInterruptHandler
 
class TProofLite
 
class TProofPlayer
 
class TProofPlayerLite
 
class TProofPlayerRemote
 
class TProofProgressDialog
 
class TProofServ
 
class TSlave
 
class TSlaveLite
 
class TVirtualPacketizer
 
class TXProofMgr
 
class TXProofServ
 
class TXSlave
 
class TXSocket
 
class TXSocketHandler
 

Additional Inherited Members

- Static Protected Attributes inherited from TQObject
static Bool_t fgAllSignalsBlocked = kFALSE
 flag used for suppression of signals
 

#include <TProof.h>

Inheritance diagram for TProof:
[legend]

Member Typedef Documentation

◆ FileMap_t

typedef std::map<TString, MD5Mod_t> TProof::FileMap_t
private

Definition at line 501 of file TProof.h.

Member Enumeration Documentation

◆ EBuildPackageOpt

Enumerator
kDontBuildOnClient 
kBuildOnSlavesNoWait 
kBuildAll 
kCollectBuildResults 

Definition at line 453 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 400 of file TProof.h.

◆ EProofClearData

Enumerator
kPurge 
kUnregistered 
kDataset 
kForceClear 

Definition at line 385 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 423 of file TProof.h.

◆ EProofShowQuotaOpt

Enumerator
kPerGroup 
kPerUser 

Definition at line 459 of file TProof.h.

◆ EProofWrkListAction

Enumerator
kActivateWorker 
kDeactivateWorker 

Definition at line 449 of file TProof.h.

◆ EQueryMode

Enumerator
kSync 
kAsync 

Definition at line 349 of file TProof.h.

◆ ERegisterOpt

Enumerator
kFailIfExists 
kOverwriteIfExists 
kMergeIfExists 

Definition at line 361 of file TProof.h.

◆ ERunStatus

Enumerator
kRunning 
kStopped 
kAborted 

Definition at line 370 of file TProof.h.

◆ ESendFileOpt

enum TProof::ESendFileOpt
private
Enumerator
kAscii 
kBinary 
kForce 
kForward 
kCpBin 
kCp 

Definition at line 441 of file TProof.h.

◆ ESlaves

enum TProof::ESlaves
protected
Enumerator
kAll 
kActive 
kUnique 
kAllUnique 

Definition at line 564 of file TProof.h.

◆ EStatusBits

Enumerator
kUsingSessionGui 
kNewInputData 
kIsClient 
kIsMaster 
kIsTopMaster 
kUseProgressDialog 

Definition at line 341 of file TProof.h.

◆ ESubMerger

Enumerator
kOutputSize 
kSendOutput 
kBeMerger 
kMergerDown 
kStopMerging 
kOutputSent 

Definition at line 376 of file TProof.h.

◆ EUploadOpt

Enumerator
kAppend 
kOverwriteDataSet 
kNoOverwriteDataSet 
kOverwriteAllFiles 
kOverwriteNoFiles 
kAskUser 

Definition at line 353 of file TProof.h.

◆ EUploadPackageOpt

Enumerator
kUntar 
kRemoveOld 

Definition at line 366 of file TProof.h.

◆ EUrgent

enum TProof::EUrgent
private
Enumerator
kLocalInterrupt 
kPing 
kHardInterrupt 
kSoftInterrupt 
kShutdownInterrupt 

Definition at line 393 of file TProof.h.

Constructor & Destructor Documentation

◆ TProof() [1/3]

TProof::TProof ( const TProof )
private

◆ TProof() [2/3]

TProof::TProof ( )
protected

Protected constructor to be used by classes deriving from TProof (they have to call Init themselves and override StartSlaves appropriately).

This constructor simply closes any previous gProof and sets gProof to this instance.

Definition at line 507 of file TProof.cxx.

◆ TProof() [3/3]

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 
)

Create a PROOF environment.

Starting PROOF involves either connecting to a master server, which in turn will start a set of slave servers, or directly starting as master server (if master = ""). Masterurl is of the form: [proof[s]://]host[:port]. Conffile is the name of the config file describing the remote PROOF cluster (this argument alows you to describe different cluster configurations). The default is proof.conf. Confdir is the directory where the config file and other PROOF related files are (like motd and noproof files). Loglevel is the log level (default = 1). User specified custom config files will be first looked for in $HOME/.conffile.

Definition at line 381 of file TProof.cxx.

◆ ~TProof()

TProof::~TProof ( )
virtual

Clean up PROOF environment.

Definition at line 646 of file TProof.cxx.

Member Function Documentation

◆ Activate()

void TProof::Activate ( TList slaves = 0)
private

Activate slave server list.

Definition at line 2379 of file TProof.cxx.

◆ ActivateAsyncInput()

void TProof::ActivateAsyncInput ( )
private

Activate the a-sync input handler.

Definition at line 4400 of file TProof.cxx.

◆ ActivateWorker()

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

Make sure that the worker identified by the ordinal number 'ord' is in the active list.

The request will be forwarded to the master in direct contact with the worker. If needed, this master will move the worker from the inactive to the active list and rebuild the list of unique workers. Use ord = "*" to activate all inactive workers. The string 'ord' can also be a comma-separated list of ordinal numbers the status of which will be modified at once. Return <0 if something went wrong (-2 if at least one worker was not found) or the number of workers with status change (on master; 0 on client).

Definition at line 11343 of file TProof.cxx.

◆ AddChain()

void TProof::AddChain ( TChain chain)

Add chain to data set.

Definition at line 10213 of file TProof.cxx.

◆ AddDynamicPath()

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

Add 'libpath' to the lib path search.

Multiple paths can be specified at once separating them with a comma or a blank. Return 0 on success, -1 otherwise

Definition at line 8833 of file TProof.cxx.

◆ AddEnvVar()

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

Add an variable to the list of environment variables passed to proofserv on the master and slaves.

Definition at line 11750 of file TProof.cxx.

◆ AddFeedback()

void TProof::AddFeedback ( const char *  name)

Add object to feedback list.

Definition at line 9979 of file TProof.cxx.

◆ AddIncludePath()

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

Add 'incpath' to the inc path search.

Multiple paths can be specified at once separating them with a comma or a blank. Return 0 on success, -1 otherwise

Definition at line 8878 of file TProof.cxx.

◆ AddInput()

void TProof::AddInput ( TObject obj)

Add objects that might be needed during the processing of the selector (see Process()).

Definition at line 9724 of file TProof.cxx.

◆ AddInputData()

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

Add data objects that might be needed during the processing of the selector (see Process()).

This object can be very large, so they are distributed in an optimized way using a dedicated file. If push is TRUE the input data are sent over even if no apparent change occured to the list.

Definition at line 9512 of file TProof.cxx.

◆ AddWorkers()

Int_t TProof::AddWorkers ( TList workerList)
protected

Works on the master node only.

It starts workers on the machines in workerList and sets the paths, packages and macros as on the master. It is a subbstitute for StartSlaves(...) The code is mostly the master part of StartSlaves, with the parallel startup removed.

Definition at line 1310 of file TProof.cxx.

◆ Archive() [1/2]

Int_t TProof::Archive ( const char *  ref,
const char *  path = 0 
)

Send archive request for the query specified by ref.

Generic method working for all queries known by the server. If ref == "Default", path is understood as a default path for archiving.

Definition at line 6067 of file TProof.cxx.

◆ Archive() [2/2]

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

Send archive request for the qry-th query in fQueries.

Definition at line 6047 of file TProof.cxx.

◆ AskForOutput()

void TProof::AskForOutput ( TSlave sl)
private

Master asks for output from worker sl.

Definition at line 4324 of file TProof.cxx.

◆ AskParallel()

void TProof::AskParallel ( )
private

Ask the for the number of parallel slaves.

Definition at line 2067 of file TProof.cxx.

◆ AskStatistics()

void TProof::AskStatistics ( )
private

Ask the for the statistics of the slaves.

Definition at line 2012 of file TProof.cxx.

◆ AssertDataSet()

Int_t TProof::AssertDataSet ( TDSet dset,
TList input,
TDataSetManager mgr,
TString emsg 
)
staticprotected

Make sure that dataset is in the form to be processed.

This may mean retrieving the relevant info from the dataset manager or from the attached input list. Returns 0 on success, -1 on error

Definition at line 12004 of file TProof.cxx.

◆ AssertMacroPath()

void TProof::AssertMacroPath ( const char *  macro)
staticprotected

Make sure that the directory path contained by macro is in the macro path.

Definition at line 8589 of file TProof.cxx.

◆ AssertPath()

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

Make sure that 'path' exists; if 'writable' is kTRUE, make also sure that the path is writable.

Definition at line 1259 of file TProof.cxx.

◆ Broadcast() [1/6]

Int_t TProof::Broadcast ( const char *  str,
Int_t  kind,
TList slaves 
)
private

Broadcast a character string buffer to all slaves in the specified list.

Use kind to set the TMessage what field. Returns the number of slaves the message was sent to. Returns -1 in case of error.

Definition at line 2508 of file TProof.cxx.

◆ Broadcast() [2/6]

Int_t TProof::Broadcast ( const char *  str,
Int_t  kind = kMESS_STRING,
ESlaves  list = kActive 
)
private

Broadcast a character string buffer to all slaves in the specified list (either all slaves or only the active slaves).

Use kind to set the TMessage what field. Returns the number of slaves the message was sent to. Returns -1 in case of error.

Definition at line 2521 of file TProof.cxx.

◆ Broadcast() [3/6]

Int_t TProof::Broadcast ( const TMessage mess,
ESlaves  list = kActive 
)
private

Broadcast a message to all slaves in the specified list (either all slaves or only the active slaves).

Returns the number of slaves the message was successfully sent to. Returns -1 in case of error.

Definition at line 2492 of file TProof.cxx.

◆ Broadcast() [4/6]

Int_t TProof::Broadcast ( const TMessage mess,
TList slaves 
)
private

Broadcast a message to all slaves in the specified list.

Returns the number of slaves the message was successfully sent to. Returns -1 in case of error.

Definition at line 2465 of file TProof.cxx.

◆ Broadcast() [5/6]

Int_t TProof::Broadcast ( Int_t  kind,
ESlaves  list = kActive 
)
inlineprivate

Definition at line 634 of file TProof.h.

◆ Broadcast() [6/6]

Int_t TProof::Broadcast ( Int_t  kind,
TList slaves 
)
inlineprivate

Definition at line 633 of file TProof.h.

◆ BroadcastFile() [1/2]

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

Broadcast file to all workers in the specified list.

Returns the number of workers the buffer was sent to. Returns -1 in case of error.

Definition at line 2600 of file TProof.cxx.

◆ BroadcastFile() [2/2]

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

Broadcast file to all workers in the specified list.

Returns the number of workers the buffer was sent to. Returns -1 in case of error.

Definition at line 2629 of file TProof.cxx.

◆ BroadcastGroupPriority() [1/2]

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

Broadcast the group priority to all workers in the specified list.

Returns the number of workers the message was successfully sent to. Returns -1 in case of error.

Definition at line 2441 of file TProof.cxx.

◆ BroadcastGroupPriority() [2/2]

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

Broadcast the group priority to all workers in the specified list.

Returns the number of workers the message was successfully sent to. Returns -1 in case of error.

Definition at line 2414 of file TProof.cxx.

◆ BroadcastObject() [1/2]

Int_t TProof::BroadcastObject ( const TObject obj,
Int_t  kind,
TList slaves 
)
private

Broadcast an object to all slaves in the specified list.

Use kind to set the TMEssage what field. Returns the number of slaves the message was sent to. Returns -1 in case of error.

Definition at line 2533 of file TProof.cxx.

◆ BroadcastObject() [2/2]

Int_t TProof::BroadcastObject ( const TObject obj,
Int_t  kind = kMESS_OBJECT,
ESlaves  list = kActive 
)
private

Broadcast an object to all slaves in the specified list.

Use kind to set the TMEssage what field. Returns the number of slaves the message was sent to. Returns -1 in case of error.

Definition at line 2545 of file TProof.cxx.

◆ BroadcastRaw() [1/2]

Int_t TProof::BroadcastRaw ( const void buffer,
Int_t  length,
ESlaves  list = kActive 
)
private

Broadcast a raw buffer of specified length to all slaves in the specified list.

Returns the number of slaves the buffer was sent to. Returns -1 in case of error.

Definition at line 2584 of file TProof.cxx.

◆ BroadcastRaw() [2/2]

Int_t TProof::BroadcastRaw ( const void buffer,
Int_t  length,
TList slaves 
)
private

Broadcast a raw buffer of specified length to all slaves in the specified list.

Returns the number of slaves the buffer was sent to. Returns -1 in case of error.

Definition at line 2557 of file TProof.cxx.

◆ Browse()

void TProof::Browse ( TBrowser b)
virtual

Build the PROOF's structure in the browser.

Reimplemented from TObject.

Definition at line 10169 of file TProof.cxx.

◆ BuildPackage()

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

Build specified package.

Executes the PROOF-INF/BUILD.sh script if it exists on all unique nodes. If opt is kBuildOnSlavesNoWait then submit build command to slaves, but don't wait for results. If opt is kCollectBuildResults then collect result from slaves. To be used on the master. If opt = kBuildAll (default) then submit and wait for results (to be used on the client). Returns 0 in case of success and -1 in case of error.

Definition at line 7980 of file TProof.cxx.

◆ CancelStagingDataSet()

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

Cancels a dataset staging request.

Returns kTRUE on success, kFALSE on failure. Dataset not found equals to a failure.

Reimplemented in TProofLite.

Definition at line 11036 of file TProof.cxx.

◆ cd()

void TProof::cd ( Int_t  id = -1)

Set session with 'id' the default one.

If 'id' is not found in the list, the current session is set as default

Definition at line 10486 of file TProof.cxx.

◆ CheckFile()

Bool_t TProof::CheckFile ( const char *  file,
TSlave slave,
Long_t  modtime,
Int_t  cpopt = (kCp | kCpBin) 
)
private

Check if a file needs to be send to the slave.

Use the following algorithm:

  • check if file appears in file map
    • if yes, get file's modtime and check against time in map, if modtime not same get md5 and compare against md5 in map, if not same return kTRUE.
    • if no, get file's md5 and modtime and store in file map, ask slave if file exists with specific md5, if yes return kFALSE, if no return kTRUE. The options 'cpopt' define if to copy things from cache to sandbox and what. To retrieve from the cache the binaries associated with the file TProof::kCpBin must be set in cpopt; the default is copy everything. Returns kTRUE in case file needs to be send, returns kFALSE in case file is already on remote node.

Definition at line 6789 of file TProof.cxx.

◆ CleanGDirectory()

void TProof::CleanGDirectory ( TList ol)
private

Remove links to objects in list 'ol' from gDirectory.

Definition at line 3036 of file TProof.cxx.

◆ CleanupSession()

Int_t TProof::CleanupSession ( const char *  sessiontag)

Send cleanup request for the session specified by tag.

Definition at line 6082 of file TProof.cxx.

◆ ClearCache()

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

Remove file from all file caches.

If file is 0 or "" or "*", remove all the files

Reimplemented in TProofLite.

Definition at line 7704 of file TProof.cxx.

◆ ClearData()

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

Remove files for the data directory.

The option 'what' can take the values: kPurge remove all files and directories under '~/data' kUnregistered remove only files not in registered datasets (default) kDataset remove files belonging to dataset 'dsname' User is prompt for confirmation, unless kForceClear is ORed with the option

Definition at line 7402 of file TProof.cxx.

◆ ClearDataProgress()

void TProof::ClearDataProgress ( Int_t  r,
Int_t  t 
)
private

Progress bar for clear data.

Definition at line 7660 of file TProof.cxx.

◆ ClearDataSetCache()

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

Clear the content of the dataset cache, if any (matching 'dataset', if defined).

Reimplemented in TProofLite.

Definition at line 10886 of file TProof.cxx.

◆ ClearFeedback()

void TProof::ClearFeedback ( )

Clear feedback list.

Definition at line 10002 of file TProof.cxx.

◆ ClearInput()

void TProof::ClearInput ( )

Clear input object list.

Definition at line 9732 of file TProof.cxx.

◆ ClearInputData() [1/2]

void TProof::ClearInputData ( const char *  name)

Remove obj 'name' form the input data list;.

Definition at line 9562 of file TProof.cxx.

◆ ClearInputData() [2/2]

void TProof::ClearInputData ( TObject obj = 0)

Remove obj form the input data list; if obj is null (default), clear the input data info.

Definition at line 9528 of file TProof.cxx.

◆ ClearPackage()

Int_t TProof::ClearPackage ( const char *  package)

Remove a specific package.

Returns 0 in case of success and -1 in case of error.

Definition at line 7847 of file TProof.cxx.

◆ ClearPackages()

Int_t TProof::ClearPackages ( )

Remove all packages.

Returns 0 in case of success and -1 in case of error.

Definition at line 7830 of file TProof.cxx.

◆ Close()

void TProof::Close ( Option_t opt = "")

Close all open slave servers.

Client can decide to shutdown the remote session by passing option is 'S' or 's'. Default for clients is detach, if supported. Masters always shutdown the remote counterpart.

Definition at line 1788 of file TProof.cxx.

◆ CloseProgressDialog()

void TProof::CloseProgressDialog ( )

Close progress dialog.

Definition at line 9273 of file TProof.cxx.

◆ Collect() [1/4]

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

Collect responses from slave sl.

Returns the number of slaves that responded (=1). If timeout >= 0, wait at most timeout seconds (timeout = -1 by default, which means wait forever). If defined (>= 0) endtype is the message that stops this collection.

Definition at line 2659 of file TProof.cxx.

◆ Collect() [2/4]

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

Collect responses from the slave servers.

Returns the number of slaves that responded. If timeout >= 0, wait at most timeout seconds (timeout = -1 by default, which means wait forever). If defined (>= 0) endtype is the message that stops this collection.

Definition at line 2717 of file TProof.cxx.

◆ Collect() [3/4]

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

Collect responses from the slave servers.

Returns the number of slaves that responded. If timeout >= 0, wait at most timeout seconds (timeout = -1 by default, which means wait forever). If defined (>= 0) endtype is the message that stops this collection.

Definition at line 2686 of file TProof.cxx.

◆ Collect() [4/4]

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

Collect responses from the slave servers.

Returns the number of messages received. Can be 0 if there are no active slaves. If timeout >= 0, wait at most timeout seconds (timeout = -1 by default, which means wait forever). If defined (>= 0) endtype is the message that stops this collection. Collect also stops its execution from time to time to check for new workers in Dynamic Startup mode.

Definition at line 2746 of file TProof.cxx.

◆ CollectInputFrom()

Int_t TProof::CollectInputFrom ( TSocket s,
Int_t  endtype = -1,
Bool_t  deactonfail = kFALSE 
)
private

Collect and analyze available input from socket s.

Returns 0 on success, -1 if any failure occurs.

Definition at line 3050 of file TProof.cxx.

◆ CreateDrawFeedback()

TDrawFeedback * TProof::CreateDrawFeedback ( )

Draw feedback creation proxy.

When accessed via TProof avoids link dependency on libProofPlayer.

Definition at line 10084 of file TProof.cxx.

◆ CreateMerger()

Bool_t TProof::CreateMerger ( TSlave sl,
Int_t  port 
)
private

Create a new merger.

Definition at line 4444 of file TProof.cxx.

◆ CreateSlave()

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

Create a new TSlave of type TSlave::kSlave.

Note: creation of TSlave is private with TProof as a friend. Derived classes must use this function to create slaves.

Definition at line 1843 of file TProof.cxx.

◆ CreateSubmaster()

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

Create a new TSlave of type TSlave::kMaster.

Note: creation of TSlave is private with TProof as a friend. Derived classes must use this function to create slaves.

Definition at line 1865 of file TProof.cxx.

◆ DataSetStatus()

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

Send dataset preparation status.

Definition at line 9314 of file TProof.cxx.

◆ DeActivateAsyncInput()

void TProof::DeActivateAsyncInput ( )
private

De-activate a-sync input handler.

Definition at line 4413 of file TProof.cxx.

◆ DeactivateWorker()

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

Remove the worker identified by the ordinal number 'ord' from the the active list.

The request will be forwarded to the master in direct contact with the worker. If needed, this master will move the worker from the active to the inactive list and rebuild the list of unique workers. Use ord = "*" to deactivate all active workers. The string 'ord' can also be a comma-separated list of ordinal numbers the status of which will be modified at once. Return <0 if something went wrong (-2 if at least one worker was not found) or the number of workers with status change (on master; 0 on client).

Definition at line 11360 of file TProof.cxx.

◆ DelEnvVar()

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

Remove an variable from the list of environment variables passed to proofserv on the master and slaves.

Definition at line 11772 of file TProof.cxx.

◆ DeleteDrawFeedback()

void TProof::DeleteDrawFeedback ( TDrawFeedback f)

Delete draw feedback object.

Definition at line 10100 of file TProof.cxx.

◆ DeleteParameters()

void TProof::DeleteParameters ( const char *  wildcard)

Delete the input list parameters specified by a wildcard (e.g.

PROOF_*) or exact name (e.g. PROOF_MaxSlavesPerNode).

Definition at line 9923 of file TProof.cxx.

◆ Detach()

void TProof::Detach ( Option_t opt = "")

Detach this instance to its proofserv.

If opt is 'S' or 's' the remote server is shutdown

Definition at line 10508 of file TProof.cxx.

◆ DisableGoAsyn()

void TProof::DisableGoAsyn ( )

Signal to disable related switches.

Definition at line 6249 of file TProof.cxx.

◆ DisablePackage()

Int_t TProof::DisablePackage ( const char *  pack)
private

Remove a specific package.

Returns 0 in case of success and -1 in case of error.

Definition at line 7875 of file TProof.cxx.

◆ DisablePackages()

Int_t TProof::DisablePackages ( )
private

Remove all packages.

Returns 0 in case of success and -1 in case of error.

Definition at line 7932 of file TProof.cxx.

◆ DownloadPackage()

Int_t TProof::DownloadPackage ( const char *  pack,
const char *  dstdir = 0 
)

Download a PROOF archive (PAR file) from the master package repository.

The PAR file is downloaded in the current directory or in the directory specified by 'dstdir'. If a package with the same name already exists at destination, a check on the MD5 sum is done and the user warned or prompted for action, depending is the file is equal or different. Returns 0 in case of success and -1 in case of error.

Definition at line 8324 of file TProof.cxx.

◆ DrawSelect() [1/2]

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

Execute the specified drawing action on a data set which is stored on the master with name 'dsetname'.

The syntax for dsetname is name[#[dir/]objname], e.g. "mydset" analysis of the first tree in the top dir of the dataset named "mydset" "mydset#T" analysis tree "T" in the top dir of the dataset named "mydset" "mydset#adir/T" analysis tree "T" in the dir "adir" of the dataset named "mydset" "mydset#adir/" analysis of the first tree in the dir "adir" of the dataset named "mydset" The last argument 'enl' specifies an entry- or event-list to be used as event selection. The return value is -1 in case of error and TSelector::GetStatus() in in case of success.

Definition at line 6172 of file TProof.cxx.

◆ DrawSelect() [2/2]

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

Execute the specified drawing action on a data set (TDSet).

Event- or Entry-lists should be set in the data set object using TDSet::SetEntryList. Returns -1 in case of error or number of selected events otherwise.

Reimplemented in TProofLite.

Definition at line 6136 of file TProof.cxx.

◆ Echo() [1/2]

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

Sends a string to master and workers and expect them to echo it back to the client via a message.

It is a special case of the generic Echo() that works with TObjects. Returns -1 on error, the number of workers that received the message on success.

Definition at line 7032 of file TProof.cxx.

◆ Echo() [2/2]

Int_t TProof::Echo ( const TObject obj)
virtual

Sends an object to master and workers and expect them to send back a message with the output of its TObject::Print().

Returns -1 on error, the number of workers that received the objects on success.

Definition at line 7018 of file TProof.cxx.

◆ EnablePackage() [1/3]

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

Enable specified package.

Executes the PROOF-INF/BUILD.sh script if it exists followed by the PROOF-INF/SETUP.C script. In case notOnClient = true, don't enable the package on the client. The default is to enable packages also on the client. If specified, enables packages only on the specified workers. Returns 0 in case of success and -1 in case of error. Provided for backward compatibility.

Definition at line 8165 of file TProof.cxx.

◆ EnablePackage() [2/3]

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

Enable specified package.

Executes the PROOF-INF/BUILD.sh script if it exists followed by the PROOF-INF/SETUP.C script. In case notOnClient = true, don't enable the package on the client. The default is to enable packages also on the client. It is is possible to specify options for the loading step via 'loadopts'; the string will be passed passed as argument to SETUP. Special option 'chkv=<o>' (or 'checkversion=<o>') can be used to control plugin version checking during building: possible choices are: off no check; failure may occur at loading on check ROOT version [default] svn check ROOT version and Git commit SHA1. (Use ';', ' ' or '|' to separate 'chkv=<o>' from the rest.) If specified, enables packages only on the specified workers. Returns 0 in case of success and -1 in case of error.

Definition at line 8187 of file TProof.cxx.

◆ EnablePackage() [3/3]

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

Enable specified package.

Executes the PROOF-INF/BUILD.sh script if it exists followed by the PROOF-INF/SETUP.C script. In case notOnClient = true, don't enable the package on the client. The default is to enable packages also on the client. It is is possible to specify a list of objects to be passed to the SETUP functions via 'loadopts'; the objects must be streamable. Returns 0 in case of success and -1 in case of error.

Definition at line 8248 of file TProof.cxx.

◆ Exec() [1/3]

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

Send command to be executed on the PROOF master and/or slaves.

If plusMaster is kTRUE then exeucte on slaves and master too. Command can be any legal command line command. Commands like ".x file.C" or ".L file.C" will cause the file file.C to be send to the PROOF cluster. Returns -1 in case of error, >=0 in case of succes.

Definition at line 6511 of file TProof.cxx.

◆ Exec() [2/3]

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

Send command to be executed on node of ordinal 'ord' (use "0" for master).

Command can be any legal command line command. Commands like ".x file.C" or ".L file.C" will cause the file file.C to be send to the PROOF cluster. If logtomacro is TRUE the text result of the action is saved in the fMacroLog TMacro, accessible via TMacro::GetMacroLog(); Returns -1 in case of error, >=0 in case of succes.

Definition at line 6579 of file TProof.cxx.

◆ Exec() [3/3]

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

Send command to be executed on the PROOF master and/or slaves.

Command can be any legal command line command. Commands like ".x file.C" or ".L file.C" will cause the file file.C to be send to the PROOF cluster. Returns -1 in case of error, >=0 in case of succes.

Definition at line 6523 of file TProof.cxx.

◆ ExistsDataSet()

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

Returns kTRUE if 'dataset' exists, kFALSE otherwise.

Reimplemented in TProofLite.

Definition at line 10858 of file TProof.cxx.

◆ Feedback()

void TProof::Feedback ( TList objs)

Get list of feedback objects.

Connect a slot to this signal to monitor the feedback object.

Definition at line 9258 of file TProof.cxx.

◆ FinalizationDone()

void TProof::FinalizationDone ( )
inlineprivate

Definition at line 694 of file TProof.h.

◆ Finalize() [1/2]

Long64_t TProof::Finalize ( const char *  ref,
Bool_t  force = kFALSE 
)

Finalize query with reference ref.

If force, force retrieval if the query is found in the local list but has already been finalized (default kFALSE). If ref = 0, finalize current query. Return 0 on success, -1 on error

Definition at line 5898 of file TProof.cxx.

◆ Finalize() [2/2]

Long64_t TProof::Finalize ( Int_t  qry = -1,
Bool_t  force = kFALSE 
)

Finalize the qry-th query in fQueries.

If force, force retrieval if the query is found in the local list but has already been finalized (default kFALSE). If query < 0, finalize current query. Return 0 on success, -1 on error

Definition at line 5873 of file TProof.cxx.

◆ FindDataSets()

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

Find datasets, returns in a TList all found datasets.

Definition at line 11000 of file TProof.cxx.

◆ FindNextFreeMerger()

Int_t TProof::FindNextFreeMerger ( )
private

Return a merger, which is both active and still accepts some workers to be assigned to it.

It works on the 'round-robin' basis.

Definition at line 4294 of file TProof.cxx.

◆ FindSlave()

TSlave * TProof::FindSlave ( TSocket s) const
private

Find slave that has TSocket s. Returns 0 in case slave is not found.

Definition at line 1881 of file TProof.cxx.

◆ FindUniqueSlaves()

void TProof::FindUniqueSlaves ( )
privatevirtual

Add to the fUniqueSlave list the active slaves that have a unique (user) file system image.

This information is used to transfer files only once to nodes that share a file system (an image). Submasters which are not in fUniqueSlaves are put in the fNonUniqueMasters list. That list is used to trigger the transferring of files to the submaster's unique slaves without the need to transfer the file to the submaster.

Reimplemented in TProofLite.

Definition at line 1902 of file TProof.cxx.

◆ GetActiveMergersCount()

Int_t TProof::GetActiveMergersCount ( )
private

Get the active mergers count.

Definition at line 4426 of file TProof.cxx.

◆ GetBytesRead()

Long64_t TProof::GetBytesRead ( ) const
inline

Definition at line 929 of file TProof.h.

◆ GetClientProtocol()

Int_t TProof::GetClientProtocol ( ) const
inline

Definition at line 914 of file TProof.h.

◆ GetConfDir()

const char * TProof::GetConfDir ( ) const
inline

Definition at line 904 of file TProof.h.

◆ GetConfFile()

const char * TProof::GetConfFile ( ) const
inline

Definition at line 905 of file TProof.h.

◆ GetCpuTime()

Float_t TProof::GetCpuTime ( ) const
inline

Definition at line 931 of file TProof.h.

◆ GetDataPoolUrl()

const char * TProof::GetDataPoolUrl ( ) const
inline

Definition at line 1043 of file TProof.h.

◆ GetDataSet()

TFileCollection * TProof::GetDataSet ( const char *  uri,
const char *  optStr = "" 
)
virtual

Get a list of TFileInfo objects describing the files of the specified dataset.

To get the short version (containing only the global meta information) specify optStr = "S:" or optStr = "short:". To get the sub-dataset of files located on a given server(s) specify the list of servers (comma-separated) in the 'optStr' field.

Reimplemented in TProofLite.

Definition at line 10927 of file TProof.cxx.

◆ GetDataSetQuota()

TMap * TProof::GetDataSetQuota ( const char *  optStr = "")

returns a map of the quotas of all groups

Definition at line 11266 of file TProof.cxx.

◆ GetDataSets()

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

Lists all datasets that match given uri.

The 'optStr' can contain a comma-separated list of servers for which the information is wanted. If ':lite:' (case insensitive) is specified in 'optStr' only the global information in the TFileCollection is retrieved; useful to only get the list of available datasets.

Reimplemented in TProofLite.

Definition at line 10799 of file TProof.cxx.

◆ GetDataSetSrvMaps()

static TList * TProof::GetDataSetSrvMaps ( const TString srvmaps)
staticprivate

◆ GetEnabledPackages()

TList * TProof::GetEnabledPackages ( ) const
inlineprotected

Definition at line 735 of file TProof.h.

◆ Getenv()

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

Get value of environment variable 'env' on node 'ord'.

Definition at line 6634 of file TProof.cxx.

◆ GetEnvVars()

const TList * TProof::GetEnvVars ( )
static

Get environemnt variables.

Definition at line 11741 of file TProof.cxx.

◆ GetFeedbackList()

TList * TProof::GetFeedbackList ( ) const

Return feedback list.

Definition at line 10023 of file TProof.cxx.

◆ GetFileInCmd()

Bool_t TProof::GetFileInCmd ( const char *  cmd,
TString fn 
)
staticprotected

Static method to extract the filename (if any) form a CINT command.

Returns kTRUE and the filename in 'fn'; returns kFALSE if not found or not appliable.

Definition at line 6485 of file TProof.cxx.

◆ GetGroup()

const char * TProof::GetGroup ( ) const
inline

Definition at line 907 of file TProof.h.

◆ GetImage()

const char * TProof::GetImage ( ) const
inline

Definition at line 910 of file TProof.h.

◆ GetInputData()

Int_t TProof::GetInputData ( TList input,
const char *  cachedir,
TString emsg 
)
staticprotected

Get the input data from the file defined in the input list.

Definition at line 12403 of file TProof.cxx.

◆ GetInputList()

TList * TProof::GetInputList ( )

Get input list.

Definition at line 9743 of file TProof.cxx.

◆ GetLastLog()

TMacro * TProof::GetLastLog ( )

Fill a TMacro with the log lines since the last reading (fLogFileR) Return (TMacro *)0 if no line was logged.

The returned TMacro must be deleted by the caller.

Definition at line 10247 of file TProof.cxx.

◆ GetListOfActiveSlaves()

TList * TProof::GetListOfActiveSlaves ( ) const
inlineprotected

Definition at line 723 of file TProof.h.

◆ GetListOfBadSlaves()

TList * TProof::GetListOfBadSlaves ( ) const
inlineprivate

Definition at line 657 of file TProof.h.

◆ GetListOfEnabledPackages()

TList * TProof::GetListOfEnabledPackages ( )

Get from the master the list of names of the packages enabled.

Definition at line 9114 of file TProof.cxx.

◆ GetListOfInactiveSlaves()

TList * TProof::GetListOfInactiveSlaves ( ) const
inlineprivate

Definition at line 655 of file TProof.h.

◆ GetListOfPackages()

TList * TProof::GetListOfPackages ( )

Get from the master the list of names of the packages available.

Definition at line 9098 of file TProof.cxx.

◆ GetListOfQueries()

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

Ask the master for the list of queries.

Reimplemented in TProofLite.

Definition at line 2078 of file TProof.cxx.

◆ GetListOfSlaveInfos()

TList * TProof::GetListOfSlaveInfos ( )

Returns list of TSlaveInfo's. In case of error return 0.

Definition at line 2311 of file TProof.cxx.

◆ GetListOfSlaves()

TList * TProof::GetListOfSlaves ( ) const
inlineprivate

Definition at line 654 of file TProof.h.

◆ GetListOfUniqueSlaves()

TList * TProof::GetListOfUniqueSlaves ( ) const
inlineprivate

Definition at line 656 of file TProof.h.

◆ GetLoadedMacros()

TList * TProof::GetLoadedMacros ( ) const
inline

Definition at line 944 of file TProof.h.

◆ GetLog()

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

Ask for remote logs in the range [start, end].

If start == -1 all the messages not yet received are sent back.

Definition at line 10230 of file TProof.cxx.

◆ GetLogLevel()

Int_t TProof::GetLogLevel ( ) const
inline

Definition at line 916 of file TProof.h.

◆ GetMacroLog()

TMacro * TProof::GetMacroLog ( )
inline

Definition at line 1019 of file TProof.h.

◆ GetManager()

TProofMgr * TProof::GetManager ( )
inline

Definition at line 1037 of file TProof.h.

◆ GetMaster()

const char * TProof::GetMaster ( ) const
inline

Definition at line 903 of file TProof.h.

◆ GetMaxQueries()

void TProof::GetMaxQueries ( )

Get max number of queries whose full results are kept in the remote sandbox.

Definition at line 2118 of file TProof.cxx.

◆ GetMissingFiles()

TFileCollection * TProof::GetMissingFiles ( TQueryResult qr = 0)

Get a TFileCollection with the files missing in the query described by 'qr' or the last query if qr is null (default).

Return a null pointer if none were found, for whatever reason. The caller is responsible for the returned object.

Definition at line 12571 of file TProof.cxx.

◆ GetNumberOfActiveSlaves()

Int_t TProof::GetNumberOfActiveSlaves ( ) const
private

Return number of active slaves, i.e.

slaves that are valid and in the current computing group.

Definition at line 1977 of file TProof.cxx.

◆ GetNumberOfBadSlaves()

Int_t TProof::GetNumberOfBadSlaves ( ) const
private

Return number of bad slaves.

This are slaves that we in the config file, but refused to startup or that died during the PROOF session.

Definition at line 2004 of file TProof.cxx.

◆ GetNumberOfDrawQueries()

Int_t TProof::GetNumberOfDrawQueries ( )
inline

Definition at line 979 of file TProof.h.

◆ GetNumberOfInactiveSlaves()

Int_t TProof::GetNumberOfInactiveSlaves ( ) const
private

Return number of inactive slaves, i.e.

slaves that are valid but not in the current computing group.

Definition at line 1986 of file TProof.cxx.

◆ GetNumberOfQueries()

Int_t TProof::GetNumberOfQueries ( )

Number of queries processed by this session.

Definition at line 2095 of file TProof.cxx.

◆ GetNumberOfSlaves()

Int_t TProof::GetNumberOfSlaves ( ) const
private

Return number of slaves as described in the config file.

Definition at line 1968 of file TProof.cxx.

◆ GetNumberOfUniqueSlaves()

Int_t TProof::GetNumberOfUniqueSlaves ( ) const
private

Return number of unique slaves, i.e.

active slaves that have each a unique different user files system.

Definition at line 1995 of file TProof.cxx.

◆ GetOutput() [1/2]

TObject * TProof::GetOutput ( const char *  name)

Get specified object that has been produced during the processing (see Process()).

Definition at line 9752 of file TProof.cxx.

◆ GetOutput() [2/2]

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

Find object 'name' in list 'out' or in the files specified in there.

Definition at line 9766 of file TProof.cxx.

◆ GetOutputList()

TList * TProof::GetOutputList ( )

Get list with all object created during processing (see Process()).

Definition at line 9798 of file TProof.cxx.

◆ GetOutputNames()

TList * TProof::GetOutputNames ( )

FIXME: to be written.

Definition at line 10108 of file TProof.cxx.

◆ GetParallel()

Int_t TProof::GetParallel ( ) const

Returns number of slaves active in parallel mode.

Returns 0 in case there are no active slaves. Returns -1 in case of error.

Definition at line 2294 of file TProof.cxx.

◆ GetParameter() [1/6]

TObject * TProof::GetParameter ( const char *  par) const

Get specified parameter.

A parameter set via SetParameter() is either a TParameter or a TNamed or 0 in case par is not defined.

Definition at line 9908 of file TProof.cxx.

◆ GetParameter() [2/6]

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

Get the value from the specified parameter from the specified collection.

Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.

Definition at line 11985 of file TProof.cxx.

◆ GetParameter() [3/6]

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

Get the value from the specified parameter from the specified collection.

Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.

Definition at line 11931 of file TProof.cxx.

◆ GetParameter() [4/6]

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

Get the value from the specified parameter from the specified collection.

Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.

Definition at line 11967 of file TProof.cxx.

◆ GetParameter() [5/6]

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

Get the value from the specified parameter from the specified collection.

Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.

Definition at line 11949 of file TProof.cxx.

◆ GetParameter() [6/6]

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

Get the value from the specified parameter from the specified collection.

Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.

Definition at line 11912 of file TProof.cxx.

◆ GetPlayer()

TVirtualProofPlayer * TProof::GetPlayer ( ) const
inlineprotected

Definition at line 716 of file TProof.h.

◆ GetPort()

Int_t TProof::GetPort ( ) const
inline

Definition at line 912 of file TProof.h.

◆ GetProgressDialog()

TPluginHandler * TProof::GetProgressDialog ( ) const
inlineprotected

Definition at line 742 of file TProof.h.

◆ GetQueryMode()

TProof::EQueryMode TProof::GetQueryMode ( Option_t mode = 0) const

Find out the query mode based on the current setting and 'mode'.

Definition at line 6109 of file TProof.cxx.

◆ GetQueryReference()

Int_t TProof::GetQueryReference ( Int_t  qry,
TString ref 
)
private

Get reference for the qry-th query in fQueries (as displayed by ShowQueries).

Definition at line 5847 of file TProof.cxx.

◆ GetQueryResult()

TQueryResult * TProof::GetQueryResult ( const char *  ref = 0)

Return pointer to the full TQueryResult instance owned by the player and referenced by 'ref'.

If ref = 0 or "", return the last query result.

Definition at line 2138 of file TProof.cxx.

◆ GetQueryResults()

TList * TProof::GetQueryResults ( )

Return pointer to the list of query results in the player.

Definition at line 2129 of file TProof.cxx.

◆ GetRC() [1/3]

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

Get into 'env' the value of double RC env variable 'rcenv' on node 'ord'.

Definition at line 6681 of file TProof.cxx.

◆ GetRC() [2/3]

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

Get into 'env' the value of integer RC env variable 'rcenv' on node 'ord'.

Definition at line 6655 of file TProof.cxx.

◆ GetRC() [3/3]

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

Get into 'env' the value of string RC env variable 'rcenv' on node 'ord'.

Definition at line 6707 of file TProof.cxx.

◆ GetRealTime()

Float_t TProof::GetRealTime ( ) const
inline

Definition at line 930 of file TProof.h.

◆ GetRemoteProtocol()

Int_t TProof::GetRemoteProtocol ( ) const
inline

Definition at line 913 of file TProof.h.

◆ GetRunStatus()

ERunStatus TProof::GetRunStatus ( ) const
inline

Definition at line 943 of file TProof.h.

◆ GetSandbox()

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

Set the sandbox path from ' Proof.Sandbox' or the alternative var 'rc'.

Use the existing setting or the default if nothing is found. If 'assert' is kTRUE, make also sure that the path exists. Return 0 on success, -1 on failure

Definition at line 1010 of file TProof.cxx.

◆ GetSeqNum()

Int_t TProof::GetSeqNum ( ) const
inline

Definition at line 918 of file TProof.h.

◆ GetSessionID()

Int_t TProof::GetSessionID ( ) const
inline

Definition at line 919 of file TProof.h.

◆ GetSessionTag()

const char * TProof::GetSessionTag ( ) const
inline

Definition at line 909 of file TProof.h.

◆ GetStagingStatusDataSet()

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

Obtains a TFileCollection showing the staging status of the specified dataset.

A valid dataset manager and dataset staging requests repository must be present on the endpoint.

Reimplemented in TProofLite.

Definition at line 11063 of file TProof.cxx.

◆ GetStatistics()

void TProof::GetStatistics ( Bool_t  verbose = kFALSE)

Get statistics about CPU time, real time and bytes read.

If verbose, print the resuls (always available via GetCpuTime(), GetRealTime() and GetBytesRead()

Definition at line 2025 of file TProof.cxx.

◆ GetStatus()

Int_t TProof::GetStatus ( ) const
inline

Definition at line 915 of file TProof.h.

◆ GetTreeHeader()

TTree * TProof::GetTreeHeader ( TDSet tdset)
virtual

Creates a tree header (a tree with nonexisting files) object for the DataSet.

Reimplemented in TProofLite.

Definition at line 10032 of file TProof.cxx.

◆ GetUrl()

const char * TProof::GetUrl ( )
inline

Definition at line 911 of file TProof.h.

◆ GetUser()

const char * TProof::GetUser ( ) const
inline

Definition at line 906 of file TProof.h.

◆ GetWorkDir()

const char * TProof::GetWorkDir ( ) const
inline

Definition at line 908 of file TProof.h.

◆ GoAsynchronous()

void TProof::GoAsynchronous ( )

Send GOASYNC message to the master.

Definition at line 6257 of file TProof.cxx.

◆ GoMoreParallel()

Int_t TProof::GoMoreParallel ( Int_t  nWorkersToAdd)
private

Add nWorkersToAdd workers to current list of workers.

This function is works on the master only, and only when an analysis is ongoing. A message is sent back to the client when we go "more" parallel. Returns -1 on error, number of total (not added!) workers on success.

Definition at line 7160 of file TProof.cxx.

◆ GoParallel()

Int_t TProof::GoParallel ( Int_t  nodes,
Bool_t  attach = kFALSE,
Bool_t  random = kFALSE 
)
private

Go in parallel mode with at most "nodes" slaves.

Since the fSlaves list is sorted by slave performace the active list will contain first the most performant nodes. Returns the number of active slaves. If random is TRUE, and nodes is less than the number of available workers, a random selection is done. Returns -1 in case of error.

Definition at line 7263 of file TProof.cxx.

◆ HandleInputMessage()

Int_t TProof::HandleInputMessage ( TSlave sl,
TMessage mess,
Bool_t  deactonfail = kFALSE 
)
private

Analyze the received message.

Returns 0 on success (1 if this the last message from this socket), -1 if any failure occurs.

Definition at line 3095 of file TProof.cxx.

◆ HandleLibIncPath()

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

Handle lib, inc search paths modification request.

Definition at line 8988 of file TProof.cxx.

◆ HandleOutputOptions()

Int_t TProof::HandleOutputOptions ( TString opt,
TString target,
Int_t  action 
)
protected

Extract from opt information about output handling settings.

The understood keywords are: of=<file>, outfile=<file> output file location ds=<dsname>, dataset=<dsname> dataset name ('of' and 'ds' are mutually exclusive,execution stops if both are found) sft[=<opt>], savetofile[=<opt>] control saving to file

For 'mvf', the <opt> integer has the following meaning: <opt> = <how>*10 + <force> <force> = 0 save to file if memory threshold is reached (the memory threshold is set by the cluster admin); in case an output file is defined, the files are merged at the end; 1 save results to file. <how> = 0 save at the end of the query 1 save results after each packet (to reduce the loss in case of crash).

Setting 'ds' automatically sets 'mvf=1'; it is still possible to set 'mvf=11' to save results after each packet.

The separator from the next option is either a ' ' or a ';'

All recognized settings are removed from the input string opt. If action == 0, set up the output file accordingly, if action == 1 clean related output file settings. If the final target file is local then 'target' is set to the final local path when action == 0 and used to retrieve the file with TFile::Cp when action == 1.

Output file settings are in the form

  <previous_option>of=name <next_option>
  <previous_option>outfile=name,...;<next_option>

The separator from the next option is either a ' ' or a ';' Called interanally by TProof::Process.

Returns 0 on success, -1 on error.

Definition at line 4927 of file TProof.cxx.

◆ HandleSubmerger()

void TProof::HandleSubmerger ( TMessage mess,
TSlave sl 
)
private

Process a message of type kPROOF_SUBMERGER.

Definition at line 4004 of file TProof.cxx.

◆ Init()

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

Start the PROOF environment.

Starting PROOF involves either connecting to a master server, which in turn will start a set of slave servers, or directly starting as master server (if master = ""). For a description of the arguments see the TProof ctor. Returns the number of started master or slave servers, returns 0 in case of error, in which case fValid remains false.

Definition at line 751 of file TProof.cxx.

◆ InitMembers()

void TProof::InitMembers ( )
protected

Default initializations.

Definition at line 521 of file TProof.cxx.

◆ Interrupt()

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

Send interrupt to master or slave servers.

Definition at line 2266 of file TProof.cxx.

◆ InterruptCurrentMonitor()

void TProof::InterruptCurrentMonitor ( )
private

If in active in a monitor set ready state.

Definition at line 11325 of file TProof.cxx.

◆ IsDataReady()

Bool_t TProof::IsDataReady ( Long64_t totalbytes,
Long64_t bytesready 
)

See if the data is ready to be analyzed.

Definition at line 2230 of file TProof.cxx.

◆ IsEndMaster()

Bool_t TProof::IsEndMaster ( ) const
inlineprivate

Definition at line 664 of file TProof.h.

◆ IsFolder()

Bool_t TProof::IsFolder ( ) const
inlinevirtual

Returns kTRUE in case object contains browsable objects (like containers or lists of other objects).

Reimplemented from TObject.

Definition at line 935 of file TProof.h.

◆ IsIdle()

Bool_t TProof::IsIdle ( ) const
inline

Definition at line 940 of file TProof.h.

◆ IsLite()

Bool_t TProof::IsLite ( ) const
inline

Definition at line 933 of file TProof.h.

◆ IsMaster()

Bool_t TProof::IsMaster ( ) const
inline

Definition at line 936 of file TProof.h.

◆ IsParallel()

Bool_t TProof::IsParallel ( ) const
inline

Definition at line 939 of file TProof.h.

◆ IsProofd()

Bool_t TProof::IsProofd ( ) const
inline

Definition at line 934 of file TProof.h.

◆ IsSync()

Bool_t TProof::IsSync ( ) const
inlineprivate

Definition at line 669 of file TProof.h.

◆ IsTty()

Bool_t TProof::IsTty ( ) const
inline

Definition at line 938 of file TProof.h.

◆ IsValid()

Bool_t TProof::IsValid ( ) const
inline

Definition at line 937 of file TProof.h.

◆ IsWaiting()

Bool_t TProof::IsWaiting ( ) const
inline

Definition at line 941 of file TProof.h.

◆ Load()

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

Load the specified macro on master, workers and, if notOnClient is kFALSE, on the client.

The macro file is uploaded if new or updated. Additional files to be uploaded (or updated, if needed) can be specified after a comma, e.g. "mymacro.C+,thisheader.h,thatheader.h". If existing in the same directory, a header basename(macro).h or .hh, is also uploaded. The default is to load the macro also on the client; notOnClient can be used to avoid loading on the client. On masters, if uniqueWorkers is kTRUE, the macro is loaded on unique workers only, and collection is not done; if uniqueWorkers is kFALSE, collection from the previous request is done, and broadcasting + collection from the other workers is done. The wrks arg can be used on the master to limit the set of workers. Returns 0 in case of success and -1 in case of error.

Reimplemented in TProofLite.

Definition at line 8618 of file TProof.cxx.

◆ LoadPackage()

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

Load specified package.

Executes the PROOF-INF/SETUP.C script on all active nodes. If notOnClient = true, don't load package on the client. The default is to load the package also on the client. The argument 'loadopts' specify a list of objects to be passed to the SETUP. The objects in the list must be streamable; the SETUP macro will be executed like this: SETUP.C(loadopts). Returns 0 in case of success and -1 in case of error.

Definition at line 8059 of file TProof.cxx.

◆ LogMessage()

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

Log a message into the appropriate window by emitting a signal.

Definition at line 6404 of file TProof.cxx.

◆ LogViewer()

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

Start the log viewer window usign the plugin manager.

Definition at line 12460 of file TProof.cxx.

◆ MakePlayer()

TVirtualProofPlayer * TProof::MakePlayer ( const char *  player = 0,
TSocket s = 0 
)
protectedvirtual

Construct a TProofPlayer object.

The player string specifies which player should be created: remote, slave, sm (supermaster) or base. Default is remote. Socket is needed in case a slave player is created.

Reimplemented in TProofSuperMaster.

Definition at line 10201 of file TProof.cxx.

◆ MarkBad() [1/2]

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

Add a bad slave server to the bad slave list and remove it from the active list and from the two monitor objects.

Assume that the work done by this worker was lost and ask packerizer to reassign it.

Definition at line 4511 of file TProof.cxx.

◆ MarkBad() [2/2]

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

Add slave with socket s to the bad slave list and remove if from the active list and from the two monitor objects.

Definition at line 4672 of file TProof.cxx.

◆ Mgr()

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

Get instance of the effective manager for 'url' Return 0 on failure.

Definition at line 11714 of file TProof.cxx.

◆ ModifyWorkerLists()

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

Modify the worker active/inactive list by making the worker identified by the ordinal number 'ord' active (add == TRUE) or inactive (add == FALSE).

The string 'ord' can also be a comma-separated list of ordinal numbers the status of which will be modified at once. If needed, the request will be forwarded to the master in direct contact with the worker. The end-master will move the worker from one list to the other active and rebuild the list of unique active workers. Use ord = "*" to deactivate all active workers. If save is TRUE the current active list is saved before any modification is done; re-running with ord = "restore" restores the saved list Return <0 if something went wrong (-2 if at least one worker was not found) or the number of workers with status change (on master; 0 on client).

Definition at line 11379 of file TProof.cxx.

◆ NotifyLogMsg()

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

Notify locally 'msg' to the appropriate units (file, stdout, window) If defined, 'sfx' is added after 'msg' (typically a line-feed);.

Definition at line 6348 of file TProof.cxx.

◆ Open()

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

Start a PROOF session on a specific cluster.

If cluster is 0 (the default) then the PROOF Session Viewer GUI pops up and 0 is returned. If cluster is "lite://" we start a PROOF-lite session. If cluster is "" (empty string) then we connect to the cluster specified by 'Proof.LocalDefault', defaulting to "lite://". If cluster is "pod://" (case insensitive), then we connect to a PROOF cluster managed by PROOF on Demand (PoD, http://pod.gsi.de ). Via conffile a specific PROOF config file in the confir directory can be specified. Use loglevel to set the default loging level for debugging. The appropriate instance of TProofMgr is created, if not yet existing. The instantiated TProof object is returned. Use TProof::cd() to switch between PROOF sessions. For more info on PROOF see the TProof ctor.

Definition at line 11573 of file TProof.cxx.

◆ operator=()

void TProof::operator= ( const TProof )
private

◆ ParseConfigField()

void TProof::ParseConfigField ( const char *  config)
private

The config file field may contain special instructions which need to be parsed at the beginning, e.g.

for debug runs with valgrind. Several options can be given separated by a ','

Definition at line 1037 of file TProof.cxx.

◆ Ping() [1/2]

Int_t TProof::Ping ( )

Ping PROOF. Returns 1 if master server responded.

Definition at line 4734 of file TProof.cxx.

◆ Ping() [2/2]

Int_t TProof::Ping ( ESlaves  list)
private

Ping PROOF slaves. Returns the number of slaves that responded.

Definition at line 4742 of file TProof.cxx.

◆ PollForNewWorkers()

Int_t TProof::PollForNewWorkers ( )
protectedvirtual

Asks the PROOF Serv for new workers in Dynamic Startup mode and activates them.

Returns the number of new workers found, or <0 on errors.

Reimplemented in TProofLite.

Definition at line 2960 of file TProof.cxx.

◆ PrepareInputDataFile()

void TProof::PrepareInputDataFile ( TString dataFile)
protected

Prepare the file with the input data objects to be sent the master; the objects are taken from the dedicated list and / or the specified file.

If the fInputData is empty the specified file is sent over. If there is no specified file, a file named "inputdata.root" is created locally with the content of fInputData and sent over to the master. If both fInputData and the specified file are not empty, a copy of the file is made locally and augmented with the content of fInputData.

Definition at line 9629 of file TProof.cxx.

◆ Print()

void TProof::Print ( Option_t option = "") const
virtual

Print status of PROOF cluster.

Reimplemented from TNamed.

Reimplemented in TProofLite.

Definition at line 4793 of file TProof.cxx.

◆ PrintProgress()

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

Print a progress bar on stderr. Used in batch mode.

Definition at line 9130 of file TProof.cxx.

◆ Process() [1/8]

Long64_t TProof::Process ( const char *  dsetname,
const char *  selector,
Option_t option = "",
Long64_t  nentries = -1,
Long64_t  first = 0,
TObject elist = 0 
)
virtual

Process a dataset which is stored on the master with name 'dsetname'.

The syntax for dsetname is name[#[dir/]objname], e.g. "mydset" analysis of the first tree in the top dir of the dataset named "mydset" "mydset#T" analysis tree "T" in the top dir of the dataset named "mydset" "mydset#adir/T" analysis tree "T" in the dir "adir" of the dataset named "mydset" "mydset#adir/" analysis of the first tree in the dir "adir" of the dataset named "mydset" The component 'name' in its more general form contains also the group and user name following "/<group>/<user>/<dsname>". Each of these components can contain one or more wildcards '*', in which case all the datasets matching the expression are added together as a global dataset (wildcard support has been added in version 5.27/02). The last argument 'elist' specifies an entry- or event-list to be used as event selection. It is also possible (starting w/ version 5.27/02) to run on multiple datasets at once in a more flexible way that the one provided by wildcarding. There are three possibilities: 1) specifying the dataset names separated by the OR operator '|', e.g. dsetname = "<dset1>|<dset2>|<dset3>|..." in this case the datasets are a seen as a global unique dataset 2) specifying the dataset names separated by a ',' or a ' ', e.g. dsetname = "<dset1>,<dset2> <dset3>,..." in this case the datasets are processed one after the other and the selector is notified when switching dataset via a bit in the current processed element. 3) giving the path of a textfile where the dataset names are specified on one or multiple lines; the lines found are joined as in 1), unless the filepath is followed by a ',' (i.e. p->Process("datasets.txt,",...) with the dataset names listed in 'datasets.txt') in which case they are treated as in 2); the file is open in raw mode with TFile::Open and therefore it cane be remote, e.g. on a Web server. Each <dsetj> has the format specified above for the single dataset processing, included wildcarding (the name of the tree and subdirectory must be same for all the datasets). In the case of multiple datasets, 'elist' is treated a global entry list. It is possible to specify per-dataset entry lists using the syntax "mydset[#adir/[T]]?enl=entrylist" or "mydset[#adir/[T]]<<entrylist" Here 'entrylist' is a tag identifying, in the order : i. a named entry-list in the input list or in the input data list ii. a named entry-list in memory (in gDirectory) iii. the path of a file containing the entry-list to be used In the case ii) and iii) the entry-list object(s) is(are) added to the input data list. The return value is -1 in case of error and TSelector::GetStatus() in in case of success.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5493 of file TProof.cxx.

◆ Process() [2/8]

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

Process with name of dataset and TSelector object.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5799 of file TProof.cxx.

◆ Process() [3/8]

Long64_t TProof::Process ( const char *  selector,
Long64_t  n,
Option_t option = "" 
)
virtual

Generic (non-data based) selector processing: the Process() method of the specified selector (.C) or TSelector object is called 'n' times.

The return value is -1 in case of error and TSelector::GetStatus() in in case of success.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5711 of file TProof.cxx.

◆ Process() [4/8]

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

Process a data set (TDSet) using the specified selector (.C) file or Tselector object Entry- or event-lists should be set in the data set object using TDSet::SetEntryList.

The return value is -1 in case of error and TSelector::GetStatus() in in case of success.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5293 of file TProof.cxx.

◆ Process() [5/8]

Long64_t TProof::Process ( TDSet dset,
TSelector selector,
Option_t option = "",
Long64_t  nentries = -1,
Long64_t  first = 0 
)
virtual

Process a data set (TDSet) using the specified selector object.

Entry- or event-lists should be set in the data set object using TDSet::SetEntryList. The return value is -1 in case of error and TSelector::GetStatus() in in case of success.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5751 of file TProof.cxx.

◆ Process() [6/8]

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

Process a data set (TFileCollection) using the specified selector (.C) file or TSelector object.

The default tree is analyzed (i.e. the first one found). To specify another tree, the default tree can be changed using TFileCollection::SetDefaultMetaData . The return value is -1 in case of error and TSelector::GetStatus() in in case of success.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5402 of file TProof.cxx.

◆ Process() [7/8]

Long64_t TProof::Process ( TFileCollection fc,
TSelector selector,
Option_t option = "",
Long64_t  nentries = -1,
Long64_t  first = 0 
)
virtual

Process a data set (TFileCollection) using the specified selector object The default tree is analyzed (i.e.

the first one found). To specify another tree, the default tree can be changed using TFileCollection::SetDefaultMetaData . The return value is -1 in case of error and TSelector::GetStatus() in in case of success.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5777 of file TProof.cxx.

◆ Process() [8/8]

Long64_t TProof::Process ( TSelector selector,
Long64_t  n,
Option_t option = "" 
)
virtual

Generic (non-data based) selector processing: the Process() method of the specified selector is called 'n' times.

The return value is -1 in case of error and TSelector::GetStatus() in in case of success.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5825 of file TProof.cxx.

◆ Progress() [1/3]

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

Get query progress information.

Connect a slot to this signal to track progress.

Definition at line 9191 of file TProof.cxx.

◆ Progress() [2/3]

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

Get query progress information.

Connect a slot to this signal to track progress.

Definition at line 9214 of file TProof.cxx.

◆ Progress() [3/3]

void TProof::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 
)

Get query progress information.

Connect a slot to this signal to track progress.

Definition at line 9236 of file TProof.cxx.

◆ Prompt()

Bool_t TProof::Prompt ( const char *  p)
private

Prompt the question 'p' requiring an answer y,Y,n,N Return kTRUE is the answer was y or Y, kFALSE in all other cases.

Definition at line 7639 of file TProof.cxx.

◆ PutLog()

void TProof::PutLog ( TQueryResult qr)

Display log of query pq into the log window frame.

Definition at line 10311 of file TProof.cxx.

◆ QueryResultReady()

void TProof::QueryResultReady ( const char *  ref)

Notify availability of a query result.

Definition at line 9359 of file TProof.cxx.

◆ RecvLogFile()

void TProof::RecvLogFile ( TSocket s,
Int_t  size 
)
private

Receive the log file of the slave with socket s.

Definition at line 6277 of file TProof.cxx.

◆ RedirectWorker()

void TProof::RedirectWorker ( TSocket s,
TSlave sl,
Int_t  output_size 
)
private

Redirect output of worker sl to some merger.

Definition at line 4248 of file TProof.cxx.

◆ RegisterDataSet()

Bool_t TProof::RegisterDataSet ( const char *  dataSetName,
TFileCollection dataSet,
const char *  optStr = "" 
)
virtual

Register the 'dataSet' on the cluster under the current user, group and the given 'dataSetName'.

If a dataset with the same name already exists the action fails unless 'opts' contains 'O', in which case the old dataset is overwritten, or contains 'U', in which case 'newDataSet' is added to the existing dataset (duplications are ignored, if any). If 'opts' contains 'V' the dataset files are also verified (if the dataset manager is configured to allow so). By default the dataset is not verified. If 'opts' contains 'T' the in the dataset object (status bits, meta,...) is trusted, i.e. not reset (if the dataset manager is configured to allow so). If 'opts' contains 'S' validation would be run serially (meaningful only if validation is required). Returns kTRUE on success.

Reimplemented in TProofLite.

Definition at line 10697 of file TProof.cxx.

◆ ReleaseMonitor()

void TProof::ReleaseMonitor ( TMonitor mon)
private

Release the used monitor to be used, making sure to delete newly created monitors.

Definition at line 2644 of file TProof.cxx.

◆ Remove() [1/2]

Int_t TProof::Remove ( const char *  ref,
Bool_t  all = kFALSE 
)

Send remove request for the query specified by ref.

If all = TRUE remove also local copies of the query, if any. Generic method working for all queries known by the server. This method can be also used to reset the list of queries waiting to be processed: for that purpose use ref == "cleanupqueue".

Definition at line 6024 of file TProof.cxx.

◆ Remove() [2/2]

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

Send remove request for the qry-th query in fQueries.

Definition at line 6003 of file TProof.cxx.

◆ RemoveChain()

void TProof::RemoveChain ( TChain chain)

Remove chain from data set.

Definition at line 10221 of file TProof.cxx.

◆ RemoveDataSet()

Int_t TProof::RemoveDataSet ( const char *  uri,
const char *  optStr = "" 
)
virtual

Remove the specified dataset from the PROOF cluster.

Files are not deleted.

Reimplemented in TProofLite.

Definition at line 10981 of file TProof.cxx.

◆ RemoveDynamicPath()

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

Remove 'libpath' from the lib path search.

Multiple paths can be specified at once separating them with a comma or a blank. Return 0 on success, -1 otherwise

Definition at line 8923 of file TProof.cxx.

◆ RemoveFeedback()

void TProof::RemoveFeedback ( const char *  name)

Remove object from feedback list.

Definition at line 9990 of file TProof.cxx.

◆ RemoveIncludePath()

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

Remove 'incpath' from the inc path search.

Multiple paths can be specified at once separating them with a comma or a blank. Return 0 on success, -1 otherwise

Definition at line 8957 of file TProof.cxx.

◆ RemoveWorkers()

Int_t TProof::RemoveWorkers ( TList workerList)
protected

Used for shuting down the workres after a query is finished.

Sends each of the workers from the workerList, a kPROOF_STOP message. If the workerList == 0, shutdown all the workers.

Definition at line 1587 of file TProof.cxx.

◆ RequestStagingDataSet()

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

Allows users to request staging of a particular dataset.

Requests are saved in a special dataset repository and must be honored by the endpoint.

Reimplemented in TProofLite.

Definition at line 11010 of file TProof.cxx.

◆ Reset()

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

Wrapper around TProofMgr::Reset(...).

Definition at line 11726 of file TProof.cxx.

◆ ResetEnvVars()

void TProof::ResetEnvVars ( )
static

Clear the list of environment variables passed to proofserv on the master and slaves.

Definition at line 11786 of file TProof.cxx.

◆ ResetMergePrg()

void TProof::ResetMergePrg ( )
private

Reset the merge progress notificator.

Definition at line 2455 of file TProof.cxx.

◆ ResetMergers()

void TProof::ResetMergers ( )
inlineprivate

Definition at line 691 of file TProof.h.

◆ ResetProgressDialog()

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

Reset progress dialog.

Definition at line 9289 of file TProof.cxx.

◆ ResetProgressDialogStatus()

void TProof::ResetProgressDialogStatus ( )
inline

Definition at line 1021 of file TProof.h.

◆ RestoreActiveList()

Int_t TProof::RestoreActiveList ( )
private

Restore saved list of active workers.

Definition at line 11547 of file TProof.cxx.

◆ Retrieve() [1/2]

Int_t TProof::Retrieve ( const char *  ref,
const char *  path = 0 
)

Send retrieve request for the query specified by ref.

If path is defined save it to path. Generic method working for all queries known by the server.

Definition at line 5957 of file TProof.cxx.

◆ Retrieve() [2/2]

Int_t TProof::Retrieve ( Int_t  qry,
const char *  path = 0 
)

Send retrieve request for the qry-th query in fQueries.

If path is defined save it to path.

Definition at line 5938 of file TProof.cxx.

◆ SaveActiveList()

void TProof::SaveActiveList ( )
private

Save current list of active workers.

Definition at line 11532 of file TProof.cxx.

◆ SaveInputData()

Int_t TProof::SaveInputData ( TQueryResult qr,
const char *  cachedir,
TString emsg 
)
staticprotected

Save input data file from 'cachedir' into the sandbox or create a the file with input data objects.

Definition at line 12301 of file TProof.cxx.

◆ SavePerfTree()

Int_t TProof::SavePerfTree ( const char *  pf = 0,
const char *  ref = 0 
)

Save performance information from TPerfStats to file 'pf'.

If 'ref' is defined, do it for query 'ref'. Return 0 on sucecss, -1 in case of any error

Definition at line 12636 of file TProof.cxx.

◆ SaveWorkerInfo()

void TProof::SaveWorkerInfo ( )
protectedvirtual

Save information about the worker set in the file .workers in the working dir.

Called each time there is a change in the worker setup, e.g. by TProof::MarkBad().

Definition at line 11798 of file TProof.cxx.

◆ SendCommand()

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

Send command to be executed on the PROOF master and/or slaves.

Command can be any legal command line command, however commands like ".x file.C" or ".L file.C" will not cause the file.C to be transfered to the PROOF cluster. In that case use TProof::Exec(). Returns the status send by the remote server as part of the kPROOF_LOGDONE message. Typically this is the return code of the command on the remote side. Returns -1 in case of error.

Definition at line 6621 of file TProof.cxx.

◆ SendCurrentState() [1/2]

Int_t TProof::SendCurrentState ( ESlaves  list = kActive)
private

Transfer the current state of the master to the active slave servers.

The current state includes: the current working directory, etc. Returns the number of active slaves. Returns -1 in case of error.

Definition at line 6748 of file TProof.cxx.

◆ SendCurrentState() [2/2]

Int_t TProof::SendCurrentState ( TList list)
private

Transfer the current state of the master to the active slave servers.

The current state includes: the current working directory, etc. Returns the number of active slaves. Returns -1 in case of error.

Definition at line 6732 of file TProof.cxx.

◆ SendDataSetStatus()

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

Send or notify data set status.

Definition at line 9326 of file TProof.cxx.

◆ SendFile()

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

Send a file to master or slave servers.

Returns number of slaves the file was sent to, maybe 0 in case master and slaves have the same file system image, -1 in case of error. If defined, send to worker 'wrk' only. If defined, the full path of the remote path will be rfile. If rfile = "cache" the file is copied to the remote cache instead of the sandbox (to copy to the cache on a different name use rfile = "cache:newname"). The mask 'opt' is an or of ESendFileOpt:

  kAscii  (0x0)      if set true ascii file transfer is used
  kBinary (0x1)      if set true binary file transfer is used
  kForce  (0x2)      if not set an attempt is done to find out
                     whether the file really needs to be downloaded
                     (a valid copy may already exist in the cache
                     from a previous run); the bit is set by
                     UploadPackage, since the check is done elsewhere.
  kForward (0x4)     if set, ask server to forward the file to slave
                     or submaster (meaningless for slave servers).
  kCpBin   (0x8)     Retrieve from the cache the binaries associated
                     with the file
  kCp      (0x10)    Retrieve the files from the cache

Definition at line 6884 of file TProof.cxx.

◆ SendGroupView()

Int_t TProof::SendGroupView ( )
private

Send to all active slaves servers the current slave group size and their unique id.

Returns number of active slaves. Returns -1 in case of error.

Definition at line 6450 of file TProof.cxx.

◆ SendingLogToWindow()

Bool_t TProof::SendingLogToWindow ( ) const
inline

Definition at line 1016 of file TProof.h.

◆ SendInitialState()

Int_t TProof::SendInitialState ( )
private

Transfer the initial (i.e.

current) state of the master to all slave servers. Currently the initial state includes: log level. Returns the number of active slaves. Returns -1 in case of error.

Definition at line 6764 of file TProof.cxx.

◆ SendInputData()

Int_t TProof::SendInputData ( TQueryResult qr,
TProof p,
TString emsg 
)
staticprotected

Send the input data file to the workers.

Definition at line 12370 of file TProof.cxx.

◆ SendInputDataFile()

void TProof::SendInputDataFile ( )
protectedvirtual

Send the input data objects to the master; the objects are taken from the dedicated list and / or the specified file.

If the fInputData is empty the specified file is sent over. If there is no specified file, a file named "inputdata.root" is created locally with the content of fInputData and sent over to the master. If both fInputData and the specified file are not empty, a copy of the file is made locally and augmented with the content of fInputData.

Reimplemented in TProofLite.

Definition at line 9602 of file TProof.cxx.

◆ SendLogToWindow()

void TProof::SendLogToWindow ( Bool_t  mode)
inline

Definition at line 1017 of file TProof.h.

◆ SendObject()

Int_t TProof::SendObject ( const TObject obj,
ESlaves  list = kActive 
)
private

Send object to master or slave servers.

Returns number of slaves object was sent to, -1 in case of error.

Definition at line 7044 of file TProof.cxx.

◆ SendPrint()

Int_t TProof::SendPrint ( Option_t option = "")
private

Send print command to master server.

Returns number of slaves message was sent to. Returns -1 in case of error.

Definition at line 7058 of file TProof.cxx.

◆ SetActive()

void TProof::SetActive ( Bool_t  = kTRUE)
inline

Definition at line 988 of file TProof.h.

◆ SetAlias()

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

Set an alias for this session.

If reconnection is supported, the alias will be communicated to the remote coordinator so that it can be recovered when reconnecting

Definition at line 10573 of file TProof.cxx.

◆ SetDataPoolUrl()

void TProof::SetDataPoolUrl ( const char *  url)
inline

Definition at line 1044 of file TProof.h.

◆ SetDataSetTreeName()

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

Set/Change the name of the default tree.

The tree name may contain subdir specification in the form "subdir/name". Returns 0 on success, -1 otherwise.

Reimplemented in TProofLite.

Definition at line 10756 of file TProof.cxx.

◆ SetDrawFeedbackOption()

void TProof::SetDrawFeedbackOption ( TDrawFeedback f,
Option_t opt 
)

Set draw feedback option.

Definition at line 10092 of file TProof.cxx.

◆ SetDSet()

void TProof::SetDSet ( TDSet dset)
inlineprotected

Definition at line 737 of file TProof.h.

◆ SetFeedback()

void TProof::SetFeedback ( TString opt,
TString optfb,
Int_t  action 
)
protected

Extract from opt in optfb information about wanted feedback settings.

Feedback are removed from the input string opt. If action == 0, set up feedback accordingly, if action == 1 clean related feedback settings (using info in optfb, if available, or reparsing opt).

Feedback requirements are in the form

  <previous_option>fb=name1,name2,name3,... <next_option>
  <previous_option>feedback=name1,name2,name3,...;<next_option>

The special name 'stats' triggers feedback about events and packets. The separator from the next option is either a ' ' or a ';'. Called interanally by TProof::Process.

Definition at line 5222 of file TProof.cxx.

◆ SetInputDataFile()

void TProof::SetInputDataFile ( const char *  datafile)

Set the file to be used to optimally distribute the input data objects.

If the file exists the object in the file are added to those in the fInputData list. If the file path is null, a default file will be created at the moment of sending the processing request with the content of the fInputData list. See also SendInputDataFile.

Definition at line 9575 of file TProof.cxx.

◆ SetLogLevel()

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

Set server logging level.

Definition at line 7069 of file TProof.cxx.

◆ SetManager()

void TProof::SetManager ( TProofMgr mgr)

Set manager and schedule its destruction after this for clean operations.

Definition at line 1291 of file TProof.cxx.

◆ SetMaxDrawQueries()

void TProof::SetMaxDrawQueries ( Int_t  max)

Set max number of draw queries whose results are saved.

Definition at line 2105 of file TProof.cxx.

◆ SetMonitor()

void TProof::SetMonitor ( TMonitor mon = 0,
Bool_t  on = kTRUE 
)
private

Activate (on == TRUE) or deactivate (on == FALSE) all sockets monitored by 'mon'.

Definition at line 2398 of file TProof.cxx.

◆ SetParallel()

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

Tell PROOF how many slaves to use in parallel.

Returns the number of parallel slaves. Returns -1 in case of error.

Definition at line 7130 of file TProof.cxx.

◆ SetParallelSilent()

Int_t TProof::SetParallelSilent ( Int_t  nodes,
Bool_t  random = kFALSE 
)
private

Tell PROOF how many slaves to use in parallel.

If random is TRUE a random selection is done (if nodes is less than the available nodes). Returns the number of parallel slaves. Returns -1 in case of error.

Definition at line 7102 of file TProof.cxx.

◆ SetParameter() [1/5]

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

Set input list parameter.

If the parameter is already set it will be set to the new value.

Definition at line 9812 of file TProof.cxx.

◆ SetParameter() [2/5]

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

Set an input list parameter.

Definition at line 9888 of file TProof.cxx.

◆ SetParameter() [3/5]

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

Set an input list parameter.

Definition at line 9831 of file TProof.cxx.

◆ SetParameter() [4/5]

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

Set an input list parameter.

Definition at line 9869 of file TProof.cxx.

◆ SetParameter() [5/5]

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

Set an input list parameter.

Definition at line 9850 of file TProof.cxx.

◆ SetPerfTree()

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

Enable/Disable saving of the performance tree.

Definition at line 12614 of file TProof.cxx.

◆ SetPlayer()

void TProof::SetPlayer ( TVirtualProofPlayer player)
protected

Set a new PROOF player.

Definition at line 10189 of file TProof.cxx.

◆ SetPrintProgress()

void TProof::SetPrintProgress ( PrintProgress_t  pp)
inline

Definition at line 1046 of file TProof.h.

◆ SetProgressDialog()

void TProof::SetProgressDialog ( Bool_t  on = kTRUE)

Enable/Disable the graphic progress dialog.

By default the dialog is enabled

Definition at line 12499 of file TProof.cxx.

◆ SetQueryMode()

void TProof::SetQueryMode ( EQueryMode  mode)

Change query running mode to the one specified by 'mode'.

Definition at line 6097 of file TProof.cxx.

◆ SetRealTimeLog()

void TProof::SetRealTimeLog ( Bool_t  on = kTRUE)

Switch ON/OFF the real-time logging facility.

When this option is ON, log messages from processing are sent back as they come, instead of being sent back at the end in one go. This may help debugging or monitoring in some cases, but, depending on the amount of log, it may have significant consequencies on the load over the network, so it must be used with care.

Definition at line 7086 of file TProof.cxx.

◆ SetRunStatus()

void TProof::SetRunStatus ( ERunStatus  rst)
inlineprivate

Definition at line 672 of file TProof.h.

◆ SetupWorkersEnv()

void TProof::SetupWorkersEnv ( TList wrks,
Bool_t  increasingpool = kFALSE 
)
protected

Set up packages, loaded macros, include and lib paths ...

Definition at line 1518 of file TProof.cxx.

◆ ShowCache()

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

List contents of file cache.

If all is true show all caches also on slaves. If everything is ok all caches are to be the same.

Reimplemented in TProofLite.

Definition at line 7681 of file TProof.cxx.

◆ ShowData()

void TProof::ShowData ( )
virtual

List contents of the data directory in the sandbox.

This is the place where files produced by the client queries are kept

Reimplemented in TProofLite.

Definition at line 7386 of file TProof.cxx.

◆ ShowDataSet()

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

display meta-info for given dataset usi

Definition at line 10967 of file TProof.cxx.

◆ ShowDataSetCache()

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

Display the content of the dataset cache, if any (matching 'dataset', if defined).

Reimplemented in TProofLite.

Definition at line 10904 of file TProof.cxx.

◆ ShowDataSetQuota()

void TProof::ShowDataSetQuota ( Option_t opt = 0)

shows the quota and usage of all groups if opt contains "U" shows also distribution of usage on user-level

Definition at line 11299 of file TProof.cxx.

◆ ShowDataSets()

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

Shows datasets in locations that match the uri.

By default shows the user's datasets and global ones

Reimplemented in TProofLite.

Definition at line 10836 of file TProof.cxx.

◆ ShowEnabledPackages()

void TProof::ShowEnabledPackages ( Bool_t  all = kFALSE)

List which packages are enabled.

If all is true show enabled packages for all active slaves. If everything is ok all active slaves should have the same packages enabled.

Definition at line 7808 of file TProof.cxx.

◆ ShowFeedback()

void TProof::ShowFeedback ( ) const

Show items in feedback list.

Definition at line 10010 of file TProof.cxx.

◆ ShowLog() [1/2]

void TProof::ShowLog ( const char *  queryref)

Display on screen the content of the temporary log file for query in reference.

Definition at line 10328 of file TProof.cxx.

◆ ShowLog() [2/2]

void TProof::ShowLog ( Int_t  qry = -1)

Display on screen the content of the temporary log file.

If qry == -2 show messages from the last (current) query. If qry == -1 all the messages not yet displayed are shown (default). If qry == 0, all the messages in the file are shown. If qry > 0, only the messages related to query 'qry' are shown. For qry != -1 the original file offset is restored at the end

Definition at line 10361 of file TProof.cxx.

◆ ShowMissingFiles()

void TProof::ShowMissingFiles ( TQueryResult qr = 0)

Show information about missing files during query described by 'qr' or the last query if qr is null (default).

A short summary is printed in the end.

Definition at line 12512 of file TProof.cxx.

◆ ShowPackages()

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

List contents of package directory.

If all is true show all package directories also on slaves. If everything is ok all package directories should be the same. If redir is kTRUE the result is redirected to the log file (option available for internal actions).

Definition at line 7760 of file TProof.cxx.

◆ ShowParameters()

void TProof::ShowParameters ( const char *  wildcard = "PROOF_*") const

Show the input list parameters specified by the wildcard.

Default is the special PROOF control parameters (PROOF_*).

Definition at line 9948 of file TProof.cxx.

◆ ShowQueries()

void TProof::ShowQueries ( Option_t opt = "")

Ask the master for the list of queries.

Options: "A" show information about all the queries known to the server, i.e. even those processed by other sessions "L" show only information about queries locally available i.e. already retrieved. If "L" is specified, "A" is ignored. "F" show all details available about queries "H" print help menu Default ""

Definition at line 2155 of file TProof.cxx.

◆ ShowStagingStatusDataSet()

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

Like GetStagingStatusDataSet, but displays results immediately.

Definition at line 11106 of file TProof.cxx.

◆ SlaveStartupThread()

static void * TProof::SlaveStartupThread ( void arg)
staticprotected

◆ StartSlaves()

Bool_t TProof::StartSlaves ( Bool_t  attach = kFALSE)
protectedvirtual

Start up PROOF slaves.

Reimplemented in TProofCondor, and TProofSuperMaster.

Definition at line 1650 of file TProof.cxx.

◆ StartupMessage()

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

Send startup message.

Definition at line 9302 of file TProof.cxx.

◆ StopProcess()

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

Send STOPPROCESS message to master and workers.

Definition at line 6214 of file TProof.cxx.

◆ SystemCmd()

void TProof::SystemCmd ( const char *  cmd,
Int_t  fdout 
)
staticprotected

Exec system command 'cmd'. If fdout > -1, append the output to fdout.

Definition at line 7725 of file TProof.cxx.

◆ TerminateWorker() [1/2]

void TProof::TerminateWorker ( const char *  ord)
private

Ask an active worker 'ord' to terminate, i.e. to shutdown.

Definition at line 4710 of file TProof.cxx.

◆ TerminateWorker() [2/2]

void TProof::TerminateWorker ( TSlave wrk)
private

Ask an active worker 'wrk' to terminate, i.e. to shutdown.

Definition at line 4686 of file TProof.cxx.

◆ Touch()

void TProof::Touch ( )

Ping PROOF slaves. Returns the number of slaves that responded.

Definition at line 4772 of file TProof.cxx.

◆ UnloadPackage()

Int_t TProof::UnloadPackage ( const char *  package)
private

Unload specified package.

Returns 0 in case of success and -1 in case of error.

Definition at line 8104 of file TProof.cxx.

◆ UnloadPackages()

Int_t TProof::UnloadPackages ( )
private

Unload all packages.

Returns 0 in case of success and -1 in case of error.

Definition at line 8137 of file TProof.cxx.

◆ UpdateDialog()

void TProof::UpdateDialog ( )
protected

Final update of the progress dialog.

Definition at line 4343 of file TProof.cxx.

◆ UploadDataSet() [1/2]

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

*** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp.

*** Please use TProofMgr::UploadFiles.

Upload a set of files and save the list of files by name dataSetName. The mask 'opt' is a combination of EUploadOpt: kAppend (0x1) if set true files will be appended to the dataset existing by given name kOverwriteDataSet (0x2) if dataset with given name exited it would be overwritten kNoOverwriteDataSet (0x4) do not overwirte if the dataset exists kOverwriteAllFiles (0x8) overwrite all files that may exist kOverwriteNoFiles (0x10) overwrite none kAskUser (0x0) ask user before overwriteng dataset/files The default value is kAskUser. The user will be asked to confirm overwriting dataset or files unless specified opt provides the answer! If kOverwriteNoFiles is set, then a pointer to TList must be passed as skippedFiles argument. The function will add to this list TFileInfo objects describing all files that existed on the cluster and were not uploaded.

Definition at line 10656 of file TProof.cxx.

◆ UploadDataSet() [2/2]

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

*** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp.

*** Please use TProofMgr::UploadFiles.

Upload a set of files and save the list of files by name dataSetName. The 'files' argument is a list of TFileInfo objects describing the files as first url. The mask 'opt' is a combination of EUploadOpt: kAppend (0x1) if set true files will be appended to the dataset existing by given name kOverwriteDataSet (0x2) if dataset with given name exited it would be overwritten kNoOverwriteDataSet (0x4) do not overwirte if the dataset exists kOverwriteAllFiles (0x8) overwrite all files that may exist kOverwriteNoFiles (0x10) overwrite none kAskUser (0x0) ask user before overwriteng dataset/files The default value is kAskUser. The user will be asked to confirm overwriting dataset or files unless specified opt provides the answer! If kOverwriteNoFiles is set, then a pointer to TList must be passed as skippedFiles argument. The function will add to this list TFileInfo objects describing all files that existed on the cluster and were not uploaded.

Communication Summary Client Master |---------—>DataSetName--------—>| |<----—kMESS_OK/kMESS_NOTOK<----—| (Name OK/file exist) (*)|----—> call RegisterDataSet ----—>| (*) - optional

Definition at line 10625 of file TProof.cxx.

◆ UploadDataSetFromFile()

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

*** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp.

*** Please use TProofMgr::UploadFiles.

Upload files listed in "file" to PROOF cluster. Where file = name of file containing list of files and dataset = dataset name and opt is a combination of EUploadOpt bits. Each file description (line) can include wildcards. Check TFileInfo compatibility

Definition at line 10674 of file TProof.cxx.

◆ UploadPackage()

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

Upload a PROOF archive (PAR file).

A PAR file is a compressed tar file with one special additional directory, PROOF-INF (blatantly copied from Java's jar format). It must have the extension .par. A PAR file can be directly a binary or a source with a build procedure. In the PROOF-INF directory there can be a build script: BUILD.sh to be called to build the package, in case of a binary PAR file don't specify a build script or make it a no-op. Then there is SETUP.C which sets the right environment variables to use the package, like LD_LIBRARY_PATH, etc. The 'opt' allows to specify whether the .PAR should be just unpacked in the existing dir (opt = kUntar, default) or a remove of the existing directory should be executed (opt = kRemoveOld), so triggering a full re-build. The option if effective only for PROOF protocol > 8 . The lab 'dirlab' (e.g. 'G0') indicates that the package is to uploaded to an alternative global directory for global usage. This may require special privileges. If download is kTRUE and the package is not found locally, then it is downloaded from the master repository. Returns 0 in case of success and -1 in case of error.

Definition at line 8431 of file TProof.cxx.

◆ UseDynamicStartup()

Bool_t TProof::UseDynamicStartup ( ) const
inline

Definition at line 921 of file TProof.h.

◆ ValidateDSet()

void TProof::ValidateDSet ( TDSet dset)
protectedvirtual

Validate a TDSet.

Reimplemented in TProofSuperMaster.

Definition at line 9370 of file TProof.cxx.

◆ VerifyDataSet()

Int_t TProof::VerifyDataSet ( const char *  uri,
const char *  optStr = "" 
)
virtual

Verify if all files in the specified dataset are available.

Print a list and return the number of missing files. Returns -1 in case of error.

Reimplemented in TProofLite.

Definition at line 11120 of file TProof.cxx.

◆ VerifyDataSetParallel()

Int_t TProof::VerifyDataSetParallel ( const char *  uri,
const char *  optStr 
)
protected

Internal function for parallel dataset verification used TProof::VerifyDataSet and TProofLite::VerifyDataSet.

Definition at line 11171 of file TProof.cxx.

Friends And Related Symbol Documentation

◆ TDataSetManager

friend class TDataSetManager
friend

Definition at line 322 of file TProof.h.

◆ TPacketizer

friend class TPacketizer
friend

Definition at line 318 of file TProof.h.

◆ TPacketizerAdaptive

friend class TPacketizerAdaptive
friend

Definition at line 320 of file TProof.h.

◆ TPacketizerDev

friend class TPacketizerDev
friend

Definition at line 319 of file TProof.h.

◆ TProofInputHandler

friend class TProofInputHandler
friend

Definition at line 324 of file TProof.h.

◆ TProofInterruptHandler

friend class TProofInterruptHandler
friend

Definition at line 325 of file TProof.h.

◆ TProofLite

friend class TProofLite
friend

Definition at line 321 of file TProof.h.

◆ TProofPlayer

friend class TProofPlayer
friend

Definition at line 326 of file TProof.h.

◆ TProofPlayerLite

friend class TProofPlayerLite
friend

Definition at line 327 of file TProof.h.

◆ TProofPlayerRemote

friend class TProofPlayerRemote
friend

Definition at line 328 of file TProof.h.

◆ TProofProgressDialog

friend class TProofProgressDialog
friend

Definition at line 329 of file TProof.h.

◆ TProofServ

friend class TProofServ
friend

Definition at line 323 of file TProof.h.

◆ TSlave

friend class TSlave
friend

Definition at line 330 of file TProof.h.

◆ TSlaveLite

friend class TSlaveLite
friend

Definition at line 331 of file TProof.h.

◆ TVirtualPacketizer

friend class TVirtualPacketizer
friend

Definition at line 332 of file TProof.h.

◆ TXProofMgr

friend class TXProofMgr
friend

Definition at line 336 of file TProof.h.

◆ TXProofServ

friend class TXProofServ
friend

Definition at line 337 of file TProof.h.

◆ TXSlave

friend class TXSlave
friend

Definition at line 333 of file TProof.h.

◆ TXSocket

friend class TXSocket
friend

Definition at line 334 of file TProof.h.

◆ TXSocketHandler

friend class TXSocketHandler
friend

Definition at line 335 of file TProof.h.

Member Data Documentation

◆ fActiveMonitor

TMonitor* TProof::fActiveMonitor
private

Definition at line 484 of file TProof.h.

◆ fActiveSlaves

TList* TProof::fActiveSlaves
private

Definition at line 477 of file TProof.h.

◆ fActiveSlavesSaved

TString TProof::fActiveSlavesSaved
private

Definition at line 478 of file TProof.h.

◆ fAllMonitor

TMonitor* TProof::fAllMonitor
protected

Definition at line 575 of file TProof.h.

◆ fAllUniqueMonitor

TMonitor* TProof::fAllUniqueMonitor
private

Definition at line 486 of file TProof.h.

◆ fAllUniqueSlaves

TList* TProof::fAllUniqueSlaves
private

Definition at line 482 of file TProof.h.

◆ fAvailablePackages

TList* TProof::fAvailablePackages
protected

Definition at line 579 of file TProof.h.

◆ fBadSlaves

TList* TProof::fBadSlaves
protected

Definition at line 574 of file TProof.h.

◆ fBytesRead

Long64_t TProof::fBytesRead
private

Definition at line 488 of file TProof.h.

◆ fBytesReady

Long64_t TProof::fBytesReady
protected

Definition at line 577 of file TProof.h.

◆ fChains

TList* TProof::fChains
private

Definition at line 496 of file TProof.h.

◆ fCheckFileStatus

Int_t TProof::fCheckFileStatus
private

Definition at line 471 of file TProof.h.

◆ fCloseMutex

std::recursive_mutex TProof::fCloseMutex
private

Definition at line 542 of file TProof.h.

◆ fCollectTimeout

Int_t TProof::fCollectTimeout
protected

Definition at line 583 of file TProof.h.

◆ fConfDir

TString TProof::fConfDir
protected

Definition at line 569 of file TProof.h.

◆ fConfFile

TString TProof::fConfFile
protected

Definition at line 568 of file TProof.h.

◆ fCpuTime

Float_t TProof::fCpuTime
private

Definition at line 490 of file TProof.h.

◆ fCurrentMonitor

TMonitor* TProof::fCurrentMonitor
private

Definition at line 487 of file TProof.h.

◆ fDataPoolUrl

TString TProof::fDataPoolUrl
protected

Definition at line 585 of file TProof.h.

◆ fDataReady

Bool_t TProof::fDataReady
protected

Definition at line 576 of file TProof.h.

◆ fDrawQueries

Int_t TProof::fDrawQueries
private

Definition at line 524 of file TProof.h.

◆ fDSet

TDSet* TProof::fDSet
private

Definition at line 503 of file TProof.h.

◆ fDynamicStartup

Bool_t TProof::fDynamicStartup
protected

Definition at line 589 of file TProof.h.

◆ fEnabledPackages

TList* TProof::fEnabledPackages
protected

Definition at line 580 of file TProof.h.

◆ fEnabledPackagesOnCluster

TList* TProof::fEnabledPackagesOnCluster
private

Definition at line 533 of file TProof.h.

◆ fEndMaster

Bool_t TProof::fEndMaster
private

Definition at line 530 of file TProof.h.

◆ fFeedback

TList* TProof::fFeedback
private

Definition at line 495 of file TProof.h.

◆ fFileMap

FileMap_t TProof::fFileMap
private

Definition at line 502 of file TProof.h.

◆ fFinalizationRunning

Bool_t TProof::fFinalizationRunning
private

Definition at line 554 of file TProof.h.

◆ fgLogViewer

TPluginHandler * TProof::fgLogViewer = 0
staticprivate

Definition at line 561 of file TProof.h.

◆ fgProofEnvList

TList * TProof::fgProofEnvList = 0
staticprivate

Definition at line 545 of file TProof.h.

◆ fGroup

TString TProof::fGroup
private

Definition at line 468 of file TProof.h.

◆ fImage

TString TProof::fImage
protected

Definition at line 570 of file TProof.h.

◆ fInactiveSlaves

TList* TProof::fInactiveSlaves
private

Definition at line 480 of file TProof.h.

◆ fInputData

TList* TProof::fInputData
private

Definition at line 535 of file TProof.h.

◆ fInputDataFile

TString TProof::fInputDataFile
private

Definition at line 536 of file TProof.h.

◆ fIntHandler

TSignalHandler* TProof::fIntHandler
private

Definition at line 491 of file TProof.h.

◆ fIsPollingWorkers

Bool_t TProof::fIsPollingWorkers
private

Definition at line 475 of file TProof.h.

◆ fIsWaiting

Bool_t TProof::fIsWaiting
private

Definition at line 508 of file TProof.h.

◆ fLastAssignedMerger

Int_t TProof::fLastAssignedMerger
private

Definition at line 552 of file TProof.h.

◆ fLastPollWorkers_s

Long64_t TProof::fLastPollWorkers_s
private

Definition at line 476 of file TProof.h.

◆ fLoadedMacros

TList* TProof::fLoadedMacros
private

Definition at line 544 of file TProof.h.

◆ fLogFileName

TString TProof::fLogFileName
private

Definition at line 511 of file TProof.h.

◆ fLogFileR

FILE* TProof::fLogFileR
private

Definition at line 513 of file TProof.h.

◆ fLogFileW

FILE* TProof::fLogFileW
private

Definition at line 512 of file TProof.h.

◆ fLogLevel

Int_t TProof::fLogLevel
private

Definition at line 469 of file TProof.h.

◆ fLogToWindowOnly

Bool_t TProof::fLogToWindowOnly
private

Definition at line 514 of file TProof.h.

◆ fMacroLog

TMacro TProof::fMacroLog
private

Definition at line 517 of file TProof.h.

◆ fManager

TProofMgr* TProof::fManager
protected

Definition at line 587 of file TProof.h.

◆ fMaster

TString TProof::fMaster
private

Definition at line 466 of file TProof.h.

◆ fMasterServ

Bool_t TProof::fMasterServ
protected

Definition at line 566 of file TProof.h.

◆ fMaxDrawQueries

Int_t TProof::fMaxDrawQueries
private

Definition at line 525 of file TProof.h.

◆ fMergePrg

TProofMergePrg TProof::fMergePrg
private

Definition at line 519 of file TProof.h.

◆ fMergers

TList* TProof::fMergers
private

Definition at line 553 of file TProof.h.

◆ fMergersByHost

Bool_t TProof::fMergersByHost
private

Definition at line 549 of file TProof.h.

◆ fMergersCount

Int_t TProof::fMergersCount
private

Definition at line 550 of file TProof.h.

◆ fMergersSet

Bool_t TProof::fMergersSet
private

Definition at line 548 of file TProof.h.

◆ fNonUniqueMasters

TList* TProof::fNonUniqueMasters
private

Definition at line 483 of file TProof.h.

◆ fNotIdle

Int_t TProof::fNotIdle
private

Definition at line 505 of file TProof.h.

◆ fOtherQueries

Int_t TProof::fOtherQueries
private

Definition at line 523 of file TProof.h.

◆ fOutputList

TProofOutputList TProof::fOutputList
private

Definition at line 538 of file TProof.h.

◆ fPackMgr

TPackMgr* TProof::fPackMgr
private

Definition at line 532 of file TProof.h.

◆ fPerfTree

TString TProof::fPerfTree
private

Definition at line 557 of file TProof.h.

◆ fPlayer

TVirtualProofPlayer* TProof::fPlayer
private

Definition at line 494 of file TProof.h.

◆ fPrepTime

Float_t TProof::fPrepTime
protected

Definition at line 594 of file TProof.h.

◆ fPrintProgress

PrintProgress_t TProof::fPrintProgress
private

Definition at line 540 of file TProof.h.

◆ fProgressDialog

TPluginHandler* TProof::fProgressDialog
private

Definition at line 492 of file TProof.h.

◆ fProgressDialogStarted

Bool_t TProof::fProgressDialogStarted
private

Definition at line 493 of file TProof.h.

◆ fProtocol

Int_t TProof::fProtocol
protected

Definition at line 571 of file TProof.h.

◆ fQueries

TList* TProof::fQueries
private

Definition at line 522 of file TProof.h.

◆ fQueryMode

EQueryMode TProof::fQueryMode
protected

Definition at line 588 of file TProof.h.

◆ fQuerySTW

TStopwatch TProof::fQuerySTW
protected

Definition at line 593 of file TProof.h.

◆ fRealTime

Float_t TProof::fRealTime
private

Definition at line 489 of file TProof.h.

◆ fRecvMessages

TList* TProof::fRecvMessages
private

Definition at line 472 of file TProof.h.

◆ fRedirectNext

Int_t TProof::fRedirectNext
private

Definition at line 555 of file TProof.h.

◆ fRedirLog

Bool_t TProof::fRedirLog
private

Definition at line 510 of file TProof.h.

◆ fRunningDSets

TList* TProof::fRunningDSets
protected

Definition at line 581 of file TProof.h.

◆ fRunStatus

ERunStatus TProof::fRunStatus
private

Definition at line 507 of file TProof.h.

◆ fSaveLogToMacro

Bool_t TProof::fSaveLogToMacro
private

Definition at line 516 of file TProof.h.

◆ fSelector

TSelector* TProof::fSelector
protected

Definition at line 591 of file TProof.h.

◆ fSendGroupView

Bool_t TProof::fSendGroupView
private

list returned by kPROOF_GETSLAVEINFO

Definition at line 474 of file TProof.h.

◆ fSeqNum

Int_t TProof::fSeqNum
private

Definition at line 526 of file TProof.h.

◆ fServType

TProofMgr::EServType TProof::fServType
protected

Definition at line 586 of file TProof.h.

◆ fSessionID

Int_t TProof::fSessionID
private

Definition at line 528 of file TProof.h.

◆ fSlaveInfo

TList* TProof::fSlaveInfo
private

Definition at line 473 of file TProof.h.

◆ fSlaves

TList* TProof::fSlaves
protected

Definition at line 572 of file TProof.h.

◆ fStatus

Int_t TProof::fStatus
private

Definition at line 470 of file TProof.h.

◆ fSync

Bool_t TProof::fSync
private

Definition at line 506 of file TProof.h.

◆ fTerminatedSlaveInfos

TList* TProof::fTerminatedSlaveInfos
protected

Definition at line 573 of file TProof.h.

◆ fTotalBytes

Long64_t TProof::fTotalBytes
protected

Definition at line 578 of file TProof.h.

◆ fTty

Bool_t TProof::fTty
private

Definition at line 465 of file TProof.h.

◆ fUniqueMonitor

TMonitor* TProof::fUniqueMonitor
private

Definition at line 485 of file TProof.h.

◆ fUniqueSlaves

TList* TProof::fUniqueSlaves
private

Definition at line 481 of file TProof.h.

◆ fUrl

TUrl TProof::fUrl
protected

Definition at line 567 of file TProof.h.

◆ fValid

Bool_t TProof::fValid
private

Definition at line 464 of file TProof.h.

◆ fWaitingSlaves

TList* TProof::fWaitingSlaves
private

Definition at line 521 of file TProof.h.

◆ fWorkDir

TString TProof::fWorkDir
private

Definition at line 467 of file TProof.h.

◆ fWorkersToMerge

Int_t TProof::fWorkersToMerge
private

Definition at line 551 of file TProof.h.

◆ fWrksOutputReady

TList* TProof::fWrksOutputReady
private

Definition at line 559 of file TProof.h.

Libraries for TProof:

The documentation for this class was generated from the following files: