 |
ROOT 6.12/07 Reference Guide |
| |
ROOT 6.12/07 Reference Guide |
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.
Classes | |
| struct | MD5Mod_t |
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. More... | |
| virtual | ~TProof () |
| Clean up PROOF environment. More... | |
| 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. More... | |
| void | AddChain (TChain *chain) |
| Add chain to data set. More... | |
| Int_t | AddDynamicPath (const char *libpath, Bool_t onClient=kFALSE, TList *wrks=0, Bool_t doCollect=kTRUE) |
| Add 'libpath' to the lib path search. More... | |
| void | AddFeedback (const char *name) |
| Add object to feedback list. More... | |
| Int_t | AddIncludePath (const char *incpath, Bool_t onClient=kFALSE, TList *wrks=0, Bool_t doCollect=kTRUE) |
| Add 'incpath' to the inc path search. More... | |
| void | AddInput (TObject *obj) |
| Add objects that might be needed during the processing of the selector (see Process()). More... | |
| void | AddInputData (TObject *obj, Bool_t push=kFALSE) |
| Add data objects that might be needed during the processing of the selector (see Process()). More... | |
| Int_t | Archive (Int_t query, const char *url) |
| Send archive request for the qry-th query in fQueries. More... | |
| Int_t | Archive (const char *queryref, const char *url=0) |
| Send archive request for the query specified by ref. More... | |
| void | Browse (TBrowser *b) |
| Build the PROOF's structure in the browser. More... | |
| virtual Bool_t | CancelStagingDataSet (const char *dataset) |
| Cancels a dataset staging request. More... | |
| void | cd (Int_t id=-1) |
| Set session with 'id' the default one. More... | |
| Int_t | CleanupSession (const char *sessiontag) |
| Send cleanup request for the session specified by tag. More... | |
| virtual void | ClearCache (const char *file=0) |
| Remove file from all file caches. More... | |
| void | ClearData (UInt_t what=kUnregistered, const char *dsname=0) |
| Remove files for the data directory. More... | |
| virtual void | ClearDataSetCache (const char *dataset=0) |
| Clear the content of the dataset cache, if any (matching 'dataset', if defined). More... | |
| void | ClearFeedback () |
| Clear feedback list. More... | |
| void | ClearInput () |
| Clear input object list. More... | |
| void | ClearInputData (TObject *obj=0) |
| Remove obj form the input data list; if obj is null (default), clear the input data info. More... | |
| void | ClearInputData (const char *name) |
| Remove obj 'name' form the input data list;. More... | |
| Int_t | ClearPackage (const char *package) |
| Remove a specific package. More... | |
| Int_t | ClearPackages () |
| Remove all packages. More... | |
| void | Close (Option_t *option="") |
| Close all open slave servers. More... | |
| void | CloseProgressDialog () |
| Close progress dialog. More... | |
| TDrawFeedback * | CreateDrawFeedback () |
| Draw feedback creation proxy. More... | |
| void | DataSetStatus (const char *msg, Bool_t status, Int_t done, Int_t total) |
| Send dataset preparation status. More... | |
| Int_t | DeactivateWorker (const char *ord, Bool_t save=kTRUE) |
| Remove the worker identified by the ordinal number 'ord' from the the active list. More... | |
| void | DeleteDrawFeedback (TDrawFeedback *f) |
| Delete draw feedback object. More... | |
| void | DeleteParameters (const char *wildcard) |
| Delete the input list parameters specified by a wildcard (e.g. More... | |
| void | Detach (Option_t *opt="") |
| Detach this instance to its proofserv. More... | |
| void | DisableGoAsyn () |
| Signal to disable related switches. More... | |
| Int_t | DownloadPackage (const char *par, const char *dstdir=0) |
| Download a PROOF archive (PAR file) from the master package repository. More... | |
| 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). More... | |
| 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'. More... | |
| 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(). More... | |
| 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. More... | |
| Int_t | EnablePackage (const char *package, Bool_t notOnClient=kFALSE, TList *workers=0) |
| Enable specified package. More... | |
| Int_t | EnablePackage (const char *package, const char *loadopts, Bool_t notOnClient=kFALSE, TList *workers=0) |
| Enable specified package. More... | |
| Int_t | EnablePackage (const char *package, TList *loadopts, Bool_t notOnClient=kFALSE, TList *workers=0) |
| Enable specified package. More... | |
| Int_t | Exec (const char *cmd, Bool_t plusMaster=kFALSE) |
| Send command to be executed on the PROOF master and/or slaves. More... | |
| 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). More... | |
| virtual Bool_t | ExistsDataSet (const char *dataset) |
| Returns kTRUE if 'dataset' exists, kFALSE otherwise. More... | |
| void | Feedback (TList *objs) |
| Get list of feedback objects. More... | |
| Long64_t | Finalize (Int_t query=-1, Bool_t force=kFALSE) |
| Finalize the qry-th query in fQueries. More... | |
| Long64_t | Finalize (const char *queryref, Bool_t force=kFALSE) |
| Finalize query with reference ref. More... | |
| TList * | FindDataSets (const char *searchString, const char *optStr="") |
| Find datasets, returns in a TList all found datasets. More... | |
| Long64_t | GetBytesRead () const |
| Int_t | GetClientProtocol () const |
| const char * | GetConfDir () const |
| const char * | GetConfFile () const |
| Float_t | GetCpuTime () const |
| const char * | GetDataPoolUrl () const |
| virtual TFileCollection * | GetDataSet (const char *dataset, const char *optStr="") |
| Get a list of TFileInfo objects describing the files of the specified dataset. More... | |
| TMap * | GetDataSetQuota (const char *optStr="") |
| returns a map of the quotas of all groups More... | |
| virtual TMap * | GetDataSets (const char *uri="", const char *optStr="") |
| Lists all datasets that match given uri. More... | |
| TString | Getenv (const char *env, const char *ord="0") |
| Get value of environment variable 'env' on node 'ord'. More... | |
| TList * | GetFeedbackList () const |
| Return feedback list. More... | |
| const char * | GetGroup () const |
| const char * | GetImage () const |
| TList * | GetInputList () |
| Get input list. More... | |
| TMacro * | GetLastLog () |
| Fill a TMacro with the log lines since the last reading (fLogFileR) Return (TMacro *)0 if no line was logged. More... | |
| TList * | GetListOfEnabledPackages () |
| Get from the master the list of names of the packages enabled. More... | |
| TList * | GetListOfPackages () |
| Get from the master the list of names of the packages available. More... | |
| virtual TList * | GetListOfQueries (Option_t *opt="") |
| Ask the master for the list of queries. More... | |
| TList * | GetListOfSlaveInfos () |
| Returns list of TSlaveInfo's. In case of error return 0. More... | |
| TList * | GetLoadedMacros () const |
| void | GetLog (Int_t start=-1, Int_t end=-1) |
| Ask for remote logs in the range [start, end]. More... | |
| Int_t | GetLogLevel () const |
| TMacro * | GetMacroLog () |
| TProofMgr * | GetManager () |
| const char * | GetMaster () const |
| void | GetMaxQueries () |
| Get max number of queries whose full results are kept in the remote sandbox. More... | |
| TFileCollection * | 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). More... | |
| Int_t | GetNumberOfDrawQueries () |
| Int_t | GetNumberOfQueries () |
| Number of queries processed by this session. More... | |
| TObject * | GetOutput (const char *name) |
| Get specified object that has been produced during the processing (see Process()). More... | |
| TList * | GetOutputList () |
| Get list with all object created during processing (see Process()). More... | |
| TList * | GetOutputNames () |
| FIXME: to be written. More... | |
| Int_t | GetParallel () const |
| Returns number of slaves active in parallel mode. More... | |
| TObject * | GetParameter (const char *par) const |
| Get specified parameter. More... | |
| Int_t | GetPort () const |
| EQueryMode | GetQueryMode (Option_t *mode=0) const |
| Find out the query mode based on the current setting and 'mode'. More... | |
| TQueryResult * | GetQueryResult (const char *ref=0) |
| Return pointer to the full TQueryResult instance owned by the player and referenced by 'ref'. More... | |
| TList * | GetQueryResults () |
| Return pointer to the list of query results in the player. More... | |
| 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'. More... | |
| 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'. More... | |
| 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'. More... | |
| Float_t | GetRealTime () const |
| Int_t | GetRemoteProtocol () const |
| ERunStatus | GetRunStatus () const |
| Int_t | GetSeqNum () const |
| Int_t | GetSessionID () const |
| const char * | GetSessionTag () const |
| virtual TFileCollection * | GetStagingStatusDataSet (const char *dataset) |
| Obtains a TFileCollection showing the staging status of the specified dataset. More... | |
| void | GetStatistics (Bool_t verbose=kFALSE) |
| Get statistics about CPU time, real time and bytes read. More... | |
| Int_t | GetStatus () const |
| virtual TTree * | GetTreeHeader (TDSet *tdset) |
| Creates a tree header (a tree with nonexisting files) object for the DataSet. More... | |
| const char * | GetUrl () |
| const char * | GetUser () const |
| const char * | GetWorkDir () const |
| void | GoAsynchronous () |
| Send GOASYNC message to the master. More... | |
| Bool_t | IsDataReady (Long64_t &totalbytes, Long64_t &bytesready) |
| See if the data is ready to be analyzed. More... | |
| Bool_t | IsFolder () const |
| Returns kTRUE in case object contains browsable objects (like containers or lists of other objects). More... | |
| 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. More... | |
| void | LogMessage (const char *msg, Bool_t all) |
| Log a message into the appropriate window by emitting a signal. More... | |
| Int_t | Ping () |
| Ping PROOF. Returns 1 if master server responded. More... | |
| virtual void | Print (Option_t *option="") const |
| Print status of PROOF cluster. More... | |
| 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. More... | |
| 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. More... | |
| 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'. More... | |
| 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. More... | |
| 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. More... | |
| 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. More... | |
| 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. More... | |
| 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. More... | |
| void | Progress (Long64_t total, Long64_t processed) |
| Get query progress information. More... | |
| 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. More... | |
| 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. More... | |
| void | PutLog (TQueryResult *qr) |
| Display log of query pq into the log window frame. More... | |
| void | QueryResultReady (const char *ref) |
| Notify availability of a query result. More... | |
| 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'. More... | |
| Int_t | Remove (Int_t query, Bool_t all=kFALSE) |
| Send remove request for the qry-th query in fQueries. More... | |
| Int_t | Remove (const char *queryref, Bool_t all=kFALSE) |
| Send remove request for the query specified by ref. More... | |
| void | RemoveChain (TChain *chain) |
| Remove chain from data set. More... | |
| virtual Int_t | RemoveDataSet (const char *dataset, const char *optStr="") |
| Remove the specified dataset from the PROOF cluster. More... | |
| Int_t | RemoveDynamicPath (const char *libpath, Bool_t onClient=kFALSE) |
| Remove 'libpath' from the lib path search. More... | |
| void | RemoveFeedback (const char *name) |
| Remove object from feedback list. More... | |
| Int_t | RemoveIncludePath (const char *incpath, Bool_t onClient=kFALSE) |
| Remove 'incpath' from the inc path search. More... | |
| virtual Bool_t | RequestStagingDataSet (const char *dataset) |
| Allows users to request staging of a particular dataset. More... | |
| void | ResetProgressDialog (const char *sel, Int_t sz, Long64_t fst, Long64_t ent) |
| Reset progress dialog. More... | |
| void | ResetProgressDialogStatus () |
| Int_t | Retrieve (Int_t query, const char *path=0) |
| Send retrieve request for the qry-th query in fQueries. More... | |
| Int_t | Retrieve (const char *queryref, const char *path=0) |
| Send retrieve request for the query specified by ref. More... | |
| Int_t | SavePerfTree (const char *pf=0, const char *qref=0) |
| Save performance information from TPerfStats to file 'pf'. More... | |
| void | SendDataSetStatus (const char *msg, UInt_t n, UInt_t tot, Bool_t st) |
| Send or notify data set status. More... | |
| 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. More... | |
| void | SetDataPoolUrl (const char *url) |
| virtual Int_t | SetDataSetTreeName (const char *dataset, const char *treename) |
| Set/Change the name of the default tree. More... | |
| void | SetDrawFeedbackOption (TDrawFeedback *f, Option_t *opt) |
| Set draw feedback option. More... | |
| void | SetInputDataFile (const char *datafile) |
| Set the file to be used to optimally distribute the input data objects. More... | |
| void | SetLogLevel (Int_t level, UInt_t mask=TProofDebug::kAll) |
| Set server logging level. More... | |
| void | SetManager (TProofMgr *mgr) |
| Set manager and schedule its destruction after this for clean operations. More... | |
| void | SetMaxDrawQueries (Int_t max) |
| Set max number of draw queries whose results are saved. More... | |
| Int_t | SetParallel (Int_t nodes=-1, Bool_t random=kFALSE) |
| Tell PROOF how many slaves to use in parallel. More... | |
| void | SetParameter (const char *par, const char *value) |
| Set input list parameter. More... | |
| void | SetParameter (const char *par, Int_t value) |
| Set an input list parameter. More... | |
| void | SetParameter (const char *par, Long_t value) |
| Set an input list parameter. More... | |
| void | SetParameter (const char *par, Long64_t value) |
| Set an input list parameter. More... | |
| void | SetParameter (const char *par, Double_t value) |
| Set an input list parameter. More... | |
| void | SetPerfTree (const char *pf="perftree.root", Bool_t withWrks=kFALSE) |
| Enable/Disable saving of the performance tree. More... | |
| void | SetPrintProgress (PrintProgress_t pp) |
| void | SetProgressDialog (Bool_t on=kTRUE) |
| Enable/Disable the graphic progress dialog. More... | |
| void | SetQueryMode (EQueryMode mode) |
| Change query running mode to the one specified by 'mode'. More... | |
| void | SetRealTimeLog (Bool_t on=kTRUE) |
| Switch ON/OFF the real-time logging facility. More... | |
| virtual void | ShowCache (Bool_t all=kFALSE) |
| List contents of file cache. More... | |
| virtual void | ShowData () |
| List contents of the data directory in the sandbox. More... | |
| void | ShowDataSet (const char *dataset="", const char *opt="filter:SsCc") |
| display meta-info for given dataset usi More... | |
| virtual void | ShowDataSetCache (const char *dataset=0) |
| Display the content of the dataset cache, if any (matching 'dataset', if defined). More... | |
| 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 More... | |
| virtual void | ShowDataSets (const char *uri="", const char *optStr="") |
| Shows datasets in locations that match the uri. More... | |
| void | ShowEnabledPackages (Bool_t all=kFALSE) |
| List which packages are enabled. More... | |
| void | ShowFeedback () const |
| Show items in feedback list. More... | |
| void | ShowLog (Int_t qry=-1) |
| Display on screen the content of the temporary log file. More... | |
| void | ShowLog (const char *queryref) |
| Display on screen the content of the temporary log file for query in reference. More... | |
| void | ShowMissingFiles (TQueryResult *qr=0) |
| Show information about missing files during query described by 'qr' or the last query if qr is null (default). More... | |
| void | ShowPackages (Bool_t all=kFALSE, Bool_t redirlog=kFALSE) |
| List contents of package directory. More... | |
| void | ShowParameters (const char *wildcard="PROOF_*") const |
| Show the input list parameters specified by the wildcard. More... | |
| void | ShowQueries (Option_t *opt="") |
| Ask the master for the list of queries. More... | |
| virtual void | ShowStagingStatusDataSet (const char *dataset, const char *optStr="filter:SsCc") |
| Like GetStagingStatusDataSet, but displays results immediately. More... | |
| void | StartupMessage (const char *msg, Bool_t status, Int_t done, Int_t total) |
| Send startup message. More... | |
| void | StopProcess (Bool_t abort, Int_t timeout=-1) |
| Send STOPPROCESS message to master and workers. More... | |
| void | Touch () |
| Ping PROOF slaves. Returns the number of slaves that responded. More... | |
| 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. More... | |
| 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. More... | |
| 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. More... | |
| Int_t | UploadPackage (const char *par, EUploadPackageOpt opt=kUntar, TList *workers=0) |
| Upload a PROOF archive (PAR file). More... | |
| Bool_t | UseDynamicStartup () const |
| virtual Int_t | VerifyDataSet (const char *dataset, const char *optStr="") |
| Verify if all files in the specified dataset are available. More... | |
 Public Member Functions inherited from TNamed | |
| TNamed () | |
| TNamed (const char *name, const char *title) | |
| TNamed (const TString &name, const TString &title) | |
| TNamed (const TNamed &named) | |
| TNamed copy ctor. More... | |
| virtual | ~TNamed () |
| TNamed destructor. More... | |
| virtual void | Clear (Option_t *option="") |
| Set name and title to empty strings (""). More... | |
| virtual TObject * | Clone (const char *newname="") const |
| Make a clone of an object using the Streamer facility. More... | |
| virtual Int_t | Compare (const TObject *obj) const |
| Compare two TNamed objects. More... | |
| virtual void | Copy (TObject &named) const |
| Copy this to obj. More... | |
| virtual void | FillBuffer (char *&buffer) |
| Encode TNamed into output buffer. More... | |
| virtual const char * | GetName () const |
| Returns name of object. More... | |
| virtual const char * | GetTitle () const |
| Returns title of object. More... | |
| virtual ULong_t | Hash () const |
| Return hash value for this object. More... | |
| virtual Bool_t | IsSortable () const |
| virtual void | ls (Option_t *option="") const |
| List TNamed name and title. More... | |
| TNamed & | operator= (const TNamed &rhs) |
| TNamed assignment operator. More... | |
| virtual void | SetName (const char *name) |
| Set the name of the TNamed. More... | |
| virtual void | SetNameTitle (const char *name, const char *title) |
| Set all the TNamed parameters (name and title). More... | |
| virtual void | SetTitle (const char *title="") |
| Set the title of the TNamed. More... | |
| virtual Int_t | Sizeof () const |
| Return size of the TNamed part of the TObject. More... | |
| Public Member Functions inherited from TObject | |
| TObject () | |
| TObject constructor. More... | |
| TObject (const TObject &object) | |
| TObject copy ctor. More... | |
| virtual | ~TObject () |
| TObject destructor. More... | |
| void | AbstractMethod (const char *method) const |
| Use this method to implement an "abstract" method that you don't want to leave purely abstract. More... | |
| virtual void | AppendPad (Option_t *option="") |
| Append graphics object to current pad. More... | |
| ULong_t | CheckedHash () |
| Checked and record whether for this class has a consistent Hash/RecursiveRemove setup (*) and then return the regular Hash value for this object. More... | |
| virtual const char * | ClassName () const |
| Returns name of class to which the object belongs. More... | |
| virtual void | Delete (Option_t *option="") |
| Delete this object. More... | |
| virtual Int_t | DistancetoPrimitive (Int_t px, Int_t py) |
| Computes distance from point (px,py) to the object. More... | |
| virtual void | Draw (Option_t *option="") |
| Default Draw method for all objects. More... | |
| virtual void | DrawClass () const |
| Draw class inheritance tree of the class to which this object belongs. More... | |
| virtual TObject * | DrawClone (Option_t *option="") const |
Draw a clone of this object in the current selected pad for instance with: gROOT->SetSelectedPad(gPad). More... | |
| virtual void | Dump () const |
| Dump contents of object on stdout. More... | |
| virtual void | Error (const char *method, const char *msgfmt,...) const |
| Issue error message. More... | |
| 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. More... | |
| virtual void | Execute (TMethod *method, TObjArray *params, Int_t *error=0) |
| Execute method on this object with parameters stored in the TObjArray. More... | |
| virtual void | ExecuteEvent (Int_t event, Int_t px, Int_t py) |
| Execute action corresponding to an event at (px,py). More... | |
| virtual void | Fatal (const char *method, const char *msgfmt,...) const |
| Issue fatal error message. More... | |
| virtual TObject * | FindObject (const char *name) const |
| Must be redefined in derived classes. More... | |
| virtual TObject * | FindObject (const TObject *obj) const |
| Must be redefined in derived classes. More... | |
| virtual Option_t * | GetDrawOption () const |
| Get option used by the graphics system to draw this object. More... | |
| virtual const char * | GetIconName () const |
| Returns mime type name of object. More... | |
| virtual char * | GetObjectInfo (Int_t px, Int_t py) const |
| Returns string containing info about the object at position (px,py). More... | |
| virtual Option_t * | GetOption () const |
| virtual UInt_t | GetUniqueID () const |
| Return the unique object id. More... | |
| virtual Bool_t | HandleTimer (TTimer *timer) |
| Execute action in response of a timer timing out. More... | |
| 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. More... | |
| virtual void | Info (const char *method, const char *msgfmt,...) const |
| Issue info message. More... | |
| virtual Bool_t | InheritsFrom (const char *classname) const |
| Returns kTRUE if object inherits from class "classname". More... | |
| virtual Bool_t | InheritsFrom (const TClass *cl) const |
| Returns kTRUE if object inherits from TClass cl. More... | |
| virtual void | Inspect () const |
| Dump contents of this object in a graphics canvas. More... | |
| 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). More... | |
| 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). More... | |
| virtual Bool_t | Notify () |
| This method must be overridden to handle object notification. More... | |
| void | Obsolete (const char *method, const char *asOfVers, const char *removedFromVers) const |
| Use this method to declare a method obsolete. More... | |
| void | operator delete (void *ptr) |
| Operator delete. More... | |
| void | operator delete[] (void *ptr) |
| Operator delete []. More... | |
| void * | operator new (size_t sz) |
| void * | operator new (size_t sz, void *vp) |
| void * | operator new[] (size_t sz) |
| void * | operator new[] (size_t sz, void *vp) |
| TObject & | operator= (const TObject &rhs) |
| TObject assignment operator. More... | |
| virtual void | Paint (Option_t *option="") |
| This method must be overridden if a class wants to paint itself. More... | |
| virtual void | Pop () |
| Pop on object drawn in a pad to the top of the display list. More... | |
| virtual Int_t | Read (const char *name) |
| Read contents of object with specified name from the current directory. More... | |
| virtual void | RecursiveRemove (TObject *obj) |
| Recursively remove this object from a list. More... | |
| void | ResetBit (UInt_t f) |
| virtual void | SaveAs (const char *filename="", Option_t *option="") const |
| Save this object in the file specified by filename. More... | |
| virtual void | SavePrimitive (std::ostream &out, Option_t *option="") |
| Save a primitive as a C++ statement(s) on output stream "out". More... | |
| void | SetBit (UInt_t f, Bool_t set) |
| Set or unset the user status bits as specified in f. More... | |
| void | SetBit (UInt_t f) |
| virtual void | SetDrawOption (Option_t *option="") |
| Set drawing option for object. More... | |
| virtual void | SetUniqueID (UInt_t uid) |
| Set the unique object id. More... | |
| virtual void | SysError (const char *method, const char *msgfmt,...) const |
| Issue system error message. More... | |
| 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. More... | |
| virtual void | Warning (const char *method, const char *msgfmt,...) const |
| Issue warning message. More... | |
| virtual Int_t | Write (const char *name=0, Int_t option=0, Int_t bufsize=0) |
| Write this object to the current directory. More... | |
| virtual Int_t | Write (const char *name=0, Int_t option=0, Int_t bufsize=0) const |
| Write this object to the current directory. More... | |
| Public Member Functions inherited from TQObject | |
| TQObject () | |
| TQObject Constructor. More... | |
| virtual | ~TQObject () |
| TQObject Destructor. More... | |
| 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. More... | |
| 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. More... | |
| 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. More... | |
| virtual void | Disconnected (const char *) |
| template<typename T > | |
| void | Emit (const char *signal, const T &arg) |
| Activate signal with single parameter. More... | |
| void | Emit (const char *signal) |
| Acitvate signal without args. More... | |
| template<typename... T> | |
| void | EmitVA (const char *signal_name, Int_t, const T &... params) |
| Emit a signal with a varying number of arguments. More... | |
| TList * | GetListOfClassSignals () const |
| Returns pointer to list of signals of this class. More... | |
| TList * | GetListOfConnections () const |
| TList * | GetListOfSignals () const |
| virtual Bool_t | HasConnection (const char *signal_name) const |
| Return true if there is any object connected to this signal. More... | |
| 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. More... | |
| virtual Int_t | NumberOfSignals () const |
| Return number of signals for this object. More... | |
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. More... | |
| static void | DelEnvVar (const char *name) |
| Remove an variable from the list of environment variables passed to proofserv on the master and slaves. More... | |
| static const TList * | GetEnvVars () |
| Get environemnt variables. More... | |
| static TObject * | GetOutput (const char *name, TList *out) |
| Find object 'name' in list 'out' or in the files specified in there. More... | |
| static Int_t | GetParameter (TCollection *c, const char *par, TString &value) |
| Get the value from the specified parameter from the specified collection. More... | |
| static Int_t | GetParameter (TCollection *c, const char *par, Int_t &value) |
| Get the value from the specified parameter from the specified collection. More... | |
| static Int_t | GetParameter (TCollection *c, const char *par, Long_t &value) |
| Get the value from the specified parameter from the specified collection. More... | |
| static Int_t | GetParameter (TCollection *c, const char *par, Long64_t &value) |
| Get the value from the specified parameter from the specified collection. More... | |
| static Int_t | GetParameter (TCollection *c, const char *par, Double_t &value) |
| Get the value from the specified parameter from the specified collection. More... | |
| static void | LogViewer (const char *url=0, Int_t sessionidx=0) |
| Start the log viewer window usign the plugin manager. More... | |
| static TProofMgr * | Mgr (const char *url) |
| Get instance of the effective manager for 'url' Return 0 on failure. More... | |
| static TProof * | Open (const char *url=0, const char *conffile=0, const char *confdir=0, Int_t loglevel=0) |
| Start a PROOF session on a specific cluster. More... | |
| static void | Reset (const char *url, Bool_t hard=kFALSE) |
| Wrapper around TProofMgr::Reset(...). More... | |
| static void | ResetEnvVars () |
| Clear the list of environment variables passed to proofserv on the master and slaves. More... | |
| Static Public Member Functions inherited from TObject | |
| static Long_t | GetDtorOnly () |
| Return destructor only flag. More... | |
| static Bool_t | GetObjectStat () |
| Get status of object stat flag. More... | |
| static void | SetDtorOnly (void *obj) |
| Set destructor only flag. More... | |
| static void | SetObjectStat (Bool_t stat) |
| Turn on/off tracking of objects in the TObjectTable. More... | |
| Static Public Member Functions inherited from TQObject | |
| static Bool_t | AreAllSignalsBlocked () |
| Returns true if all signals are blocked. More... | |
| static Bool_t | BlockAllSignals (Bool_t b) |
| Block or unblock all signals. Returns the previous block status. More... | |
| static Bool_t | Connect (TQObject *sender, const char *signal, const char *receiver_class, void *receiver, const char *slot) |
| Create connection between sender and receiver. More... | |
| 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. More... | |
| 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. More... | |
| static Bool_t | Disconnect (const char *class_name, const char *signal, void *receiver=0, const char *slot=0) |
| Disconnects "class signal". More... | |
Protected Types | |
| enum | ESlaves { kAll, kActive, kUnique, kAllUnique } |
Protected Member Functions | |
| TProof () | |
| Protected constructor to be used by classes deriving from TProof (they have to call Init themselves and override StartSlaves appropriately). More... | |
| Int_t | AddWorkers (TList *wrks) |
| Works on the master node only. More... | |
| 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. More... | |
| Int_t | Collect (ESlaves list=kActive, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE) |
| Collect responses from the slave servers. More... | |
| Int_t | Collect (TList *slaves, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE) |
| Collect responses from the slave servers. More... | |
| TSlave * | CreateSlave (const char *url, const char *ord, Int_t perf, const char *image, const char *workdir) |
| Create a new TSlave of type TSlave::kSlave. More... | |
| TSlave * | CreateSubmaster (const char *url, const char *ord, const char *image, const char *msd, Int_t nwk=1) |
| Create a new TSlave of type TSlave::kMaster. More... | |
| TList * | GetEnabledPackages () const |
| TList * | GetListOfActiveSlaves () const |
| TVirtualProofPlayer * | GetPlayer () const |
| TPluginHandler * | GetProgressDialog () 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'. More... | |
| void | HandleLibIncPath (const char *what, Bool_t add, const char *dirs) |
| Handle lib, inc search paths modification request. More... | |
| Int_t | HandleOutputOptions (TString &opt, TString &target, Int_t action) |
| Extract from opt information about output handling settings. More... | |
| Int_t | Init (const char *masterurl, const char *conffile, const char *confdir, Int_t loglevel, const char *alias=0) |
| Start the PROOF environment. More... | |
| void | InitMembers () |
| Default initializations. More... | |
| virtual TVirtualProofPlayer * | MakePlayer (const char *player=0, TSocket *s=0) |
| Construct a TProofPlayer object. More... | |
| virtual Int_t | PollForNewWorkers () |
| Asks the PROOF Serv for new workers in Dynamic Startup mode and activates them. More... | |
| 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. More... | |
| Int_t | RemoveWorkers (TList *wrks) |
| Used for shuting down the workres after a query is finished. More... | |
| virtual void | SaveWorkerInfo () |
| Save information about the worker set in the file .workers in the working dir. More... | |
| 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. More... | |
| virtual void | SendInputDataFile () |
| Send the input data objects to the master; the objects are taken from the dedicated list and / or the specified file. More... | |
| void | SetDSet (TDSet *dset) |
| void | SetFeedback (TString &opt, TString &optfb, Int_t action) |
| Extract from opt in optfb information about wanted feedback settings. More... | |
| void | SetPlayer (TVirtualProofPlayer *player) |
| Set a new PROOF player. More... | |
| void | SetupWorkersEnv (TList *wrks, Bool_t increasingpool=kFALSE) |
| Set up packages, loaded macros, include and lib paths ... More... | |
| virtual Bool_t | StartSlaves (Bool_t attach=kFALSE) |
| Start up PROOF slaves. More... | |
| void | UpdateDialog () |
| Final update of the progress dialog. More... | |
| virtual void | ValidateDSet (TDSet *dset) |
| Validate a TDSet. More... | |
| Int_t | VerifyDataSetParallel (const char *uri, const char *optStr) |
| Internal function for parallel dataset verification used TProof::VerifyDataSet and TProofLite::VerifyDataSet. More... | |
| 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). More... | |
| void | MakeZombie () |
| Protected Member Functions inherited from TQObject | |
| virtual void * | GetSender () |
| 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. More... | |
| static void | AssertMacroPath (const char *macro) |
| Make sure that the directory path contained by macro is in the macro path. More... | |
| static Bool_t | GetFileInCmd (const char *cmd, TString &fn) |
| Static method to extract the filename (if any) form a CINT command. More... | |
| static Int_t | GetInputData (TList *input, const char *cachedir, TString &emsg) |
| Get the input data from the file defined in the input list. More... | |
| 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. More... | |
| static Int_t | SendInputData (TQueryResult *qr, TProof *p, TString &emsg) |
| Send the input data file to the workers. More... | |
| static void * | SlaveStartupThread (void *arg) |
| static void | SystemCmd (const char *cmd, Int_t fdout) |
| Exec system command 'cmd'. If fdout > -1, append the output to fdout. More... | |
| 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 consitency of sender/receiver methods/arguments. More... | |
| 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. More... | |
| static Bool_t | ConnectToClass (TQObject *sender, const char *signal, TClass *receiver_class, void *receiver, const char *slot) |
| Create connection between sender and receiver. More... | |
| 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. More... | |
Protected Attributes | |
| TMonitor * | fAllMonitor |
| TList * | fAvailablePackages |
| TList * | fBadSlaves |
| Long64_t | fBytesReady |
| Int_t | fCollectTimeout |
| TString | fConfDir |
| TString | fConfFile |
| TString | fDataPoolUrl |
| Bool_t | fDataReady |
| Bool_t | fDynamicStartup |
| TList * | fEnabledPackages |
| TString | fImage |
| TProofMgr * | fManager |
| Bool_t | fMasterServ |
| Float_t | fPrepTime |
| Int_t | fProtocol |
| EQueryMode | fQueryMode |
| TStopwatch | fQuerySTW |
| TList * | fRunningDSets |
| TSelector * | fSelector |
| TProofMgr::EServType | fServType |
| TList * | fSlaves |
| TList * | fTerminatedSlaveInfos |
| Long64_t | fTotalBytes |
| TUrl | fUrl |
| Protected Attributes inherited from TNamed | |
| TString | fName |
| TString | fTitle |
| Protected Attributes inherited from TQObject | |
| TList * | fListOfConnections |
| list of signals from this object More... | |
| TList * | fListOfSignals |
| Bool_t | fSignalsBlocked |
| list of connections to this object More... | |
Private Member Functions | |
| TProof (const TProof &) | |
| void | Activate (TList *slaves=0) |
| Activate slave server list. More... | |
| void | ActivateAsyncInput () |
| Activate the a-sync input handler. More... | |
| void | AskForOutput (TSlave *sl) |
| Master asks for output from worker sl. More... | |
| void | AskParallel () |
| Ask the for the number of parallel slaves. More... | |
| void | AskStatistics () |
| Ask the for the statistics of the slaves. More... | |
| Int_t | Broadcast (const TMessage &mess, TList *slaves) |
| Broadcast a message to all slaves in the specified list. More... | |
| 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). More... | |
| Int_t | Broadcast (const char *mess, Int_t kind, TList *slaves) |
| Broadcast a character string buffer to all slaves in the specified list. More... | |
| 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). More... | |
| Int_t | Broadcast (Int_t kind, TList *slaves) |
| Int_t | Broadcast (Int_t kind, ESlaves list=kActive) |
| Int_t | BroadcastFile (const char *file, Int_t opt, const char *rfile, TList *wrks) |
| Broadcast file to all workers in the specified list. More... | |
| 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. More... | |
| Int_t | BroadcastGroupPriority (const char *grp, Int_t priority, ESlaves list=kAllUnique) |
| Broadcast the group priority to all workers in the specified list. More... | |
| Int_t | BroadcastGroupPriority (const char *grp, Int_t priority, TList *workers) |
| Broadcast the group priority to all workers in the specified list. More... | |
| Int_t | BroadcastObject (const TObject *obj, Int_t kind, TList *slaves) |
| Broadcast an object to all slaves in the specified list. More... | |
| Int_t | BroadcastObject (const TObject *obj, Int_t kind=kMESS_OBJECT, ESlaves list=kActive) |
| Broadcast an object to all slaves in the specified list. More... | |
| 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. More... | |
| 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. More... | |
| Int_t | BuildPackage (const char *package, EBuildPackageOpt opt=kBuildAll, Int_t chkveropt=TPackMgr::kCheckROOT, TList *workers=0) |
| Build specified package. More... | |
| 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. More... | |
| void | CleanGDirectory (TList *ol) |
| Remove links to objects in list 'ol' from gDirectory. More... | |
| void | ClearDataProgress (Int_t r, Int_t t) |
| Progress bar for clear data. More... | |
| Int_t | Collect (const TSlave *sl, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE) |
| Collect responses from slave sl. More... | |
| Int_t | Collect (TMonitor *mon, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE) |
| Collect responses from the slave servers. More... | |
| Int_t | CollectInputFrom (TSocket *s, Int_t endtype=-1, Bool_t deactonfail=kFALSE) |
| Collect and analyze available input from socket s. More... | |
| Bool_t | CreateMerger (TSlave *sl, Int_t port) |
| Create a new merger. More... | |
| void | DeActivateAsyncInput () |
| De-activate a-sync input handler. More... | |
| Int_t | DisablePackage (const char *package) |
| Remove a specific package. More... | |
| Int_t | DisablePackages () |
| Remove all packages. More... | |
| Int_t | Exec (const char *cmd, ESlaves list, Bool_t plusMaster) |
| Send command to be executed on the PROOF master and/or slaves. More... | |
| void | FinalizationDone () |
| Int_t | FindNextFreeMerger () |
| Return a merger, which is both active and still accepts some workers to be assigned to it. More... | |
| TSlave * | FindSlave (TSocket *s) const |
| Find slave that has TSocket s. Returns 0 in case slave is not found. More... | |
| virtual void | FindUniqueSlaves () |
| Add to the fUniqueSlave list the active slaves that have a unique (user) file system image. More... | |
| Int_t | GetActiveMergersCount () |
| Get the active mergers count. More... | |
| TList * | GetListOfBadSlaves () const |
| TList * | GetListOfInactiveSlaves () const |
| TList * | GetListOfSlaves () const |
| TList * | GetListOfUniqueSlaves () const |
| Int_t | GetNumberOfActiveSlaves () const |
| Return number of active slaves, i.e. More... | |
| Int_t | GetNumberOfBadSlaves () const |
| Return number of bad slaves. More... | |
| Int_t | GetNumberOfInactiveSlaves () const |
| Return number of inactive slaves, i.e. More... | |
| Int_t | GetNumberOfSlaves () const |
| Return number of slaves as described in the config file. More... | |
| Int_t | GetNumberOfUniqueSlaves () const |
| Return number of unique slaves, i.e. More... | |
| Int_t | GetQueryReference (Int_t qry, TString &ref) |
| Get reference for the qry-th query in fQueries (as displayed by ShowQueries). More... | |
| Int_t | GoMoreParallel (Int_t nWorkersToAdd) |
| Add nWorkersToAdd workers to current list of workers. More... | |
| Int_t | GoParallel (Int_t nodes, Bool_t accept=kFALSE, Bool_t random=kFALSE) |
| Go in parallel mode with at most "nodes" slaves. More... | |
| Int_t | HandleInputMessage (TSlave *wrk, TMessage *m, Bool_t deactonfail=kFALSE) |
| Analyze the received message. More... | |
| void | HandleSubmerger (TMessage *mess, TSlave *sl) |
| Process a message of type kPROOF_SUBMERGER. More... | |
| void | Interrupt (EUrgent type, ESlaves list=kActive) |
| Send interrupt to master or slave servers. More... | |
| void | InterruptCurrentMonitor () |
| If in active in a monitor set ready state. More... | |
| 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. More... | |
| 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. More... | |
| 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. More... | |
| 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). More... | |
| void | NotifyLogMsg (const char *msg, const char *sfx="\) |
| Notify locally 'msg' to the appropriate units (file, stdout, window) If defined, 'sfx' is added after 'msg' (typically a line-feed);. More... | |
| 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. More... | |
| Int_t | Ping (ESlaves list) |
| Ping PROOF slaves. Returns the number of slaves that responded. More... | |
| 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. More... | |
| 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. More... | |
| void | RecvLogFile (TSocket *s, Int_t size) |
| Receive the log file of the slave with socket s. More... | |
| void | RedirectWorker (TSocket *s, TSlave *sl, Int_t output_size) |
| Redirect output of worker sl to some merger. More... | |
| void | ReleaseMonitor (TMonitor *mon) |
| Release the used monitor to be used, making sure to delete newly created monitors. More... | |
| void | ResetMergePrg () |
| Reset the merge progress notificator. More... | |
| void | ResetMergers () |
| Int_t | RestoreActiveList () |
| Restore saved list of active workers. More... | |
| void | SaveActiveList () |
| Save current list of active workers. More... | |
| Int_t | SendCommand (const char *cmd, ESlaves list=kActive) |
| Send command to be executed on the PROOF master and/or slaves. More... | |
| Int_t | SendCurrentState (ESlaves list=kActive) |
| Transfer the current state of the master to the active slave servers. More... | |
| Int_t | SendCurrentState (TList *list) |
| Transfer the current state of the master to the active slave servers. More... | |
| Int_t | SendGroupView () |
| Send to all active slaves servers the current slave group size and their unique id. More... | |
| Int_t | SendInitialState () |
| Transfer the initial (i.e. More... | |
| Int_t | SendObject (const TObject *obj, ESlaves list=kActive) |
| Send object to master or slave servers. More... | |
| Int_t | SendPrint (Option_t *option="") |
| Send print command to master server. More... | |
| void | SetMonitor (TMonitor *mon=0, Bool_t on=kTRUE) |
| Activate (on == TRUE) or deactivate (on == FALSE) all sockets monitored by 'mon'. More... | |
| Int_t | SetParallelSilent (Int_t nodes, Bool_t random=kFALSE) |
| Tell PROOF how many slaves to use in parallel. More... | |
| void | SetRunStatus (ERunStatus rst) |
| void | TerminateWorker (TSlave *wrk) |
| Ask an active worker 'wrk' to terminate, i.e. to shutdown. More... | |
| void | TerminateWorker (const char *ord) |
| Ask an active worker 'ord' to terminate, i.e. to shutdown. More... | |
| Int_t | UnloadPackage (const char *package) |
| Unload specified package. More... | |
| Int_t | UnloadPackages () |
| Unload all packages. More... | |
Static Private Member Functions | |
| static TList * | GetDataSetSrvMaps (const TString &srvmaps) |
Static Private Attributes | |
| static TPluginHandler * | fgLogViewer = 0 |
| static TList * | fgProofEnvList = 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 More... | |
#include <TProof.h>
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
| enum TProof::EQueryMode |
| enum TProof::ERegisterOpt |
| enum TProof::ERunStatus |
|
private |
|
protected |
| enum TProof::EStatusBits |
| enum TProof::ESubMerger |
| enum TProof::EUploadOpt |
|
private |
|
private |
|
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 510 of file TProof.cxx.
| 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 384 of file TProof.cxx.
|
virtual |
Clean up PROOF environment.
Definition at line 649 of file TProof.cxx.
Activate slave server list.
Definition at line 2367 of file TProof.cxx.
|
private |
Activate the a-sync input handler.
Definition at line 4382 of file TProof.cxx.
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 11325 of file TProof.cxx.
Add chain to data set.
Definition at line 10195 of file TProof.cxx.
| 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 8815 of file TProof.cxx.
|
static |
Add an variable to the list of environment variables passed to proofserv on the master and slaves.
Definition at line 11732 of file TProof.cxx.
| void TProof::AddFeedback | ( | const char * | name | ) |
Add object to feedback list.
Definition at line 9961 of file TProof.cxx.
| 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 8860 of file TProof.cxx.
Add objects that might be needed during the processing of the selector (see Process()).
Definition at line 9706 of file TProof.cxx.
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 9494 of file TProof.cxx.
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 1304 of file TProof.cxx.
Send archive request for the qry-th query in fQueries.
Definition at line 6029 of file TProof.cxx.
| 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 6049 of file TProof.cxx.
Master asks for output from worker sl.
Definition at line 4306 of file TProof.cxx.
|
private |
Ask the for the number of parallel slaves.
Definition at line 2055 of file TProof.cxx.
|
private |
Ask the for the statistics of the slaves.
Definition at line 2000 of file TProof.cxx.
|
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 11987 of file TProof.cxx.
|
staticprotected |
Make sure that the directory path contained by macro is in the macro path.
Definition at line 8571 of file TProof.cxx.
Make sure that 'path' exists; if 'writable' is kTRUE, make also sure that the path is writable.
Definition at line 1253 of file TProof.cxx.
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 2453 of file TProof.cxx.
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 2480 of file TProof.cxx.
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 2496 of file TProof.cxx.
|
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 2509 of file TProof.cxx.
|
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 2588 of file TProof.cxx.
|
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 2617 of file TProof.cxx.
|
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 2429 of file TProof.cxx.
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 2402 of file TProof.cxx.
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 2521 of file TProof.cxx.
|
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.
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 2545 of file TProof.cxx.
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 2572 of file TProof.cxx.
Build the PROOF's structure in the browser.
Reimplemented from TObject.
Definition at line 10151 of file TProof.cxx.
|
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 7962 of file TProof.cxx.
|
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 11018 of file TProof.cxx.
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 10468 of file TProof.cxx.
|
private |
Check if a file needs to be send to the slave.
Use the following algorithm:
Definition at line 6771 of file TProof.cxx.
Remove links to objects in list 'ol' from gDirectory.
Definition at line 3018 of file TProof.cxx.
| Int_t TProof::CleanupSession | ( | const char * | sessiontag | ) |
Send cleanup request for the session specified by tag.
Definition at line 6064 of file TProof.cxx.
|
virtual |
Remove file from all file caches.
If file is 0 or "" or "*", remove all the files
Reimplemented in TProofLite.
Definition at line 7686 of file TProof.cxx.
| 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 7384 of file TProof.cxx.
Progress bar for clear data.
Definition at line 7642 of file TProof.cxx.
|
virtual |
Clear the content of the dataset cache, if any (matching 'dataset', if defined).
Reimplemented in TProofLite.
Definition at line 10868 of file TProof.cxx.
| void TProof::ClearFeedback | ( | ) |
Clear feedback list.
Definition at line 9984 of file TProof.cxx.
| void TProof::ClearInput | ( | ) |
Clear input object list.
Definition at line 9714 of file TProof.cxx.
Remove obj form the input data list; if obj is null (default), clear the input data info.
Definition at line 9510 of file TProof.cxx.
| void TProof::ClearInputData | ( | const char * | name | ) |
Remove obj 'name' form the input data list;.
Definition at line 9544 of file TProof.cxx.
| 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 7829 of file TProof.cxx.
| Int_t TProof::ClearPackages | ( | ) |
Remove all packages.
Returns 0 in case of success and -1 in case of error.
Definition at line 7812 of file TProof.cxx.
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 1776 of file TProof.cxx.
| void TProof::CloseProgressDialog | ( | ) |
Close progress dialog.
Definition at line 9255 of file TProof.cxx.
|
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 2647 of file TProof.cxx.
|
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 2734 of file TProof.cxx.
|
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 2705 of file TProof.cxx.
|
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 2674 of file TProof.cxx.
|
private |
Collect and analyze available input from socket s.
Returns 0 on success, -1 if any failure occurs.
Definition at line 3032 of file TProof.cxx.
| TDrawFeedback * TProof::CreateDrawFeedback | ( | ) |
Draw feedback creation proxy.
When accessed via TProof avoids link dependency on libProofPlayer.
Definition at line 10066 of file TProof.cxx.
Create a new merger.
Definition at line 4426 of file TProof.cxx.
|
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 1831 of file TProof.cxx.
|
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 1853 of file TProof.cxx.
Send dataset preparation status.
Definition at line 9296 of file TProof.cxx.
|
private |
De-activate a-sync input handler.
Definition at line 4395 of file TProof.cxx.
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 11342 of file TProof.cxx.
|
static |
Remove an variable from the list of environment variables passed to proofserv on the master and slaves.
Definition at line 11754 of file TProof.cxx.
| void TProof::DeleteDrawFeedback | ( | TDrawFeedback * | f | ) |
Delete draw feedback object.
Definition at line 10082 of file TProof.cxx.
| 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 9905 of file TProof.cxx.
Detach this instance to its proofserv.
If opt is 'S' or 's' the remote server is shutdown
Definition at line 10490 of file TProof.cxx.
| void TProof::DisableGoAsyn | ( | ) |
Signal to disable related switches.
Definition at line 6231 of file TProof.cxx.
|
private |
Remove a specific package.
Returns 0 in case of success and -1 in case of error.
Definition at line 7857 of file TProof.cxx.
|
private |
Remove all packages.
Returns 0 in case of success and -1 in case of error.
Definition at line 7914 of file TProof.cxx.
| 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 8306 of file TProof.cxx.
|
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 6118 of file TProof.cxx.
| 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 6154 of file TProof.cxx.
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 7000 of file TProof.cxx.
|
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 7014 of file TProof.cxx.
| 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 8147 of file TProof.cxx.
| 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 8169 of file TProof.cxx.
| 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 8230 of file TProof.cxx.
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 6505 of file TProof.cxx.
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 6493 of file TProof.cxx.
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 6561 of file TProof.cxx.
|
virtual |
Returns kTRUE if 'dataset' exists, kFALSE otherwise.
Reimplemented in TProofLite.
Definition at line 10840 of file TProof.cxx.
Get list of feedback objects.
Connect a slot to this signal to monitor the feedback object.
Definition at line 9240 of file TProof.cxx.
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 5855 of file TProof.cxx.
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 5880 of file TProof.cxx.
| TList * TProof::FindDataSets | ( | const char * | searchString, |
| const char * | optStr = "" |
||
| ) |
Find datasets, returns in a TList all found datasets.
Definition at line 10982 of file TProof.cxx.
|
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 4276 of file TProof.cxx.
Find slave that has TSocket s. Returns 0 in case slave is not found.
Definition at line 1869 of file TProof.cxx.
|
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 1890 of file TProof.cxx.
|
private |
Get the active mergers count.
Definition at line 4408 of file TProof.cxx.
|
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 10909 of file TProof.cxx.
| TMap * TProof::GetDataSetQuota | ( | const char * | optStr = "" | ) |
returns a map of the quotas of all groups
Definition at line 11248 of file TProof.cxx.
|
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 10781 of file TProof.cxx.
|
inlineprotected |
| TString TProof::Getenv | ( | const char * | env, |
| const char * | ord = "0" |
||
| ) |
Get value of environment variable 'env' on node 'ord'.
Definition at line 6616 of file TProof.cxx.
|
static |
Get environemnt variables.
Definition at line 11723 of file TProof.cxx.
| TList * TProof::GetFeedbackList | ( | ) | const |
Return feedback list.
Definition at line 10005 of file TProof.cxx.
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 6467 of file TProof.cxx.
Get the input data from the file defined in the input list.
Definition at line 12386 of file TProof.cxx.
| TList * TProof::GetInputList | ( | ) |
Get input list.
Definition at line 9725 of file TProof.cxx.
| 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 10229 of file TProof.cxx.
|
inlineprotected |
| TList * TProof::GetListOfEnabledPackages | ( | ) |
Get from the master the list of names of the packages enabled.
Definition at line 9096 of file TProof.cxx.
|
inlineprivate |
| TList * TProof::GetListOfPackages | ( | ) |
Get from the master the list of names of the packages available.
Definition at line 9080 of file TProof.cxx.
Ask the master for the list of queries.
Reimplemented in TProofLite.
Definition at line 2066 of file TProof.cxx.
| TList * TProof::GetListOfSlaveInfos | ( | ) |
Returns list of TSlaveInfo's. In case of error return 0.
Definition at line 2299 of file TProof.cxx.
|
inlineprivate |
Ask for remote logs in the range [start, end].
If start == -1 all the messages not yet received are sent back.
Definition at line 10212 of file TProof.cxx.
| void TProof::GetMaxQueries | ( | ) |
Get max number of queries whose full results are kept in the remote sandbox.
Definition at line 2106 of file TProof.cxx.
| 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 12554 of file TProof.cxx.
|
private |
Return number of active slaves, i.e.
slaves that are valid and in the current computing group.
Definition at line 1965 of file TProof.cxx.
|
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 1992 of file TProof.cxx.
|
private |
Return number of inactive slaves, i.e.
slaves that are valid but not in the current computing group.
Definition at line 1974 of file TProof.cxx.
| Int_t TProof::GetNumberOfQueries | ( | ) |
Number of queries processed by this session.
Definition at line 2083 of file TProof.cxx.
|
private |
Return number of slaves as described in the config file.
Definition at line 1956 of file TProof.cxx.
|
private |
Return number of unique slaves, i.e.
active slaves that have each a unique different user files system.
Definition at line 1983 of file TProof.cxx.
| TObject * TProof::GetOutput | ( | const char * | name | ) |
Get specified object that has been produced during the processing (see Process()).
Definition at line 9734 of file TProof.cxx.
Find object 'name' in list 'out' or in the files specified in there.
Definition at line 9748 of file TProof.cxx.
| TList * TProof::GetOutputList | ( | ) |
Get list with all object created during processing (see Process()).
Definition at line 9780 of file TProof.cxx.
| TList * TProof::GetOutputNames | ( | ) |
FIXME: to be written.
Definition at line 10090 of file TProof.cxx.
| 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 2282 of file TProof.cxx.
| 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 9890 of file TProof.cxx.
|
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 11895 of file TProof.cxx.
|
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 11914 of file TProof.cxx.
|
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 11932 of file TProof.cxx.
|
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 11950 of file TProof.cxx.
|
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 11968 of file TProof.cxx.
|
inlineprotected |
|
inlineprotected |
| TProof::EQueryMode TProof::GetQueryMode | ( | Option_t * | mode = 0 | ) | const |
Find out the query mode based on the current setting and 'mode'.
Definition at line 6091 of file TProof.cxx.
Get reference for the qry-th query in fQueries (as displayed by ShowQueries).
Definition at line 5829 of file TProof.cxx.
| 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 2126 of file TProof.cxx.
| TList * TProof::GetQueryResults | ( | ) |
Return pointer to the list of query results in the player.
Definition at line 2117 of file TProof.cxx.
Get into 'env' the value of integer RC env variable 'rcenv' on node 'ord'.
Definition at line 6637 of file TProof.cxx.
Get into 'env' the value of double RC env variable 'rcenv' on node 'ord'.
Definition at line 6663 of file TProof.cxx.
Get into 'env' the value of string RC env variable 'rcenv' on node 'ord'.
Definition at line 6689 of file TProof.cxx.
|
inline |
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 1004 of file TProof.cxx.
|
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 11045 of file TProof.cxx.
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 2013 of file TProof.cxx.
Creates a tree header (a tree with nonexisting files) object for the DataSet.
Reimplemented in TProofLite.
Definition at line 10014 of file TProof.cxx.
| void TProof::GoAsynchronous | ( | ) |
Send GOASYNC message to the master.
Definition at line 6239 of file TProof.cxx.
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 7142 of file TProof.cxx.
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 7245 of file TProof.cxx.
|
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 3077 of file TProof.cxx.
Handle lib, inc search paths modification request.
Definition at line 8970 of file TProof.cxx.
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 4909 of file TProof.cxx.
Process a message of type kPROOF_SUBMERGER.
Definition at line 3986 of file TProof.cxx.
|
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 745 of file TProof.cxx.
|
protected |
Default initializations.
Definition at line 524 of file TProof.cxx.
Send interrupt to master or slave servers.
Definition at line 2254 of file TProof.cxx.
|
private |
If in active in a monitor set ready state.
Definition at line 11307 of file TProof.cxx.
See if the data is ready to be analyzed.
Definition at line 2218 of file TProof.cxx.
|
inlinevirtual |
|
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 8600 of file TProof.cxx.
|
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 8041 of file TProof.cxx.
Log a message into the appropriate window by emitting a signal.
Definition at line 6386 of file TProof.cxx.
Start the log viewer window usign the plugin manager.
Definition at line 12443 of file TProof.cxx.
|
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 10183 of file TProof.cxx.
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 4493 of file TProof.cxx.
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 4654 of file TProof.cxx.
|
static |
Get instance of the effective manager for 'url' Return 0 on failure.
Definition at line 11696 of file TProof.cxx.
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 11361 of file TProof.cxx.
|
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 6330 of file TProof.cxx.
|
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 11555 of file TProof.cxx.
|
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 1031 of file TProof.cxx.
Ping PROOF slaves. Returns the number of slaves that responded.
Definition at line 4724 of file TProof.cxx.
| Int_t TProof::Ping | ( | ) |
Ping PROOF. Returns 1 if master server responded.
Definition at line 4716 of file TProof.cxx.
|
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 2942 of file TProof.cxx.
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 9611 of file TProof.cxx.
Print status of PROOF cluster.
Reimplemented from TNamed.
Reimplemented in TProofLite.
Definition at line 4775 of file TProof.cxx.
|
private |
Print a progress bar on stderr. Used in batch mode.
Definition at line 9112 of file TProof.cxx.
|
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 5275 of file TProof.cxx.
|
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 5384 of file TProof.cxx.
|
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 5475 of file TProof.cxx.
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 5693 of file TProof.cxx.
|
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 5733 of file TProof.cxx.
|
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 5759 of file TProof.cxx.
|
virtual |
Process with name of dataset and TSelector object.
Reimplemented in TProofLite, and TProofSuperMaster.
Definition at line 5781 of file TProof.cxx.
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 5807 of file TProof.cxx.
Get query progress information.
Connect a slot to this signal to track progress.
Definition at line 9173 of file TProof.cxx.
| 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 9196 of file TProof.cxx.
| 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 9218 of file TProof.cxx.
|
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 7621 of file TProof.cxx.
| void TProof::PutLog | ( | TQueryResult * | qr | ) |
Display log of query pq into the log window frame.
Definition at line 10293 of file TProof.cxx.
| void TProof::QueryResultReady | ( | const char * | ref | ) |
Notify availability of a query result.
Definition at line 9341 of file TProof.cxx.
Receive the log file of the slave with socket s.
Definition at line 6259 of file TProof.cxx.
Redirect output of worker sl to some merger.
Definition at line 4230 of file TProof.cxx.
|
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 10679 of file TProof.cxx.
Release the used monitor to be used, making sure to delete newly created monitors.
Definition at line 2632 of file TProof.cxx.
Send remove request for the qry-th query in fQueries.
Definition at line 5985 of file TProof.cxx.
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 6006 of file TProof.cxx.
Remove chain from data set.
Definition at line 10203 of file TProof.cxx.
|
virtual |
Remove the specified dataset from the PROOF cluster.
Files are not deleted.
Reimplemented in TProofLite.
Definition at line 10963 of file TProof.cxx.
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 8905 of file TProof.cxx.
| void TProof::RemoveFeedback | ( | const char * | name | ) |
Remove object from feedback list.
Definition at line 9972 of file TProof.cxx.
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 8939 of file TProof.cxx.
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 1575 of file TProof.cxx.
|
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 10992 of file TProof.cxx.
Wrapper around TProofMgr::Reset(...).
Definition at line 11708 of file TProof.cxx.
|
static |
Clear the list of environment variables passed to proofserv on the master and slaves.
Definition at line 11768 of file TProof.cxx.
|
private |
Reset the merge progress notificator.
Definition at line 2443 of file TProof.cxx.
Reset progress dialog.
Definition at line 9271 of file TProof.cxx.
|
private |
Restore saved list of active workers.
Definition at line 11529 of file TProof.cxx.
Send retrieve request for the qry-th query in fQueries.
If path is defined save it to path.
Definition at line 5920 of file TProof.cxx.
| 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 5939 of file TProof.cxx.
|
private |
Save current list of active workers.
Definition at line 11514 of file TProof.cxx.
|
staticprotected |
Save input data file from 'cachedir' into the sandbox or create a the file with input data objects.
Definition at line 12284 of file TProof.cxx.
| 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 12619 of file TProof.cxx.
|
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 11780 of file TProof.cxx.
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 6603 of file TProof.cxx.
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 6730 of file TProof.cxx.
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 6714 of file TProof.cxx.
Send or notify data set status.
Definition at line 9308 of file TProof.cxx.
|
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 6866 of file TProof.cxx.
|
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 6432 of file TProof.cxx.
|
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 6746 of file TProof.cxx.
|
staticprotected |
Send the input data file to the workers.
Definition at line 12353 of file TProof.cxx.
|
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 9584 of file TProof.cxx.
Send object to master or slave servers.
Returns number of slaves object was sent to, -1 in case of error.
Definition at line 7026 of file TProof.cxx.
Send print command to master server.
Returns number of slaves message was sent to. Returns -1 in case of error.
Definition at line 7040 of file TProof.cxx.
|
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 10555 of file TProof.cxx.
|
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 10738 of file TProof.cxx.
| void TProof::SetDrawFeedbackOption | ( | TDrawFeedback * | f, |
| Option_t * | opt | ||
| ) |
Set draw feedback option.
Definition at line 10074 of file TProof.cxx.
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 5204 of file TProof.cxx.
| 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 9557 of file TProof.cxx.
| void TProof::SetLogLevel | ( | Int_t | level, |
| UInt_t | mask = TProofDebug::kAll |
||
| ) |
Set server logging level.
Definition at line 7051 of file TProof.cxx.
Set manager and schedule its destruction after this for clean operations.
Definition at line 1285 of file TProof.cxx.
Set max number of draw queries whose results are saved.
Definition at line 2093 of file TProof.cxx.
Activate (on == TRUE) or deactivate (on == FALSE) all sockets monitored by 'mon'.
Definition at line 2386 of file TProof.cxx.
Tell PROOF how many slaves to use in parallel.
Returns the number of parallel slaves. Returns -1 in case of error.
Definition at line 7112 of file TProof.cxx.
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 7084 of file TProof.cxx.
| 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 9794 of file TProof.cxx.
Set an input list parameter.
Definition at line 9813 of file TProof.cxx.
Set an input list parameter.
Definition at line 9832 of file TProof.cxx.
Set an input list parameter.
Definition at line 9851 of file TProof.cxx.
Set an input list parameter.
Definition at line 9870 of file TProof.cxx.
Enable/Disable saving of the performance tree.
Definition at line 12597 of file TProof.cxx.
|
protected |
Set a new PROOF player.
Definition at line 10171 of file TProof.cxx.
|
inline |
Enable/Disable the graphic progress dialog.
By default the dialog is enabled
Definition at line 12482 of file TProof.cxx.
| void TProof::SetQueryMode | ( | EQueryMode | mode | ) |
Change query running mode to the one specified by 'mode'.
Definition at line 6079 of file TProof.cxx.
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 7068 of file TProof.cxx.
|
inlineprivate |
Set up packages, loaded macros, include and lib paths ...
Definition at line 1512 of file TProof.cxx.
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 7663 of file TProof.cxx.
|
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 7368 of file TProof.cxx.
| void TProof::ShowDataSet | ( | const char * | dataset = "", |
| const char * | opt = "filter:SsCc" |
||
| ) |
display meta-info for given dataset usi
Definition at line 10949 of file TProof.cxx.
|
virtual |
Display the content of the dataset cache, if any (matching 'dataset', if defined).
Reimplemented in TProofLite.
Definition at line 10886 of file TProof.cxx.
shows the quota and usage of all groups if opt contains "U" shows also distribution of usage on user-level
Definition at line 11281 of file TProof.cxx.
|
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 10818 of file TProof.cxx.
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 7790 of file TProof.cxx.
| void TProof::ShowFeedback | ( | ) | const |
Show items in feedback list.
Definition at line 9992 of file TProof.cxx.
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 10343 of file TProof.cxx.
| void TProof::ShowLog | ( | const char * | queryref | ) |
Display on screen the content of the temporary log file for query in reference.
Definition at line 10310 of file TProof.cxx.
| 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 12495 of file TProof.cxx.
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 7742 of file TProof.cxx.
| 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 9930 of file TProof.cxx.
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 2143 of file TProof.cxx.
|
virtual |
Like GetStagingStatusDataSet, but displays results immediately.
Definition at line 11088 of file TProof.cxx.
Start up PROOF slaves.
Reimplemented in TProofCondor, and TProofSuperMaster.
Definition at line 1638 of file TProof.cxx.
Send startup message.
Definition at line 9284 of file TProof.cxx.
Send STOPPROCESS message to master and workers.
Definition at line 6196 of file TProof.cxx.
Exec system command 'cmd'. If fdout > -1, append the output to fdout.
Definition at line 7707 of file TProof.cxx.
Ask an active worker 'wrk' to terminate, i.e. to shutdown.
Definition at line 4668 of file TProof.cxx.
|
private |
Ask an active worker 'ord' to terminate, i.e. to shutdown.
Definition at line 4692 of file TProof.cxx.
| void TProof::Touch | ( | ) |
Ping PROOF slaves. Returns the number of slaves that responded.
Definition at line 4754 of file TProof.cxx.
|
private |
Unload specified package.
Returns 0 in case of success and -1 in case of error.
Definition at line 8086 of file TProof.cxx.
|
private |
Unload all packages.
Returns 0 in case of success and -1 in case of error.
Definition at line 8119 of file TProof.cxx.
|
protected |
Final update of the progress dialog.
Definition at line 4325 of file TProof.cxx.
*** 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 10607 of file TProof.cxx.
| 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 10638 of file TProof.cxx.
| 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 10656 of file TProof.cxx.
| 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 8413 of file TProof.cxx.
|
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 11102 of file TProof.cxx.
|
protected |
Internal function for parallel dataset verification used TProof::VerifyDataSet and TProofLite::VerifyDataSet.
Definition at line 11153 of file TProof.cxx.
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
staticprivate |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
protected |
|
protected |
|
private |
|
private |
|
protected |
ROOT 6.12/07 - Reference Guide Generated on Sat Sep 29 2018 23:44:15 (GVA Time) using Doxygen 1.8.13.