 |
ROOT
6.07/01
Reference Guide
|
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
|
ROOT
6.07/01
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... | |
| void | cd (Int_t id=-1) |
| Set session with 'id' the default one. More... | |
| Int_t | Ping () |
| Ping PROOF. Returns 1 if master server responded. More... | |
| void | Touch () |
| Ping PROOF slaves. Returns the number of slaves that responded. 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... | |
| TString | Getenv (const char *env, const char *ord="0") |
| Get value of environment variable 'env' on node 'ord'. 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... | |
| 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... | |
| 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... | |
| 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... | |
| Int_t | CleanupSession (const char *sessiontag) |
| Send cleanup request for the session specified by tag. 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... | |
| 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... | |
| 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... | |
| void | DisableGoAsyn () |
| Signal to disable related switches. More... | |
| void | GoAsynchronous () |
| Send GOASYNC message to the master. More... | |
| void | StopProcess (Bool_t abort, Int_t timeout=-1) |
| Send STOPPROCESS message to master and workers. More... | |
| void | Browse (TBrowser *b) |
| Build the PROOF's structure in the browser. 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 | SetParallel (Int_t nodes=-1, Bool_t random=kFALSE) |
| Tell PROOF how many slaves to use in parallel. More... | |
| void | SetLogLevel (Int_t level, UInt_t mask=TProofDebug::kAll) |
| Set server logging level. More... | |
| void | Close (Option_t *option="") |
| Close all open slave servers. More... | |
| virtual void | Print (Option_t *option="") const |
| Print status of PROOF cluster. More... | |
| virtual void | ShowCache (Bool_t all=kFALSE) |
| List contents of file cache. More... | |
| virtual void | ClearCache (const char *file=0) |
| Remove file from all file caches. More... | |
| TList * | GetListOfPackages () |
| Get from the master the list of names of the packages available. More... | |
| TList * | GetListOfEnabledPackages () |
| Get from the master the list of names of the packages enabled. More... | |
| void | ShowPackages (Bool_t all=kFALSE, Bool_t redirlog=kFALSE) |
| List contents of package directory. More... | |
| void | ShowEnabledPackages (Bool_t all=kFALSE) |
| List which packages are enabled. More... | |
| Int_t | ClearPackages () |
| Remove all packages. More... | |
| Int_t | ClearPackage (const char *package) |
| Remove a specific package. More... | |
| Int_t | DownloadPackage (const char *par, const char *dstdir=0) |
| Download a PROOF archive (PAR file) from the master package repository. 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 | UploadPackage (const char *par, EUploadPackageOpt opt=kUntar, TList *workers=0) |
| Upload a PROOF archive (PAR file). More... | |
| 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... | |
| 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... | |
| 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... | |
| Int_t | RemoveDynamicPath (const char *libpath, Bool_t onClient=kFALSE) |
| Remove 'libpath' from the lib path search. More... | |
| Int_t | RemoveIncludePath (const char *incpath, Bool_t onClient=kFALSE) |
| Remove 'incpath' from the inc path search. 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... | |
| 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... | |
| virtual TMap * | GetDataSets (const char *uri="", const char *optStr="") |
| Lists all datasets that match given uri. More... | |
| virtual void | ShowDataSets (const char *uri="", const char *optStr="") |
| Shows datasets in locations that match the uri. More... | |
| TMap * | GetDataSetQuota (const char *optStr="") |
| returns a map of the quotas of all groups 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 Bool_t | ExistsDataSet (const char *dataset) |
| Returns kTRUE if 'dataset' exists, kFALSE otherwise. More... | |
| void | ShowDataSet (const char *dataset="", const char *opt="filter:SsCc") |
| display meta-info for given dataset usi More... | |
| virtual Int_t | RemoveDataSet (const char *dataset, const char *optStr="") |
| Remove the specified dataset from the PROOF cluster. More... | |
| virtual Int_t | VerifyDataSet (const char *dataset, const char *optStr="") |
| Verify if all files in the specified dataset are available. More... | |
| virtual TFileCollection * | GetDataSet (const char *dataset, const char *optStr="") |
| Get a list of TFileInfo objects describing the files of the specified dataset. More... | |
| TList * | FindDataSets (const char *searchString, const char *optStr="") |
| Find datasets, returns in a TList all found datasets. More... | |
| virtual Bool_t | RequestStagingDataSet (const char *dataset) |
| Allows users to request staging of a particular dataset. More... | |
| virtual TFileCollection * | GetStagingStatusDataSet (const char *dataset) |
| Obtains a TFileCollection showing the staging status of the specified dataset. More... | |
| virtual void | ShowStagingStatusDataSet (const char *dataset, const char *optStr="filter:SsCc") |
| Like GetStagingStatusDataSet, but displays results immediately. More... | |
| virtual Bool_t | CancelStagingDataSet (const char *dataset) |
| Cancels a dataset staging request. More... | |
| virtual Int_t | SetDataSetTreeName (const char *dataset, const char *treename) |
| Set/Change the name of the default tree. More... | |
| virtual void | ShowDataSetCache (const char *dataset=0) |
| Display the content of the dataset cache, if any (matching 'dataset', if defined). More... | |
| virtual void | ClearDataSetCache (const char *dataset=0) |
| Clear the content of the dataset cache, if any (matching 'dataset', if defined). More... | |
| virtual void | ShowData () |
| List contents of the data directory in the sandbox. More... | |
| void | ClearData (UInt_t what=kUnregistered, const char *dsname=0) |
| Remove files for the data directory. More... | |
| const char * | GetMaster () const |
| const char * | GetConfDir () const |
| const char * | GetConfFile () const |
| const char * | GetUser () const |
| const char * | GetGroup () const |
| const char * | GetWorkDir () const |
| const char * | GetSessionTag () const |
| const char * | GetImage () const |
| const char * | GetUrl () |
| Int_t | GetPort () const |
| Int_t | GetRemoteProtocol () const |
| Int_t | GetClientProtocol () const |
| Int_t | GetStatus () const |
| Int_t | GetLogLevel () const |
| Int_t | GetParallel () const |
| Returns number of slaves active in parallel mode. More... | |
| Int_t | GetSeqNum () const |
| Int_t | GetSessionID () const |
| TList * | GetListOfSlaveInfos () |
| Returns list of TSlaveInfo's. In case of error return 0. More... | |
| Bool_t | UseDynamicStartup () const |
| EQueryMode | GetQueryMode (Option_t *mode=0) const |
| Find out the query mode based on the current setting and 'mode'. 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... | |
| void | GetStatistics (Bool_t verbose=kFALSE) |
| Get statistics about CPU time, real time and bytes read. More... | |
| Long64_t | GetBytesRead () const |
| Float_t | GetRealTime () const |
| Float_t | GetCpuTime () const |
| Bool_t | IsLite () const |
| Bool_t | IsProofd () const |
| Bool_t | IsFolder () const |
| Returns kTRUE in case object contains browsable objects (like containers or lists of other objects). More... | |
| Bool_t | IsMaster () const |
| Bool_t | IsValid () const |
| Bool_t | IsTty () const |
| Bool_t | IsParallel () const |
| Bool_t | IsIdle () const |
| Bool_t | IsWaiting () const |
| ERunStatus | GetRunStatus () const |
| TList * | GetLoadedMacros () const |
| 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... | |
| TObject * | GetParameter (const char *par) const |
| Get specified parameter. More... | |
| void | DeleteParameters (const char *wildcard) |
| Delete the input list parameters specified by a wildcard (e.g. More... | |
| void | ShowParameters (const char *wildcard="PROOF_*") const |
| Show the input list parameters specified by the wildcard. More... | |
| void | AddInput (TObject *obj) |
| Add objects that might be needed during the processing of the selector (see Process()). More... | |
| void | ClearInput () |
| Clear input object list. More... | |
| TList * | GetInputList () |
| Get input list. 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... | |
| 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... | |
| 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... | |
| void | AddInputData (TObject *obj, Bool_t push=kFALSE) |
| Add data objects that might be needed during the processing of the selector (see Process()). More... | |
| void | SetInputDataFile (const char *datafile) |
| Set the file to be used to optimally distribute the input data objects. 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... | |
| void | AddFeedback (const char *name) |
| Add object to feedback list. More... | |
| void | RemoveFeedback (const char *name) |
| Remove object from feedback list. More... | |
| void | ClearFeedback () |
| Clear feedback list. More... | |
| void | ShowFeedback () const |
| Show items in feedback list. More... | |
| TList * | GetFeedbackList () const |
| Return feedback list. More... | |
| virtual TList * | GetListOfQueries (Option_t *opt="") |
| Ask the master for the list of queries. More... | |
| Int_t | GetNumberOfQueries () |
| Number of queries processed by this session. More... | |
| Int_t | GetNumberOfDrawQueries () |
| TList * | GetQueryResults () |
| Return pointer to the list of query results in the player. More... | |
| TQueryResult * | GetQueryResult (const char *ref=0) |
| Return pointer to the full TQueryResult instance owned by the player and referenced by 'ref'. More... | |
| void | GetMaxQueries () |
| Get max number of queries whose full results are kept in the remote sandbox. More... | |
| void | SetMaxDrawQueries (Int_t max) |
| Set max number of draw queries whose results are saved. More... | |
| void | ShowQueries (Option_t *opt="") |
| Ask the master for the list of queries. More... | |
| Bool_t | IsDataReady (Long64_t &totalbytes, Long64_t &bytesready) |
| See if the data is ready to be analyzed. More... | |
| void | SetActive (Bool_t=kTRUE) |
| void | LogMessage (const char *msg, Bool_t all) |
| Log a message into the appropriate window by emitting a signal. 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 | Feedback (TList *objs) |
| Get list of feedback objects. More... | |
| void | QueryResultReady (const char *ref) |
| Notify availability of a query result. More... | |
| void | CloseProgressDialog () |
| Close progress dialog. More... | |
| void | ResetProgressDialog (const char *sel, Int_t sz, Long64_t fst, Long64_t ent) |
| Reset progress dialog. More... | |
| void | StartupMessage (const char *msg, Bool_t status, Int_t done, Int_t total) |
| Send startup message. More... | |
| void | DataSetStatus (const char *msg, Bool_t status, Int_t done, Int_t total) |
| Send dataset preparation status. More... | |
| void | SendDataSetStatus (const char *msg, UInt_t n, UInt_t tot, Bool_t st) |
| Send or notify data set status. More... | |
| void | GetLog (Int_t start=-1, Int_t end=-1) |
| Ask for remote logs in the range [start, end]. More... | |
| TMacro * | GetLastLog () |
| Fill a TMacro with the log lines since the last reading (fLogFileR) Return (TMacro *)0 if no line was logged. More... | |
| void | PutLog (TQueryResult *qr) |
| Display log of query pq into the log window frame. 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... | |
| Bool_t | SendingLogToWindow () const |
| void | SendLogToWindow (Bool_t mode) |
| TMacro * | GetMacroLog () |
| void | ResetProgressDialogStatus () |
| virtual TTree * | GetTreeHeader (TDSet *tdset) |
| Creates a tree header (a tree with nonexisting files) object for the DataSet. More... | |
| TList * | GetOutputNames () |
| FIXME: to be written. More... | |
| void | AddChain (TChain *chain) |
| Add chain to data set. More... | |
| void | RemoveChain (TChain *chain) |
| Remove chain from data set. More... | |
| TDrawFeedback * | CreateDrawFeedback () |
| Draw feedback creation proxy. More... | |
| void | SetDrawFeedbackOption (TDrawFeedback *f, Option_t *opt) |
| Set draw feedback option. More... | |
| void | DeleteDrawFeedback (TDrawFeedback *f) |
| Delete draw feedback object. More... | |
| void | Detach (Option_t *opt="") |
| Detach this instance to its proofserv. More... | |
| virtual void | SetAlias (const char *alias="") |
| Set an alias for this session. More... | |
| TProofMgr * | GetManager () |
| void | SetManager (TProofMgr *mgr) |
| Set manager and schedule its destruction after this for clean operations. 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... | |
| 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... | |
| const char * | GetDataPoolUrl () const |
| void | SetDataPoolUrl (const char *url) |
| void | SetPrintProgress (PrintProgress_t pp) |
| void | SetProgressDialog (Bool_t on=kTRUE) |
| Enable/Disable the graphic progress dialog. More... | |
| Int_t | SavePerfTree (const char *pf=0, const char *qref=0) |
| Save performance information from TPerfStats to file 'pf'. More... | |
| void | SetPerfTree (const char *pf="perftree.root", Bool_t withWrks=kFALSE) |
| Enable/Disable saving of the performance tree. 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 & | operator= (const TNamed &rhs) |
| TNamed assignment operator. More... | |
| virtual | ~TNamed () |
| 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 | SetName (const char *name) |
| Change (i.e. More... | |
| virtual void | SetNameTitle (const char *name, const char *title) |
| Change (i.e. set) all the TNamed parameters (name and title). More... | |
| virtual void | SetTitle (const char *title="") |
| Change (i.e. set) the title of the TNamed. More... | |
| virtual void | ls (Option_t *option="") const |
| List TNamed name and title. More... | |
| virtual Int_t | Sizeof () const |
| Return size of the TNamed part of the TObject. More... | |
| Public Member Functions inherited from TObject | |
| TObject () | |
| TObject (const TObject &object) | |
| TObject copy ctor. More... | |
| TObject & | operator= (const TObject &rhs) |
| TObject assignment operator. More... | |
| virtual | ~TObject () |
| TObject destructor. More... | |
| virtual void | AppendPad (Option_t *option="") |
| Append graphics object to current pad. 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 pad. More... | |
| virtual void | Dump () const |
| Dump contents of object on stdout. 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 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 UInt_t | GetUniqueID () const |
| Return the unique object id. More... | |
| virtual const char * | GetIconName () const |
| Returns mime type name of object. More... | |
| virtual Option_t * | GetOption () const |
| virtual char * | GetObjectInfo (Int_t px, Int_t py) const |
| Returns string containing info about the object at position (px,py). More... | |
| virtual Bool_t | HandleTimer (TTimer *timer) |
| Execute action in response of a timer timing out. 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... | |
| virtual Bool_t | IsEqual (const TObject *obj) const |
| Default equal comparison (objects are equal if they have the same address in memory). More... | |
| Bool_t | IsOnHeap () const |
| Bool_t | IsZombie () const |
| virtual Bool_t | Notify () |
| This method must be overridden to handle object notification. 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... | |
| 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... | |
| 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 | UseCurrentStyle () |
| Set current style settings in this object This function is called when either TCanvas::UseCurrentStyle or TROOT::ForceStyle have been invoked. 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... | |
| void * | operator new (size_t sz) |
| void * | operator new[] (size_t sz) |
| void * | operator new (size_t sz, void *vp) |
| void * | operator new[] (size_t sz, void *vp) |
| void | operator delete (void *ptr) |
| Operator delete. More... | |
| void | operator delete[] (void *ptr) |
| Operator delete []. 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) |
| void | ResetBit (UInt_t f) |
| Bool_t | TestBit (UInt_t f) const |
| Int_t | TestBits (UInt_t f) const |
| void | InvertBit (UInt_t f) |
| virtual void | Info (const char *method, const char *msgfmt,...) const |
| Issue info message. More... | |
| virtual void | Warning (const char *method, const char *msgfmt,...) const |
| Issue warning message. More... | |
| virtual void | Error (const char *method, const char *msgfmt,...) const |
| Issue error message. More... | |
| virtual void | SysError (const char *method, const char *msgfmt,...) const |
| Issue system error message. More... | |
| virtual void | Fatal (const char *method, const char *msgfmt,...) const |
| Issue fatal error message. 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... | |
| 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... | |
| void | Obsolete (const char *method, const char *asOfVers, const char *removedFromVers) const |
| Use this method to declare a method obsolete. More... | |
| Public Member Functions inherited from TQObject | |
| TQObject () | |
| TQObject Constructor. More... | |
| virtual | ~TQObject () |
| TQObject Destructor. More... | |
| TList * | GetListOfClassSignals () const |
| Returns pointer to list of signals of this class. More... | |
| TList * | GetListOfSignals () const |
| TList * | GetListOfConnections () const |
| Bool_t | AreSignalsBlocked () const |
| Bool_t | BlockSignals (Bool_t b) |
| void | CollectClassSignalLists (TList &list, TClass *cls) |
| Collect class signal lists from class cls and all its base-classes. More... | |
| template<typename... T> | |
| void | EmitVA (const char *signal_name, Int_t, const T &...params) |
| void | EmitVA (const char *signal, Int_t nargs, va_list va)=delete |
| void | Emit (const char *signal) |
| Acitvate signal without args. More... | |
| void | Emit (const char *signal, Long_t *paramArr) |
| Emit a signal with a varying number of arguments, paramArr is an array of the parameters. More... | |
| void | Emit (const char *signal, const char *params) |
| Activate signal with parameter text string. More... | |
| void | Emit (const char *signal, Double_t param) |
| Activate signal with single parameter. More... | |
| void | Emit (const char *signal, Long_t param) |
| Activate signal with single parameter. More... | |
| void | Emit (const char *signal, Long64_t param) |
| Activate signal with single parameter. More... | |
| void | Emit (const char *signal, Bool_t param) |
| void | Emit (const char *signal, Char_t param) |
| void | Emit (const char *signal, UChar_t param) |
| void | Emit (const char *signal, Short_t param) |
| void | Emit (const char *signal, UShort_t param) |
| void | Emit (const char *signal, Int_t param) |
| void | Emit (const char *signal, UInt_t param) |
| void | Emit (const char *signal, ULong_t param) |
| void | Emit (const char *signal, ULong64_t param) |
| void | Emit (const char *signal, Float_t param) |
| 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... | |
| 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 | HighPriority (const char *signal_name, const char *slot_name=0) |
| virtual void | LowPriority (const char *signal_name, const char *slot_name=0) |
| virtual Bool_t | HasConnection (const char *signal_name) const |
| Return true if there is any object connected to this signal. More... | |
| virtual Int_t | NumberOfSignals () const |
| Return number of signals for this object. More... | |
| virtual Int_t | NumberOfConnections () const |
| Return number of connections for this object. More... | |
| virtual void | Connected (const char *) |
| virtual void | Disconnected (const char *) |
| virtual void | Destroyed () |
| virtual void | ChangedBy (const char *method) |
| virtual void | Message (const char *msg) |
Static Public Member Functions | |
| static TObject * | GetOutput (const char *name, TList *out) |
| Find object 'name' in list 'out' or in the files specified in there. 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 | 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 void | Reset (const char *url, Bool_t hard=kFALSE) |
| Wrapper around TProofMgr::Reset(...). More... | |
| 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 void | ResetEnvVars () |
| Clear the list of environment variables passed to proofserv on the master and slaves. 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 Public Member Functions inherited from TObject | |
| static Long_t | GetDtorOnly () |
| Return destructor only flag. More... | |
| static void | SetDtorOnly (void *obj) |
| Set destructor only flag. More... | |
| static Bool_t | GetObjectStat () |
| Get status of object stat 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 | 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... | |
| 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... | |
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... | |
| void | InitMembers () |
| Default initializations. 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... | |
| virtual Bool_t | StartSlaves (Bool_t attach=kFALSE) |
| Start up PROOF slaves. More... | |
| Int_t | AddWorkers (TList *wrks) |
| Works on the master node only. More... | |
| Int_t | RemoveWorkers (TList *wrks) |
| Used for shuting down the workres after a query is finished. More... | |
| void | SetupWorkersEnv (TList *wrks, Bool_t increasingpool=kFALSE) |
| Set up packages, loaded macros, include and lib paths ... More... | |
| void | SetPlayer (TVirtualProofPlayer *player) |
| Set a new PROOF player. More... | |
| TVirtualProofPlayer * | GetPlayer () const |
| virtual TVirtualProofPlayer * | MakePlayer (const char *player=0, TSocket *s=0) |
| Construct a TProofPlayer object. More... | |
| void | UpdateDialog () |
| Final update of the progress dialog. More... | |
| void | HandleLibIncPath (const char *what, Bool_t add, const char *dirs) |
| Handle lib, inc search paths modification request. More... | |
| TList * | GetListOfActiveSlaves () const |
| 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... | |
| virtual Int_t | PollForNewWorkers () |
| Asks the PROOF Serv for new workers in Dynamic Startup mode and activates them. More... | |
| virtual void | SaveWorkerInfo () |
| Save information about the worker set in the file .workers in the working dir. 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... | |
| TList * | GetEnabledPackages () const |
| void | SetDSet (TDSet *dset) |
| 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... | |
| TPluginHandler * | GetProgressDialog () const |
| 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 | 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 | 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... | |
| 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... | |
| 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... | |
| void | SetFeedback (TString &opt, TString &optfb, Int_t action) |
| Extract from opt in optfb information about wanted feedback settings. More... | |
| Int_t | HandleOutputOptions (TString &opt, TString &target, Int_t action) |
| Extract from opt information about output handling settings. More... | |
| Protected Member Functions inherited from TObject | |
| void | MakeZombie () |
| virtual void | DoError (int level, const char *location, const char *fmt, va_list va) const |
| Interface to ErrorHandler (protected). More... | |
| Protected Member Functions inherited from TQObject | |
| virtual void * | GetSender () |
| virtual const char * | GetSenderClassName () const |
Static Protected Member Functions | |
| static void * | SlaveStartupThread (void *arg) |
| 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 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 Bool_t | GetFileInCmd (const char *cmd, TString &fn) |
| Static method to extract the filename (if any) form a CINT command. More... | |
| 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 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... | |
| 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) |
Protected Attributes | |
| Bool_t | fMasterServ |
| TUrl | fUrl |
| TString | fConfFile |
| TString | fConfDir |
| TString | fImage |
| Int_t | fProtocol |
| TList * | fSlaves |
| TList * | fTerminatedSlaveInfos |
| TList * | fBadSlaves |
| TMonitor * | fAllMonitor |
| Bool_t | fDataReady |
| Long64_t | fBytesReady |
| Long64_t | fTotalBytes |
| TList * | fAvailablePackages |
| TList * | fEnabledPackages |
| TList * | fRunningDSets |
| Int_t | fCollectTimeout |
| TString | fDataPoolUrl |
| TProofMgr::EServType | fServType |
| TProofMgr * | fManager |
| EQueryMode | fQueryMode |
| Bool_t | fDynamicStartup |
| TSelector * | fSelector |
| TStopwatch | fQuerySTW |
| Float_t | fPrepTime |
| Protected Attributes inherited from TNamed | |
| TString | fName |
| TString | fTitle |
| Protected Attributes inherited from TQObject | |
| TList * | fListOfSignals |
| TList * | fListOfConnections |
| list of signals from this object More... | |
| Bool_t | fSignalsBlocked |
| list of connections to this object More... | |
Private Member Functions | |
| TProof (const TProof &) | |
| void | operator= (const TProof &) |
| void | CleanGDirectory (TList *ol) |
| Remove links to objects in list 'ol' from gDirectory. 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... | |
| 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... | |
| 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... | |
| Int_t | SendObject (const TObject *obj, ESlaves list=kActive) |
| Send object to master or 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 | SendPrint (Option_t *option="") |
| Send print command to master server. More... | |
| Int_t | Ping (ESlaves list) |
| Ping PROOF slaves. Returns the number of slaves that responded. More... | |
| void | Interrupt (EUrgent type, ESlaves list=kActive) |
| Send interrupt to master or slave servers. More... | |
| void | AskStatistics () |
| Ask the for the statistics of the slaves. More... | |
| void | AskParallel () |
| Ask the for the number of parallel slaves. 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 | GoMoreParallel (Int_t nWorkersToAdd) |
| Add nWorkersToAdd workers to current list of workers. More... | |
| Int_t | SetParallelSilent (Int_t nodes, Bool_t random=kFALSE) |
| Tell PROOF how many slaves to use in parallel. More... | |
| void | RecvLogFile (TSocket *s, Int_t size) |
| Receive the log file of the slave with socket s. More... | |
| void | NotifyLogMsg (const char *msg, const char *sfx="\n") |
| Notify locally 'msg' to the appropriate units (file, stdout, window) If defined, 'sfx' is added after 'msg' (typically a line-feed);. More... | |
| Int_t | BuildPackage (const char *package, EBuildPackageOpt opt=kBuildAll, Int_t chkveropt=kCheckROOT, TList *workers=0) |
| Build specified package. More... | |
| Int_t | BuildPackageOnClient (const char *package, Int_t opt=0, TString *path=0, Int_t chkveropt=kCheckROOT) |
| Build specified package on the client. More... | |
| Int_t | LoadPackage (const char *package, Bool_t notOnClient=kFALSE, TList *loadopts=0, TList *workers=0) |
| Load specified package. More... | |
| Int_t | LoadPackageOnClient (const char *package, TList *loadopts=0) |
| Load specified package in the client. More... | |
| Int_t | UnloadPackage (const char *package) |
| Unload specified package. More... | |
| Int_t | UnloadPackageOnClient (const char *package) |
| Unload a specific package on the client. More... | |
| Int_t | UnloadPackages () |
| Unload all packages. More... | |
| Int_t | UploadPackageOnClient (const char *package, EUploadPackageOpt opt, TMD5 *md5) |
| Upload a package on the client in ~/.proof/packages. More... | |
| Int_t | DisablePackage (const char *package) |
| Remove a specific package. More... | |
| Int_t | DisablePackageOnClient (const char *package) |
| Remove a specific package 'pack' from the client. More... | |
| Int_t | DisablePackages () |
| Remove all packages. More... | |
| void | Activate (TList *slaves=0) |
| Activate slave server list. 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 | 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... | |
| 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 | SetMonitor (TMonitor *mon=0, Bool_t on=kTRUE) |
| Activate (on == TRUE) or deactivate (on == FALSE) all sockets monitored by 'mon'. More... | |
| void | ReleaseMonitor (TMonitor *mon) |
| Release the used monitor to be used, making sure to delete newly created monitors. More... | |
| virtual void | FindUniqueSlaves () |
| Add to the fUniqueSlave list the active slaves that have a unique (user) file system image. More... | |
| TSlave * | FindSlave (TSocket *s) const |
| Find slave that has TSocket s. Returns 0 in case slave is not found. More... | |
| TList * | GetListOfSlaves () const |
| TList * | GetListOfInactiveSlaves () const |
| TList * | GetListOfUniqueSlaves () const |
| TList * | GetListOfBadSlaves () const |
| Int_t | GetNumberOfSlaves () const |
| Return number of slaves as described in the config file. More... | |
| Int_t | GetNumberOfActiveSlaves () const |
| Return number of active slaves, i.e. More... | |
| Int_t | GetNumberOfInactiveSlaves () const |
| Return number of inactive slaves, i.e. More... | |
| Int_t | GetNumberOfUniqueSlaves () const |
| Return number of unique slaves, i.e. More... | |
| Int_t | GetNumberOfBadSlaves () const |
| Return number of bad slaves. More... | |
| Bool_t | IsEndMaster () const |
| 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... | |
| Int_t | RestoreActiveList () |
| Restore saved list of active workers. More... | |
| void | SaveActiveList () |
| Save current list of active workers. More... | |
| Bool_t | IsSync () const |
| void | InterruptCurrentMonitor () |
| If in active in a monitor set ready state. More... | |
| void | SetRunStatus (ERunStatus rst) |
| 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... | |
| 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... | |
| void | ActivateAsyncInput () |
| Activate the a-sync input handler. More... | |
| void | DeActivateAsyncInput () |
| De-activate a-sync input handler. More... | |
| Int_t | GetQueryReference (Int_t qry, TString &ref) |
| Get reference for the qry-th query in fQueries (as displayed by ShowQueries). 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 | CreateMerger (TSlave *sl, Int_t port) |
| Create a new merger. More... | |
| void | RedirectWorker (TSocket *s, TSlave *sl, Int_t output_size) |
| Redirect output of worker sl to some merger. More... | |
| Int_t | GetActiveMergersCount () |
| Get the active mergers count. More... | |
| Int_t | FindNextFreeMerger () |
| Return a merger, which is both active and still accepts some workers to be assigned to it. More... | |
| void | ResetMergers () |
| void | AskForOutput (TSlave *sl) |
| Master asks for output from worker sl. More... | |
| void | FinalizationDone () |
| void | ResetMergePrg () |
| Reset the merge progress notificator. More... | |
| void | ParseConfigField (const char *config) |
| The config file field may contain special instructions which need to be parsed at the beginning, e.g. 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 | ClearDataProgress (Int_t r, Int_t t) |
| Progress bar for clear data. More... | |
Static Private Member Functions | |
| static TList * | GetDataSetSrvMaps (const TString &srvmaps) |
Static Private Attributes | |
| static TList * | fgProofEnvList = 0 |
| static TPluginHandler * | fgLogViewer = 0 |
Friends | |
| class | TPacketizer |
| class | TPacketizerDev |
| class | TPacketizerAdaptive |
| class | TProofLite |
| class | TDataSetManager |
| class | TProofServ |
| class | TProofInputHandler |
| class | TProofInterruptHandler |
| class | TProofPlayer |
| class | TProofPlayerLite |
| class | TProofPlayerRemote |
| class | TProofProgressDialog |
| class | TSlave |
| class | TSlaveLite |
| class | TVirtualPacketizer |
| class | TXSlave |
| class | TXSocket |
| class | TXSocketHandler |
| class | TXProofMgr |
| class | TXProofServ |
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 |
|
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 509 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 383 of file TProof.cxx.
|
virtual |
Clean up PROOF environment.
Definition at line 650 of file TProof.cxx.
Activate slave server list.
Definition at line 2396 of file TProof.cxx.
Referenced by HandleInputMessage(), TProofPlayerLite::Process(), and TProofPlayerRemote::Process().
|
private |
Activate the a-sync input handler.
Definition at line 4411 of file TProof.cxx.
Referenced by Collect(), TProofLite::Init(), and Init().
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 11931 of file TProof.cxx.
Referenced by TProofNodes::ActivateWorkers(), Exec(), TProofServ::HandleWorkerLists(), and RestoreActiveList().
Add chain to data set.
Definition at line 10801 of file TProof.cxx.
Referenced by TProofChain::TProofChain().
| 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 9421 of file TProof.cxx.
Referenced by TProofServ::HandleLibIncPath(), and SetupWorkersEnv().
|
static |
Add an variable to the list of environment variables passed to proofserv on the master and slaves.
Definition at line 12338 of file TProof.cxx.
Referenced by TXSlave::Init(), InitMembers(), ParseConfigField(), TProofServ::SetupCommon(), and VerifyDataSet().
| void TProof::AddFeedback | ( | const char * | name | ) |
Add object to feedback list.
Definition at line 10567 of file TProof.cxx.
Referenced by TProofPlayerRemote::DrawSelect(), TSessionServerFrame::OnBtnConnectClicked(), TSessionQueryFrame::OnBtnSubmit(), TSessionViewer::OnCascadeMenu(), and SetFeedback().
| 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 9466 of file TProof.cxx.
Referenced by TProofServ::HandleLibIncPath(), Load(), and SetupWorkersEnv().
Add objects that might be needed during the processing of the selector (see Process()).
Definition at line 10312 of file TProof.cxx.
Referenced by TProofChain::AddAliases(), TDSet::AddInput(), ClearInput(), TProofBenchDataSet::Handle(), TProofLite::Init(), Init(), TProofBench::MakeDataSet(), Process(), TProofLite::SendInputDataFile(), SendInputDataFile(), TProofBenchRunCPU::SetParameters(), and TProofBenchRunDataRead::SetParameters().
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 10100 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 1333 of file TProof.cxx.
Referenced by TProofServ::HandleProcess(), TProofServ::HandleSocketInput(), PollForNewWorkers(), and StartSlaves().
Send archive request for the qry-th query in fQueries.
Definition at line 6055 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 6075 of file TProof.cxx.
Master asks for output from worker sl.
Definition at line 4335 of file TProof.cxx.
Referenced by HandleSubmerger(), and RedirectWorker().
|
private |
Ask the for the number of parallel slaves.
Definition at line 2084 of file TProof.cxx.
Referenced by TProofLite::Init(), Init(), and TProofServ::SendParallel().
|
private |
Ask the for the statistics of the slaves.
Definition at line 2029 of file TProof.cxx.
Referenced by GetStatistics(), GoMoreParallel(), GoParallel(), Print(), TProofLite::Process(), TProofServ::ProcessNext(), and TProofLite::SetQueryRunning().
|
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 12593 of file TProof.cxx.
Referenced by TProofServ::HandleProcess(), and TProofLite::Process().
Make sure that 'path' exists; if 'writable' is kTRUE, make also sure that the path is writable.
Definition at line 1282 of file TProof.cxx.
Referenced by TProofLite::CreateSandbox(), GetSandbox(), and Init().
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 2482 of file TProof.cxx.
Referenced by AddDynamicPath(), AddIncludePath(), Archive(), AskParallel(), AskStatistics(), Broadcast(), BroadcastObject(), BuildPackage(), CancelStagingDataSet(), CleanupSession(), ClearCache(), ClearDataSetCache(), DisablePackage(), DisablePackages(), Echo(), ExistsDataSet(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetListOfEnabledPackages(), GetListOfPackages(), GetListOfQueries(), GetLog(), GetMaxQueries(), GetStagingStatusDataSet(), GoAsynchronous(), IsDataReady(), TProofPlayerRemote::JoinProcess(), Load(), LoadPackage(), ModifyWorkerLists(), TProofLite::PollForNewWorkers(), TProofPlayerLite::Process(), TProofPlayerRemote::Process(), RegisterDataSet(), Remove(), RemoveDataSet(), RemoveDynamicPath(), RemoveIncludePath(), RequestStagingDataSet(), Retrieve(), SendCommand(), SendCurrentState(), SendObject(), SendPrint(), SetDataSetTreeName(), SetLogLevel(), SetParallelSilent(), SetRealTimeLog(), TProofLite::SetupWorkers(), ShowCache(), ShowDataSetCache(), ShowDataSetQuota(), ShowDataSets(), ShowEnabledPackages(), ShowPackages(), TerminateWorker(), UnloadPackage(), UnloadPackages(), and VerifyDataSet().
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 2509 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 2525 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 2538 of file TProof.cxx.
Definition at line 671 of file TProof.h.
Referenced by Broadcast().
Definition at line 672 of file TProof.h.
Referenced by Broadcast().
|
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.
Referenced by BroadcastFile(), SendInputData(), and SendInputDataFile().
|
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 2646 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 2458 of file TProof.cxx.
Referenced by TXProofServ::HandleInput().
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 2431 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 2550 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 2562 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 2574 of file TProof.cxx.
Referenced by BroadcastRaw().
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 2601 of file TProof.cxx.
Build the PROOF's structure in the browser.
Reimplemented from TObject.
Definition at line 10757 of file TProof.cxx.
Referenced by TSessionViewer::MyHandleMenu().
|
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 8044 of file TProof.cxx.
Referenced by EnablePackage(), and TProofServ::HandleCache().
|
private |
Build specified package on the client.
Executes the PROOF-INF/BUILD.sh script if it exists on the client. If opt == 0, both the preparation and building phases are run. If opt == 1, only the preparation phase (asserting and, eventually, downloading of the package) is done; '*path' contains the full path to the package to be passed in the next call If opt == 2, only the building phase is run using *path . Returns 0 in case of success and -1 in case of error. The code is equivalent to the one in TProofServ.cxx (TProof::kBuildPackage case). Keep in sync in case of changes.
Definition at line 8134 of file TProof.cxx.
Referenced by BuildPackage().
|
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 11624 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 11074 of file TProof.cxx.
Referenced by TSessionQueryFrame::OnBtnSubmit(), and TSessionViewer::OnListTreeClicked().
|
private |
Check if a file needs to be send to the slave.
Use the following algorithm:
Definition at line 6797 of file TProof.cxx.
Referenced by SendFile().
Remove links to objects in list 'ol' from gDirectory.
Definition at line 3047 of file TProof.cxx.
Referenced by HandleInputMessage().
| Int_t TProof::CleanupSession | ( | const char * | sessiontag | ) |
Send cleanup request for the session specified by tag.
Definition at line 6090 of file TProof.cxx.
Referenced by TSessionViewer::CleanupSession().
|
virtual |
Remove file from all file caches.
If file is 0 or "" or "*", remove all the files
Reimplemented in TProofLite.
Definition at line 7712 of file TProof.cxx.
Referenced by TProofServ::HandleCache().
| 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 7410 of file TProof.cxx.
|
virtual |
Clear the content of the dataset cache, if any (matching 'dataset', if defined).
Reimplemented in TProofLite.
Definition at line 11474 of file TProof.cxx.
Referenced by DataSetCache().
| void TProof::ClearFeedback | ( | ) |
Clear feedback list.
Definition at line 10590 of file TProof.cxx.
Referenced by TSessionServerFrame::OnBtnConnectClicked(), TSessionQueryFrame::OnBtnSubmit(), and TSessionViewer::OnCascadeMenu().
| void TProof::ClearInput | ( | ) |
Clear input object list.
Definition at line 10320 of file TProof.cxx.
Referenced by TDSet::ClearInput().
Remove obj form the input data list; if obj is null (default), clear the input data info.
Definition at line 10116 of file TProof.cxx.
Referenced by ClearInputData().
| void TProof::ClearInputData | ( | const char * | name | ) |
Remove obj 'name' form the input data list;.
Definition at line 10150 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 7873 of file TProof.cxx.
Referenced by TProofServ::HandleCache(), and TSessionFrame::OnDisablePackages().
| Int_t TProof::ClearPackages | ( | ) |
Remove all packages.
Returns 0 in case of success and -1 in case of error.
Definition at line 7856 of file TProof.cxx.
Referenced by TProofServ::HandleCache(), and TSessionFrame::OnClearPackages().
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 1805 of file TProof.cxx.
Referenced by Detach(), TXProofMgr::DetachSession(), TXProofServ::HandleError(), TXProofServ::HandleTermination(), TProofBench::TProofBench(), VerifyDataSet(), and ~TProof().
| void TProof::CloseProgressDialog | ( | ) |
|
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 2676 of file TProof.cxx.
Referenced by AddDynamicPath(), AddIncludePath(), Archive(), AskParallel(), AskStatistics(), BuildPackage(), CancelStagingDataSet(), CheckFile(), CleanupSession(), ClearCache(), ClearDataSetCache(), Collect(), Detach(), DisablePackage(), DisablePackages(), ExistsDataSet(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetListOfEnabledPackages(), GetListOfPackages(), GetListOfQueries(), GetListOfSlaveInfos(), GetLog(), GetMaxQueries(), GetStagingStatusDataSet(), GetTreeHeader(), GoParallel(), TXProofServ::HandleTermination(), TSlave::Interrupt(), IsDataReady(), Load(), LoadPackage(), ModifyWorkerLists(), TProofLite::PollForNewWorkers(), Print(), TProofPlayerLite::Process(), TProofPlayerRemote::Process(), RegisterDataSet(), Remove(), RemoveDataSet(), RemoveDynamicPath(), RemoveIncludePath(), RequestStagingDataSet(), Retrieve(), SendCommand(), SendFile(), SendPrint(), SetDataSetTreeName(), SetParallelSilent(), TProofLite::SetupWorkers(), ShowCache(), ShowDataSetCache(), ShowDataSetQuota(), ShowDataSets(), ShowEnabledPackages(), ShowPackages(), TProofSuperMaster::StartSlaves(), StartSlaves(), UnloadPackage(), UnloadPackages(), UploadPackage(), TProofSuperMaster::ValidateDSet(), ValidateDSet(), and VerifyDataSet().
|
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 2763 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 2734 of file TProof.cxx.
Referenced by ClassImp().
|
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 2703 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 3061 of file TProof.cxx.
Referenced by Collect(), TXSlave::HandleInput(), and TProofInputHandler::Notify().
| TDrawFeedback * TProof::CreateDrawFeedback | ( | ) |
Draw feedback creation proxy.
When accessed via TProof avoids link dependency on libProofPlayer.
Definition at line 10672 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 1860 of file TProof.cxx.
Referenced by AddWorkers(), TProofLite::PollForNewWorkers(), TProofLite::SetupWorkers(), and TProofCondor::StartSlaves().
|
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 1882 of file TProof.cxx.
Referenced by AddWorkers(), TProofSuperMaster::StartSlaves(), and StartSlaves().
Send dataset preparation status.
Definition at line 9902 of file TProof.cxx.
Referenced by HandleInputMessage().
|
private |
De-activate a-sync input handler.
Definition at line 4424 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 11948 of file TProof.cxx.
Referenced by TProofNodes::ActivateWorkers(), Exec(), HandleInputMessage(), TProofServ::HandleWorkerLists(), and RestoreActiveList().
|
static |
Remove an variable from the list of environment variables passed to proofserv on the master and slaves.
Definition at line 12360 of file TProof.cxx.
Referenced by TXSlave::Init(), InitMembers(), and ParseConfigField().
| void TProof::DeleteDrawFeedback | ( | TDrawFeedback * | f | ) |
Delete draw feedback object.
Definition at line 10688 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 10511 of file TProof.cxx.
Referenced by TProofBenchRunCPU::DeleteParameters(), TProofBenchRunDataRead::DeleteParameters(), TProofBenchDataSet::Handle(), HandleOutputOptions(), TProofBench::MakeDataSet(), SetFeedback(), SetPerfTree(), and VerifyDataSetParallel().
Detach this instance to its proofserv.
If opt is 'S' or 's' the remote server is shutdown
Definition at line 11096 of file TProof.cxx.
Referenced by TProofMgr::DetachSession(), TSessionFrame::OnBtnDisconnectClicked(), TSessionFrame::ShutdownSession(), and TSessionViewer::Terminate().
| void TProof::DisableGoAsyn | ( | ) |
Signal to disable related switches.
Definition at line 6257 of file TProof.cxx.
Referenced by HandleInputMessage().
|
private |
Remove a specific package.
Returns 0 in case of success and -1 in case of error.
Definition at line 7901 of file TProof.cxx.
Referenced by ClearPackage(), and TProofServ::HandleCache().
|
private |
Remove a specific package 'pack' from the client.
Returns 0 in case of success and -1 in case of error.
Definition at line 7958 of file TProof.cxx.
Referenced by DisablePackage().
|
private |
Remove all packages.
Returns 0 in case of success and -1 in case of error.
Definition at line 7993 of file TProof.cxx.
Referenced by ClearPackages(), and TProofServ::HandleCache().
| 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 8802 of file TProof.cxx.
Referenced by BuildPackageOnClient().
|
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 6144 of file TProof.cxx.
Referenced by TDSet::Draw(), and DrawSelect().
| 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 6180 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 7026 of file TProof.cxx.
Referenced by Echo(), and TProofServ::HandleSocketInput().
|
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 7040 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 8643 of file TProof.cxx.
Referenced by EnablePackage(), TProofBenchDataSet::Handle(), TProofBench::MakeDataSet(), TSessionServerFrame::OnBtnConnectClicked(), TSessionFrame::OnEnablePackages(), TProofBenchRunCPU::Run(), TProofBenchRunDataRead::Run(), and SetupWorkersEnv().
| 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 8665 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 8728 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 6531 of file TProof.cxx.
Referenced by Exec(), Getenv(), GetRC(), HandleOutputOptions(), TSessionFrame::OnCommandLine(), and TProof().
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 6519 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 6587 of file TProof.cxx.
|
virtual |
Returns kTRUE if 'dataset' exists, kFALSE otherwise.
Reimplemented in TProofLite.
Definition at line 11446 of file TProof.cxx.
Referenced by ClearData(), TProofBench::CopyDataSet(), ExistsDataSet(), TProofBenchRunDataRead::GetDataSet(), TProofBenchDataSet::Handle(), and TProofBenchRunDataRead::Run().
Get list of feedback objects.
Connect a slot to this signal to monitor the feedback object.
Definition at line 9846 of file TProof.cxx.
Referenced by TProofPlayerRemote::Feedback().
|
inlineprivate |
Definition at line 732 of file TProof.h.
Referenced by TProofPlayerRemote::Finalize().
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 5881 of file TProof.cxx.
Referenced by TProofPlayerLite::Finalize(), TProofPlayerRemote::Finalize(), and TSessionQueryFrame::OnBtnFinalize().
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 5906 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 11588 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 4305 of file TProof.cxx.
Referenced by RedirectWorker().
Find slave that has TSocket s. Returns 0 in case slave is not found.
Definition at line 1898 of file TProof.cxx.
Referenced by Collect(), CollectInputFrom(), and MarkBad().
|
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 1919 of file TProof.cxx.
Referenced by GoMoreParallel(), GoParallel(), MarkBad(), and ModifyWorkerLists().
|
private |
Get the active mergers count.
Definition at line 4437 of file TProof.cxx.
Referenced by HandleSubmerger().
|
inline |
Definition at line 965 of file TProof.h.
Referenced by TQueryResultManager::FinalizeQuery(), GetStatistics(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TProofServ::SendStatistics(), TProofLite::SetQueryRunning(), and TProofServ::SetQueryRunning().
|
inline |
Definition at line 950 of file TProof.h.
Referenced by TProofNodes::ActivateWorkers(), TProofLite::Print(), Print(), and TSessionFrame::ProofInfos().
|
inline |
Definition at line 940 of file TProof.h.
Referenced by TProofCondor::GetJobAd(), Print(), and TSessionFrame::ProofInfos().
|
inline |
Definition at line 941 of file TProof.h.
Referenced by TSessionServerFrame::OnBtnConnectClicked(), Print(), TSessionFrame::ProofInfos(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
|
inline |
Definition at line 967 of file TProof.h.
Referenced by TQueryResultManager::FinalizeQuery(), GetStatistics(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TProofServ::SendStatistics(), TProofLite::SetQueryRunning(), and TProofServ::SetQueryRunning().
|
inline |
|
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 11515 of file TProof.cxx.
Referenced by ClearData(), TProofBench::CopyDataSet(), GetDataSet(), TProofBenchRunDataRead::GetDataSet(), TProofBenchDataSet::Handle(), HandleOutputOptions(), TProofBench::MakeDataSet(), ShowDataSet(), TSessionFrame::UpdateListOfDataSets(), and VerifyDataSet().
| TMap * TProof::GetDataSetQuota | ( | const char * | optStr = "" | ) |
returns a map of the quotas of all groups
Definition at line 11854 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 11387 of file TProof.cxx.
Referenced by ClearData(), and GetDataSets().
|
inlineprotected |
Definition at line 773 of file TProof.h.
Referenced by SetupWorkersEnv().
| TString TProof::Getenv | ( | const char * | env, |
| const char * | ord = "0" |
||
| ) |
Get value of environment variable 'env' on node 'ord'.
Definition at line 6642 of file TProof.cxx.
|
static |
Get environemnt variables.
Definition at line 12329 of file TProof.cxx.
Referenced by AddWorkers(), TXSlave::Init(), TSlave::Init(), Init(), ParseConfigField(), TProofLite::ResolveKeywords(), and TProofBench::TProofBench().
| TList * TProof::GetFeedbackList | ( | ) | const |
Return feedback list.
Definition at line 10611 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 6493 of file TProof.cxx.
Referenced by Exec(), and TProofServ::HandleSocketInput().
|
inline |
Definition at line 943 of file TProof.h.
Referenced by ClearData(), TProofServ::ResolveKeywords(), and TProofMgr::UploadFiles().
|
inline |
Definition at line 946 of file TProof.h.
Referenced by Print(), and TSessionFrame::ProofInfos().
Get the input data from the file defined in the input list.
Definition at line 12992 of file TProof.cxx.
Referenced by TProofServ::HandleProcess().
| TList * TProof::GetInputList | ( | ) |
Get input list.
Definition at line 10331 of file TProof.cxx.
Referenced by TProofChain::AddAliases(), ClearInputData(), TProofBenchRunCPU::DeleteParameters(), TProofBenchRunDataRead::DeleteParameters(), TProofBenchDataSet::Handle(), TProofBench::MakeDataSet(), PrepareInputDataFile(), TProofPlayerLite::Process(), TProofPlayerRemote::Process(), Process(), and VerifyDataSetParallel().
| 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 10835 of file TProof.cxx.
Referenced by DownloadPackage(), and GetStatistics().
|
inlineprotected |
Definition at line 761 of file TProof.h.
Referenced by ClassImp(), GetListOfSlaveInfos(), GetParallel(), GetTreeHeader(), HandleInputMessage(), TProofServ::HandleSocketInput(), TProofServ::HandleWorkerLists(), TProofPlayerRemote::InitPacketizer(), IsDataReady(), TProofSuperMaster::ValidateDSet(), and ValidateDSet().
|
inlineprivate |
Definition at line 695 of file TProof.h.
Referenced by GetListOfSlaveInfos(), HandleInputMessage(), and TProofServ::HandleWorkerLists().
| TList * TProof::GetListOfEnabledPackages | ( | ) |
Get from the master the list of names of the packages enabled.
Definition at line 9702 of file TProof.cxx.
Referenced by TSessionViewer::UpdateListOfPackages().
|
inlineprivate |
Definition at line 693 of file TProof.h.
Referenced by TProofServ::HandleSocketInput().
| TList * TProof::GetListOfPackages | ( | ) |
Get from the master the list of names of the packages available.
Definition at line 9686 of file TProof.cxx.
Referenced by TSessionViewer::UpdateListOfPackages().
Ask the master for the list of queries.
Reimplemented in TProofLite.
Definition at line 2095 of file TProof.cxx.
Referenced by GetQueryReference(), TSessionFrame::OnBtnGetQueriesClicked(), ShowLog(), and ShowQueries().
| TList * TProof::GetListOfSlaveInfos | ( | ) |
Returns list of TSlaveInfo's. In case of error return 0.
Definition at line 2328 of file TProof.cxx.
Referenced by TProofNodes::Build(), TProofServ::HandleSocketInput(), TProofLite::ShowData(), and TPerfStats::TPerfStats().
|
inlineprivate |
Definition at line 692 of file TProof.h.
Referenced by GetListOfSlaveInfos(), and TProofServ::HandleWorkerLists().
|
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 10818 of file TProof.cxx.
|
inline |
Definition at line 952 of file TProof.h.
Referenced by TProofCondor::GetJobAd(), TXSlave::Init(), TSessionServerFrame::OnBtnConnectClicked(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
|
inline |
Definition at line 1073 of file TProof.h.
Referenced by cd(), Detach(), and TXSlave::Init().
|
inline |
Definition at line 939 of file TProof.h.
Referenced by TProofBenchRunDataRead::GetDataSet(), TProofBenchDataSet::Handle(), TSessionServerFrame::OnBtnConnectClicked(), Print(), TProofProgressDialog::Progress(), TSessionQueryFrame::Progress(), TSessionFrame::ProofInfos(), TProofProgressDialog::ResetProgressDialog(), TSessionQueryFrame::ResetProgressDialog(), TProofBench::SetOutFile(), TSessionLogView::SetTitle(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
| void TProof::GetMaxQueries | ( | ) |
Get max number of queries whose full results are kept in the remote sandbox.
Definition at line 2135 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 13160 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 1994 of file TProof.cxx.
Referenced by HandleSubmerger(), MarkBad(), TProofLite::Print(), Print(), SendGroupView(), and SendInitialState().
|
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 2021 of file TProof.cxx.
Referenced by TProofLite::Print(), and Print().
|
private |
Return number of inactive slaves, i.e.
slaves that are valid but not in the current computing group.
Definition at line 2003 of file TProof.cxx.
Referenced by TProofLite::Print(), and Print().
| Int_t TProof::GetNumberOfQueries | ( | ) |
Number of queries processed by this session.
Definition at line 2112 of file TProof.cxx.
Referenced by ShowQueries().
|
private |
Return number of slaves as described in the config file.
Definition at line 1985 of file TProof.cxx.
Referenced by TProofLite::Print(), and Print().
|
private |
Return number of unique slaves, i.e.
active slaves that have each a unique different user files system.
Definition at line 2012 of file TProof.cxx.
Referenced by Exec(), TProofLite::Print(), and Print().
| TObject * TProof::GetOutput | ( | const char * | name | ) |
Get specified object that has been produced during the processing (see Process()).
Definition at line 10340 of file TProof.cxx.
Referenced by TDSet::GetOutput(), HandleInputMessage(), and MarkBad().
Find object 'name' in list 'out' or in the files specified in there.
Definition at line 10354 of file TProof.cxx.
| TList * TProof::GetOutputList | ( | ) |
Get list with all object created during processing (see Process()).
Definition at line 10386 of file TProof.cxx.
Referenced by GetOutput(), TDSet::GetOutputList(), HandleOutputOptions(), TProofServ::HandleSocketInput(), TProofBench::MakeDataSet(), TProofBenchRunCPU::Run(), TProofBenchRunDataRead::Run(), SavePerfTree(), and VerifyDataSetParallel().
| TList * TProof::GetOutputNames | ( | ) |
FIXME: to be written.
Definition at line 10696 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 2311 of file TProof.cxx.
Referenced by TProofMgrLite::CreateSession(), GetStatistics(), GoMoreParallel(), GoParallel(), TProofServ::HandleSocketInput(), IsParallel(), TProofLite::Print(), Print(), TProofPlayerLite::Process(), TProofPlayerRemote::Process(), TProofProgressDialog::Progress(), TSessionQueryFrame::Progress(), TSessionFrame::ProofInfos(), TProofProgressDialog::ResetProgressDialog(), TSessionQueryFrame::ResetProgressDialog(), SendCurrentState(), TProofServ::SendLogFile(), TProofServ::SendParallel(), SetParallelSilent(), TProofLite::SetQueryRunning(), TProofServ::SetQueryRunning(), TProofBench::TProofBench(), and VerifyDataSet().
| 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 10496 of file TProof.cxx.
Referenced by AssertDataSet(), ClassImp(), Collect(), TPacketizerMulti::CreatePacketizer(), TProofDraw::FillWeight(), TProofBenchDataSet::Handle(), TProofServ::HandleProcess(), HandleSubmerger(), TProofPlayerRemote::InitPacketizer(), TProofBench::MakeDataSet(), MarkBad(), TProofPlayerLite::Process(), TProofPlayer::Process(), TProofPlayerRemote::Process(), TProofDraw::SetDrawAtt(), TProofPlayerLite::SetupFeedback(), TProofPlayerRemote::SetupFeedback(), TProofPlayerSuperMaster::SetupFeedback(), TPerfStats::TPerfStats(), and VerifyDataSetParallel().
|
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 12501 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 12520 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 12538 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 12556 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 12574 of file TProof.cxx.
|
inlineprotected |
Definition at line 754 of file TProof.h.
Referenced by TProofServ::HandleSocketInput(), TVirtualPacketizer::HandleTimer(), TProofSuperMaster::MakePlayer(), MakePlayer(), and TProofSuperMaster::Process().
|
inline |
Definition at line 948 of file TProof.h.
Referenced by TSessionServerFrame::OnBtnConnectClicked(), Print(), TSessionFrame::ProofInfos(), TProof(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
|
inlineprotected |
Definition at line 780 of file TProof.h.
Referenced by TProofSuperMaster::Process().
| TProof::EQueryMode TProof::GetQueryMode | ( | Option_t * | mode = 0 | ) | const |
Find out the query mode based on the current setting and 'mode'.
Definition at line 6117 of file TProof.cxx.
Referenced by TProofPlayerLite::Process(), TProofLite::Process(), TProofPlayerRemote::Process(), and Process().
Get reference for the qry-th query in fQueries (as displayed by ShowQueries).
Definition at line 5855 of file TProof.cxx.
Referenced by Archive(), Finalize(), Remove(), and Retrieve().
| 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 2155 of file TProof.cxx.
Referenced by Finalize(), GetMissingFiles(), TPerfStats::PacketEvent(), TProofLite::Process(), Process(), TSessionViewer::QueryResultReady(), TProofBenchRunCPU::Run(), TProofBenchRunDataRead::Run(), ShowMissingFiles(), and TPerfStats::WriteQueryLog().
| TList * TProof::GetQueryResults | ( | ) |
Return pointer to the list of query results in the player.
Definition at line 2146 of file TProof.cxx.
Referenced by ShowLog().
Get into 'env' the value of integer RC env variable 'rcenv' on node 'ord'.
Definition at line 6663 of file TProof.cxx.
Referenced by Init().
Get into 'env' the value of double RC env variable 'rcenv' on node 'ord'.
Definition at line 6689 of file TProof.cxx.
Get into 'env' the value of string RC env variable 'rcenv' on node 'ord'.
Definition at line 6715 of file TProof.cxx.
|
inline |
Definition at line 966 of file TProof.h.
Referenced by GetStatistics(), TProofLite::Print(), Print(), and TSessionFrame::ProofInfos().
|
inline |
Definition at line 949 of file TProof.h.
Referenced by TProofNodes::ActivateWorkers(), AddWorkers(), GoAsynchronous(), HandleInputMessage(), Init(), Load(), Print(), TSessionFrame::ProofInfos(), TProofProgressDialog::ResetProgressDialog(), and UpdateDialog().
|
inline |
Definition at line 979 of file TProof.h.
Referenced by TProofPlayerRemote::InitPacketizer(), and TDSet::Lookup().
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 1033 of file TProof.cxx.
Referenced by TProofLite::CreateSandbox(), Init(), and TProofLite::SetProofServEnv().
|
inline |
Definition at line 954 of file TProof.h.
Referenced by TSessionQueryFrame::OnBtnSubmit().
|
inline |
Definition at line 955 of file TProof.h.
Referenced by TProofMgrLite::CreateSession(), TProofMgr::CreateSession(), and TProofMgr::QuerySessions().
|
inline |
Definition at line 945 of file TProof.h.
Referenced by ClassImp(), TStatsFeedback::Feedback(), TSessionQueryFrame::OnBtnSubmit(), Print(), TSessionFrame::ProofInfos(), TProofMgr::QuerySessions(), TProofServ::ResolveKeywords(), and SetFeedback().
|
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 11651 of file TProof.cxx.
Referenced by ShowStagingStatusDataSet().
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 2042 of file TProof.cxx.
|
inline |
Definition at line 951 of file TProof.h.
Referenced by TSessionViewer::ShowStatus().
Creates a tree header (a tree with nonexisting files) object for the DataSet.
Reimplemented in TProofLite.
Definition at line 10620 of file TProof.cxx.
Referenced by TDSet::GetTreeHeader(), and TProofChain::TProofChain().
|
inline |
Definition at line 947 of file TProof.h.
Referenced by TProofMgrLite::CreateSession(), TProofMgr::CreateSession(), HandleOutputOptions(), and TProofMgr::QuerySessions().
|
inline |
Definition at line 942 of file TProof.h.
Referenced by ClearData(), TSessionServerFrame::OnBtnConnectClicked(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TProofServ::ResolveKeywords(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
| void TProof::GoAsynchronous | ( | ) |
Send GOASYNC message to the master.
Definition at line 6265 of file TProof.cxx.
Referenced by TProofProgressDialog::DoAsyn().
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 7168 of file TProof.cxx.
Referenced by AddWorkers().
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 7271 of file TProof.cxx.
Referenced by AddWorkers(), TProofLite::Init(), Init(), and SetParallelSilent().
|
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 3106 of file TProof.cxx.
Referenced by CollectInputFrom().
Handle lib, inc search paths modification request.
Definition at line 9576 of file TProof.cxx.
Referenced by AddDynamicPath(), AddIncludePath(), RemoveDynamicPath(), and RemoveIncludePath().
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 4938 of file TProof.cxx.
Referenced by TProofLite::Process(), and Process().
Process a message of type kPROOF_SUBMERGER.
Definition at line 4015 of file TProof.cxx.
Referenced by HandleInputMessage().
|
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 747 of file TProof.cxx.
Referenced by TProof().
|
protected |
Send interrupt to master or slave servers.
Definition at line 2283 of file TProof.cxx.
Referenced by TProofServ::HandleSigPipe(), TXProofServ::HandleUrgentData(), TProofServ::HandleUrgentData(), and SendFile().
|
private |
If in active in a monitor set ready state.
Definition at line 11913 of file TProof.cxx.
Referenced by TXProofMgr::HandleError(), TXProofServ::HandleTermination(), and StopProcess().
See if the data is ready to be analyzed.
Definition at line 2247 of file TProof.cxx.
Referenced by TProofServ::HandleSocketInput().
|
inlineprivate |
Definition at line 702 of file TProof.h.
Referenced by TXProofServ::CreateServer(), TProofServ::CreateServer(), HandleSubmerger(), and ModifyWorkerLists().
|
inlinevirtual |
|
inline |
Definition at line 976 of file TProof.h.
Referenced by TXProofMgr::AttachSession(), Collect(), TProofMgrLite::CreateSession(), TProofMgr::CreateSession(), Detach(), TProofLite::DrawSelect(), DrawSelect(), GoAsynchronous(), GoMoreParallel(), Init(), TProofLite::Load(), LoadPackage(), NotifyLogMsg(), TProofLite::Process(), Process(), TProofMgr::QuerySessions(), and RecvLogFile().
|
inline |
Definition at line 969 of file TProof.h.
Referenced by TDSet::Add(), TProofPlayerRemote::AddOutputObject(), AskForOutput(), BuildPackage(), ClassImp(), TProofMgrLite::CreateSession(), DisablePackage(), DisablePackages(), Exec(), GetDataSetQuota(), GetListOfSlaveInfos(), GoMoreParallel(), HandleInputMessage(), HandleOutputOptions(), HandleSubmerger(), TProofPlayerRemote::Incorporate(), TProofPlayerRemote::JoinProcess(), Load(), TProofPlayerRemote::MergeOutput(), TProofPlayerRemote::MergeOutputFiles(), TProofPlayerRemote::NotifyMemory(), TSessionServerFrame::OnBtnConnectClicked(), TSessionQueryFrame::OnBtnSubmit(), ParseConfigField(), TProofPlayerRemote::Process(), Process(), RedirectWorker(), Remove(), SendDataSetStatus(), TProofPlayerRemote::SetMerging(), TProofBench::SetOutFile(), ShowDataSetQuota(), ShowEnabledPackages(), ShowPackages(), TPerfStats::TPerfStats(), TProofChain::TProofChain(), UnloadPackage(), UnloadPackages(), TSessionViewer::UpdateListOfProofs(), TSessionViewer::UpdateListOfSessions(), and UploadPackage().
|
inline |
Definition at line 972 of file TProof.h.
Referenced by AddWorkers(), ClassImp(), TSlave::Close(), Collect(), TSlave::Create(), TProofPlayerRemote::Finalize(), GoMoreParallel(), TXSlave::HandleError(), TXSlave::Init(), TSlave::Init(), Init(), TSlave::Interrupt(), TProofPlayerRemote::JoinProcess(), LoadPackage(), MarkBad(), TProofPlayerLite::Process(), TProofPlayerRemote::Process(), TSessionFrame::ProofInfos(), RemoveWorkers(), TerminateWorker(), and TXSlave::TXSlave().
|
inline |
Definition at line 975 of file TProof.h.
Referenced by TProofPlayerLite::Finalize(), TProofPlayerRemote::Finalize(), TProofServ::IsParallel(), TProofLite::Print(), Print(), TProofPlayerLite::Process(), TSessionFrame::ProofInfos(), TSessionFrame::UpdateListOfDataSets(), TSessionViewer::UpdateListOfPackages(), and VerifyDataSet().
|
inline |
Definition at line 970 of file TProof.h.
Referenced by Close(), TSlave::Create(), SetAlias(), and TProof().
|
inlineprivate |
Definition at line 707 of file TProof.h.
Referenced by Collect(), TProofPlayerRemote::Process(), and TProofProgressDialog::ResetProgressDialog().
|
inline |
Definition at line 974 of file TProof.h.
Referenced by ClearData(), and HandleInputMessage().
|
inline |
Definition at line 973 of file TProof.h.
Referenced by AskParallel(), AskStatistics(), TXProofMgr::AttachSession(), Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), TProofNodes::Build(), TSessionQueryFrame::Build(), BuildPackage(), TSessionViewer::CleanupSession(), TProofLite::ClearCache(), ClearCache(), ClearData(), ClearPackage(), ClearPackages(), TXProofServ::CreateServer(), TProofServ::CreateServer(), TProofMgrLite::CreateSession(), TProofMgr::CreateSession(), TSessionViewer::DeleteQuery(), Detach(), DisablePackage(), DisablePackages(), TProofLite::DrawSelect(), DrawSelect(), Echo(), EnablePackage(), Exec(), GetListOfEnabledPackages(), GetListOfPackages(), GetListOfQueries(), GetListOfSlaveInfos(), GetLog(), GetParallel(), getProof(), GoAsynchronous(), GoMoreParallel(), GoParallel(), TSessionQueryFrame::IndicateStop(), TProofLite::Init(), Init(), Interrupt(), IsDataReady(), TProofLite::Load(), Load(), LoadPackage(), MarkBad(), TSessionQueryFrame::Modified(), TSessionViewer::MyHandleMenu(), TSessionFrame::OnApplyLogLevel(), TSessionFrame::OnApplyParallel(), TSessionQueryFrame::OnBtnAbort(), TSessionServerFrame::OnBtnConnectClicked(), TSessionFrame::OnBtnDisconnectClicked(), TSessionQueryFrame::OnBtnFinalize(), TSessionFrame::OnBtnGetQueriesClicked(), TSessionFrame::OnBtnRemoveDSet(), TSessionQueryFrame::OnBtnRetrieve(), TEditQueryFrame::OnBtnSave(), TSessionQueryFrame::OnBtnStop(), TSessionQueryFrame::OnBtnSubmit(), TSessionFrame::OnBtnVerifyDSet(), TSessionViewer::OnCascadeMenu(), TSessionFrame::OnClearPackages(), TSessionFrame::OnCommandLine(), TSessionFrame::OnDisablePackages(), TSessionFrame::OnEnablePackages(), TSessionViewer::OnListTreeClicked(), TSessionFrame::OnUploadPackages(), Print(), TProofSuperMaster::Process(), TProofLite::Process(), Process(), TSessionFrame::ProofInfos(), TSessionQueryFrame::ResetProgressDialog(), TSessionViewer::ResetSession(), SavePerfTree(), SendCommand(), SendCurrentState(), SendFile(), SendGroupView(), SendInitialState(), SendInputData(), SendObject(), SendPrint(), SetAlias(), SetParallelSilent(), TProofBench::SetProofDS(), SetRealTimeLog(), TProofLite::ShowCache(), ShowCache(), TProofLite::ShowData(), ShowData(), TSessionViewer::ShowEnabledPackages(), ShowEnabledPackages(), TSessionViewer::ShowPackages(), ShowPackages(), ShowQueries(), TSessionViewer::ShowStatus(), TSessionFrame::ShutdownSession(), StopProcess(), TSessionViewer::Terminate(), TProofBench::TProofBench(), TUploadDataSetDlg::TUploadDataSetDlg(), UnloadPackage(), UnloadPackages(), TSessionQueryFrame::UpdateButtons(), TSessionQueryFrame::UpdateInfos(), TSessionFrame::UpdateListOfDataSets(), TSessionViewer::UpdateListOfPackages(), TUploadDataSetDlg::UploadDataSet(), UploadPackage(), and TProofProgressDialog::~TProofProgressDialog().
|
inline |
|
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 9209 of file TProof.cxx.
Referenced by TProofServ::HandleCache(), TProofLite::Load(), and SetupWorkersEnv().
|
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 8329 of file TProof.cxx.
Referenced by EnablePackage(), and TProofServ::HandleCache().
Load specified package in the client.
Executes the PROOF-INF/SETUP.C script on the client. Returns 0 in case of success and -1 in case of error. The code is equivalent to the one in TProofServ.cxx (TProof::kLoadPackage case). Keep in sync in case of changes. 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 8381 of file TProof.cxx.
Referenced by LoadPackage().
Log a message into the appropriate window by emitting a signal.
Definition at line 6412 of file TProof.cxx.
Referenced by ShowLog().
Start the log viewer window usign the plugin manager.
Definition at line 13049 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 10789 of file TProof.cxx.
Referenced by TProofLite::Init(), Init(), and TProofServ::MakePlayer().
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 4522 of file TProof.cxx.
Referenced by Broadcast(), BroadcastGroupPriority(), BroadcastRaw(), CollectInputFrom(), GetListOfSlaveInfos(), GoParallel(), HandleInputMessage(), MarkBad(), Ping(), SendFile(), SendGroupView(), and TerminateWorker().
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 4683 of file TProof.cxx.
|
static |
Get instance of the effective manager for 'url' Return 0 on failure.
Definition at line 12302 of file TProof.cxx.
Referenced by TProofProgressMemoryPlot::BuildLogList(), TProofProgressLog::BuildLogList(), TProofProgressLog::DoLog(), TProofProgressMemoryPlot::DoPlot(), Reset(), and TSessionViewer::ResetSession().
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 11967 of file TProof.cxx.
Referenced by ActivateWorker(), and DeactivateWorker().
|
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 6356 of file TProof.cxx.
Referenced by HandleInputMessage(), and SendDataSetStatus().
|
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 12161 of file TProof.cxx.
Referenced by getProof(), and TProofBench::TProofBench().
|
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 1060 of file TProof.cxx.
Referenced by Init().
Ping PROOF slaves. Returns the number of slaves that responded.
Definition at line 4753 of file TProof.cxx.
Referenced by TProofServ::HandleSocketInput(), and TXProofServ::HandleUrgentData().
| Int_t TProof::Ping | ( | ) |
Ping PROOF. Returns 1 if master server responded.
Definition at line 4745 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 2971 of file TProof.cxx.
Referenced by Collect().
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 10217 of file TProof.cxx.
Referenced by TProofLite::SendInputDataFile(), and SendInputDataFile().
Print status of PROOF cluster.
Reimplemented from TNamed.
Reimplemented in TProofLite.
Definition at line 4804 of file TProof.cxx.
Referenced by GetStatistics(), TProofBenchRunCPU::Print(), TProofBenchRunDataRead::Print(), and TProofServ::Print().
|
private |
Print a progress bar on stderr. Used in batch mode.
Definition at line 9718 of file TProof.cxx.
Referenced by Progress().
|
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 5304 of file TProof.cxx.
Referenced by TProofBenchDataSet::Handle(), TProofBench::MakeDataSet(), TProofSuperMaster::Process(), TProofLite::Process(), TDSet::Process(), Process(), TProofBenchRunCPU::Run(), TProofBenchRunDataRead::Run(), and VerifyDataSetParallel().
|
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 5410 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 5501 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 5719 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 5759 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 5785 of file TProof.cxx.
|
virtual |
Process with name of dataset and TSelector object.
Reimplemented in TProofLite, and TProofSuperMaster.
Definition at line 5807 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 5833 of file TProof.cxx.
Get query progress information.
Connect a slot to this signal to track progress.
Definition at line 9779 of file TProof.cxx.
Referenced by TProofPlayerRemote::Progress(), and UpdateDialog().
| 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 9802 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 9824 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 7647 of file TProof.cxx.
Referenced by ClearData().
| void TProof::PutLog | ( | TQueryResult * | qr | ) |
Display log of query pq into the log window frame.
Definition at line 10899 of file TProof.cxx.
Referenced by ShowLog().
| void TProof::QueryResultReady | ( | const char * | ref | ) |
Notify availability of a query result.
Definition at line 9947 of file TProof.cxx.
Referenced by HandleInputMessage(), and TProofLite::Process().
Receive the log file of the slave with socket s.
Definition at line 6285 of file TProof.cxx.
Referenced by HandleInputMessage().
Redirect output of worker sl to some merger.
Definition at line 4259 of file TProof.cxx.
Referenced by HandleSubmerger().
|
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 11285 of file TProof.cxx.
Referenced by TProofBench::CopyDataSet(), TProofBench::MakeDataSet(), RegisterDataSet(), and TProofBenchRunDataRead::Run().
Release the used monitor to be used, making sure to delete newly created monitors.
Definition at line 2661 of file TProof.cxx.
Referenced by Collect().
Send remove request for the qry-th query in fQueries.
Definition at line 6011 of file TProof.cxx.
Referenced by TSessionViewer::DeleteQuery(), and Detach().
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 6032 of file TProof.cxx.
Remove chain from data set.
Definition at line 10809 of file TProof.cxx.
Referenced by Close(), ~TProof(), and TProofChain::~TProofChain().
|
virtual |
Remove the specified dataset from the PROOF cluster.
Files are not deleted.
Reimplemented in TProofLite.
Definition at line 11569 of file TProof.cxx.
Referenced by ClearData(), TSessionFrame::OnBtnRemoveDSet(), RemoveDataSet(), TProofBenchDataSet::RemoveFiles(), and TProofBenchRunDataRead::Run().
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 9511 of file TProof.cxx.
Referenced by TProofServ::HandleLibIncPath().
| void TProof::RemoveFeedback | ( | const char * | name | ) |
Remove object from feedback list.
Definition at line 10578 of file TProof.cxx.
Referenced by TProofPlayerRemote::DrawSelect(), and SetFeedback().
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 9545 of file TProof.cxx.
Referenced by TProofServ::HandleLibIncPath().
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 1604 of file TProof.cxx.
Referenced by TProofServ::HandleSocketInput(), TProofLite::Process(), TProofServ::ProcessNext(), and TProofLite::~TProofLite().
|
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 11598 of file TProof.cxx.
Wrapper around TProofMgr::Reset(...).
Definition at line 12314 of file TProof.cxx.
|
static |
Clear the list of environment variables passed to proofserv on the master and slaves.
Definition at line 12374 of file TProof.cxx.
|
private |
Reset the merge progress notificator.
Definition at line 2472 of file TProof.cxx.
Referenced by TProofPlayerLite::Process(), and TProofPlayerRemote::Process().
|
inlineprivate |
Definition at line 729 of file TProof.h.
Referenced by TProofServ::HandleProcess().
Reset progress dialog.
Definition at line 9877 of file TProof.cxx.
Referenced by HandleInputMessage(), and TProofLite::Process().
|
inline |
Definition at line 1057 of file TProof.h.
Referenced by TProofProgressDialog::~TProofProgressDialog().
|
private |
Restore saved list of active workers.
Definition at line 12135 of file TProof.cxx.
Referenced by ModifyWorkerLists().
Send retrieve request for the qry-th query in fQueries.
If path is defined save it to path.
Definition at line 5946 of file TProof.cxx.
Referenced by Finalize(), TSessionQueryFrame::OnBtnRetrieve(), and ShowLog().
| 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 5965 of file TProof.cxx.
|
private |
Save current list of active workers.
Definition at line 12120 of file TProof.cxx.
Referenced by ModifyWorkerLists().
|
staticprotected |
Save input data file from 'cachedir' into the sandbox or create a the file with input data objects.
Definition at line 12890 of file TProof.cxx.
Referenced by TProofServ::HandleProcess().
| 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 13225 of file TProof.cxx.
Referenced by TProofLite::Process(), and Process().
|
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 12386 of file TProof.cxx.
Referenced by AddWorkers(), TXProofServ::CreateServer(), and MarkBad().
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 6629 of file TProof.cxx.
Referenced by Exec(), and TProofServ::HandleSocketInput().
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 6756 of file TProof.cxx.
Referenced by TProofLite::PollForNewWorkers(), TProofServ::Reset(), and SetParallelSilent().
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 6740 of file TProof.cxx.
Send or notify data set status.
Definition at line 9914 of file TProof.cxx.
Referenced by TDSet::Lookup(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().
|
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 6892 of file TProof.cxx.
Referenced by BroadcastFile(), Exec(), TProofServ::HandleSocketInput(), Load(), TProofPlayerRemote::SendSelector(), and UploadPackage().
|
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 6458 of file TProof.cxx.
Referenced by Collect(), GoMoreParallel(), GoParallel(), and TProofLite::SetupWorkers().
|
inline |
Definition at line 1052 of file TProof.h.
Referenced by TSessionViewer::ShowLog(), and ShowLog().
|
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 6772 of file TProof.cxx.
Referenced by TProofLite::Init(), and Init().
|
staticprotected |
Send the input data file to the workers.
Definition at line 12959 of file TProof.cxx.
Referenced by TProofPlayerRemote::Process().
|
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 10190 of file TProof.cxx.
Referenced by TProofPlayerLite::Process(), and TProofPlayerRemote::Process().
Definition at line 1053 of file TProof.h.
Referenced by TSessionViewer::ShowLog().
Send object to master or slave servers.
Returns number of slaves object was sent to, -1 in case of error.
Definition at line 7052 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 7066 of file TProof.cxx.
Referenced by Print().
Definition at line 1024 of file TProof.h.
Referenced by TProofServ::HandleSigPipe(), TProofServ::HandleSocketInput(), TXProofServ::HandleUrgentData(), TProofServ::HandleUrgentData(), TProofLite::Init(), Init(), and TProofCondor::SetActive().
|
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 11161 of file TProof.cxx.
Referenced by Init(), and TSessionServerFrame::OnBtnConnectClicked().
|
inline |
Definition at line 1080 of file TProof.h.
Referenced by TXSlave::ParseBuffer().
|
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 11344 of file TProof.cxx.
| void TProof::SetDrawFeedbackOption | ( | TDrawFeedback * | f, |
| Option_t * | opt | ||
| ) |
Set draw feedback option.
Definition at line 10680 of file TProof.cxx.
Definition at line 775 of file TProof.h.
Referenced by TProofSuperMaster::ValidateDSet(), and ValidateDSet().
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 5233 of file TProof.cxx.
Referenced by TProofLite::Process(), and Process().
| 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 10163 of file TProof.cxx.
| void TProof::SetLogLevel | ( | Int_t | level, |
| UInt_t | mask = TProofDebug::kAll |
||
| ) |
Set server logging level.
Definition at line 7077 of file TProof.cxx.
Referenced by getProof(), TProofServ::HandleSocketInput(), TSessionFrame::OnApplyLogLevel(), TSessionServerFrame::OnBtnConnectClicked(), and SendInitialState().
Set manager and schedule its destruction after this for clean operations.
Definition at line 1314 of file TProof.cxx.
Referenced by TXProofMgr::AttachSession().
Set max number of draw queries whose results are saved.
Definition at line 2122 of file TProof.cxx.
Activate (on == TRUE) or deactivate (on == FALSE) all sockets monitored by 'mon'.
Definition at line 2415 of file TProof.cxx.
Referenced by TXProofServ::Terminate().
Tell PROOF how many slaves to use in parallel.
Returns the number of parallel slaves. Returns -1 in case of error.
Definition at line 7138 of file TProof.cxx.
Referenced by TProofNodes::ActivateWorkers(), TProofServ::HandleSocketInput(), TSessionFrame::OnApplyParallel(), and TProofLite::SetupWorkers().
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 7110 of file TProof.cxx.
Referenced by SetParallel().
| 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 10400 of file TProof.cxx.
Referenced by TProofBenchDataSet::CopyFiles(), TProofChain::FillDrawAttributes(), TProofBenchDataSet::Handle(), HandleOutputOptions(), TProofBench::MakeDataSet(), TProofPlayerLite::Process(), TProofLite::Process(), TProofPlayerRemote::Process(), SetFeedback(), TProofBenchRunCPU::SetParameters(), TProofBenchRunDataRead::SetParameters(), SetPerfTree(), and VerifyDataSetParallel().
Set an input list parameter.
Definition at line 10419 of file TProof.cxx.
Set an input list parameter.
Definition at line 10438 of file TProof.cxx.
Set an input list parameter.
Definition at line 10457 of file TProof.cxx.
Set an input list parameter.
Definition at line 10476 of file TProof.cxx.
Enable/Disable saving of the performance tree.
Definition at line 13203 of file TProof.cxx.
Referenced by TProofLite::Process(), and Process().
|
protected |
Set a new PROOF player.
Definition at line 10777 of file TProof.cxx.
Referenced by TProofServ::DeletePlayer(), TProofSuperMaster::MakePlayer(), TProofServ::MakePlayer(), and MakePlayer().
|
inline |
Enable/Disable the graphic progress dialog.
By default the dialog is enabled
Definition at line 13088 of file TProof.cxx.
| void TProof::SetQueryMode | ( | EQueryMode | mode | ) |
Change query running mode to the one specified by 'mode'.
Definition at line 6105 of file TProof.cxx.
Referenced by TSessionServerFrame::OnBtnConnectClicked().
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 7094 of file TProof.cxx.
Referenced by TProofServ::HandleSocketInput().
|
inlineprivate |
Definition at line 710 of file TProof.h.
Referenced by TProofServ::HandleSocketInput(), TProofLite::Init(), TProofLite::Process(), Process(), and StopProcess().
Set up packages, loaded macros, include and lib paths ...
Definition at line 1541 of file TProof.cxx.
Referenced by AddWorkers(), and TProofLite::PollForNewWorkers().
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 7689 of file TProof.cxx.
Referenced by TProofServ::HandleCache().
|
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 7394 of file TProof.cxx.
Referenced by ClearData().
| void TProof::ShowDataSet | ( | const char * | dataset = "", |
| const char * | opt = "filter:SsCc" |
||
| ) |
display meta-info for given dataset usi
Definition at line 11555 of file TProof.cxx.
Referenced by TProofBenchRunDataRead::Run().
|
virtual |
Display the content of the dataset cache, if any (matching 'dataset', if defined).
Reimplemented in TProofLite.
Definition at line 11492 of file TProof.cxx.
Referenced by DataSetCache().
shows the quota and usage of all groups if opt contains "U" shows also distribution of usage on user-level
Definition at line 11887 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 11424 of file TProof.cxx.
Referenced by ShowDataSets().
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 7832 of file TProof.cxx.
Referenced by TProofServ::HandleCache(), and TSessionViewer::ShowEnabledPackages().
| void TProof::ShowFeedback | ( | ) | const |
Show items in feedback list.
Definition at line 10598 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 10949 of file TProof.cxx.
Referenced by TSessionViewer::ShowLog().
| void TProof::ShowLog | ( | const char * | queryref | ) |
Display on screen the content of the temporary log file for query in reference.
Definition at line 10916 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 13101 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 7768 of file TProof.cxx.
Referenced by DownloadPackage(), TProofServ::HandleCache(), and TSessionViewer::ShowPackages().
| 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 10536 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 2172 of file TProof.cxx.
|
virtual |
Like GetStagingStatusDataSet, but displays results immediately.
Definition at line 11694 of file TProof.cxx.
Start up PROOF slaves.
Reimplemented in TProofCondor, and TProofSuperMaster.
Definition at line 1667 of file TProof.cxx.
Referenced by Init().
Send startup message.
Definition at line 9890 of file TProof.cxx.
Referenced by HandleInputMessage(), and StartSlaves().
Send STOPPROCESS message to master and workers.
Definition at line 6222 of file TProof.cxx.
Referenced by Detach(), TProofProgressDialog::DoAbort(), TProofProgressDialog::DoStop(), TXProofServ::HandleInput(), TProofServ::HandleSocketInput(), TXProofServ::HandleTermination(), TSessionQueryFrame::OnBtnAbort(), TSessionQueryFrame::OnBtnStop(), and TProofChain::Progress().
Exec system command 'cmd'. If fdout > -1, append the output to fdout.
Definition at line 7733 of file TProof.cxx.
Referenced by ShowPackages().
Ask an active worker 'wrk' to terminate, i.e. to shutdown.
Definition at line 4697 of file TProof.cxx.
Referenced by TProofServ::HandleSocketInput(), RemoveWorkers(), and TerminateWorker().
|
private |
Ask an active worker 'ord' to terminate, i.e. to shutdown.
Definition at line 4721 of file TProof.cxx.
| void TProof::Touch | ( | ) |
Ping PROOF slaves. Returns the number of slaves that responded.
Definition at line 4783 of file TProof.cxx.
|
private |
Unload specified package.
Returns 0 in case of success and -1 in case of error.
Definition at line 8541 of file TProof.cxx.
Referenced by ClearPackage(), and TProofServ::HandleCache().
|
private |
Unload a specific package on the client.
Returns 0 in case of success and -1 in case of error. The code is equivalent to the one in TProofServ.cxx (TProof::UnloadPackage case). Keep in sync in case of changes.
Definition at line 8576 of file TProof.cxx.
Referenced by UnloadPackage(), and UnloadPackages().
|
private |
Unload all packages.
Returns 0 in case of success and -1 in case of error.
Definition at line 8611 of file TProof.cxx.
Referenced by ClearPackages(), and TProofServ::HandleCache().
|
protected |
Final update of the progress dialog.
Definition at line 4354 of file TProof.cxx.
Referenced by HandleInputMessage(), and TProofLite::Process().
*** 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 11213 of file TProof.cxx.
Referenced by TUploadDataSetDlg::UploadDataSet().
| 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 11244 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 11262 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 8909 of file TProof.cxx.
Referenced by TProofBenchDataSet::Handle(), TProofServ::HandleCache(), TProofServ::HandleCheckFile(), TProofBench::MakeDataSet(), TSessionFrame::OnEnablePackages(), TSessionFrame::OnUploadPackages(), TProofBenchRunCPU::Run(), TProofBenchRunDataRead::Run(), and SetupWorkersEnv().
|
private |
Upload a package on the client in ~/.proof/packages.
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), thereby triggering a full re-build. This option if effective only for PROOF protocol > 8. Returns 0 in case of success and -1 in case of error.
Definition at line 9082 of file TProof.cxx.
Referenced by BuildPackageOnClient(), and UploadPackage().
|
inline |
Definition at line 957 of file TProof.h.
Referenced by TProofServ::HandleProcess(), TProofServ::HandleSocketInput(), TProofServ::IsParallel(), TProofServ::ProcessNext(), and TProofBench::TProofBench().
Validate a TDSet.
Reimplemented in TProofSuperMaster.
Definition at line 9958 of file TProof.cxx.
Referenced by TProofServ::HandleSocketInput().
|
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 11708 of file TProof.cxx.
Referenced by HandleOutputOptions(), TSessionFrame::OnBtnVerifyDSet(), RegisterDataSet(), and VerifyDataSet().
|
protected |
Internal function for parallel dataset verification used TProof::VerifyDataSet and TProofLite::VerifyDataSet.
Definition at line 11759 of file TProof.cxx.
Referenced by TProofLite::VerifyDataSet(), and VerifyDataSet().
|
friend |
|
friend |
|
friend |
|
friend |
Definition at line 350 of file TProof.h.
Referenced by CreateSlave(), CreateSubmaster(), TProofLite::PollForNewWorkers(), and TProofLite::SetupWorkers().
|
friend |
Definition at line 351 of file TProof.h.
Referenced by StartSlaves().
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |
|
private |
Definition at line 515 of file TProof.h.
Referenced by Collect(), GoMoreParallel(), GoParallel(), TProofLite::Init(), Init(), InitMembers(), MarkBad(), ModifyWorkerLists(), TProofLite::PollForNewWorkers(), ReleaseMonitor(), and ~TProof().
|
private |
Definition at line 508 of file TProof.h.
Referenced by Activate(), AddWorkers(), Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), Browse(), Close(), CreateMerger(), TProofLite::CreateSymLinks(), Detach(), TProofLite::FindUniqueSlaves(), FindUniqueSlaves(), GetListOfActiveSlaves(), GetNumberOfActiveSlaves(), GoMoreParallel(), GoParallel(), TXProofServ::HandleUrgentData(), TProofLite::Init(), Init(), InitMembers(), Interrupt(), Load(), MarkBad(), ModifyWorkerLists(), Ping(), TProofLite::PollForNewWorkers(), Print(), ResetMergePrg(), SaveActiveList(), SendFile(), SendGroupView(), SetAlias(), TProofLite::SetupWorkers(), and ~TProof().
|
private |
Definition at line 509 of file TProof.h.
Referenced by RestoreActiveList(), and SaveActiveList().
|
protected |
Definition at line 609 of file TProof.h.
Referenced by Activate(), AddWorkers(), Collect(), TProofLite::Init(), Init(), InitMembers(), MarkBad(), TProofLite::PollForNewWorkers(), ReleaseMonitor(), TProofLite::SetupWorkers(), TProofSuperMaster::StartSlaves(), TProofCondor::StartSlaves(), StartSlaves(), and ~TProof().
|
private |
Definition at line 517 of file TProof.h.
Referenced by Collect(), TProofLite::FindUniqueSlaves(), FindUniqueSlaves(), TProofLite::Init(), Init(), InitMembers(), ReleaseMonitor(), and ~TProof().
|
private |
Definition at line 513 of file TProof.h.
Referenced by Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), Close(), TProofLite::FindUniqueSlaves(), FindUniqueSlaves(), TProofLite::Init(), Init(), InitMembers(), Interrupt(), MarkBad(), Ping(), and ~TProof().
|
protected |
Definition at line 613 of file TProof.h.
Referenced by GetListOfPackages(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), and ~TProof().
|
protected |
Definition at line 608 of file TProof.h.
Referenced by AddWorkers(), Close(), GetListOfBadSlaves(), GetNumberOfBadSlaves(), GoMoreParallel(), GoParallel(), TProofLite::Init(), Init(), InitMembers(), MarkBad(), TProofLite::PollForNewWorkers(), SaveWorkerInfo(), TProofLite::SetupWorkers(), TProofSuperMaster::StartSlaves(), TProofCondor::StartSlaves(), and ~TProof().
|
private |
Definition at line 519 of file TProof.h.
Referenced by Collect(), GetBytesRead(), GetStatistics(), HandleInputMessage(), Init(), and InitMembers().
|
protected |
Definition at line 611 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and IsDataReady().
|
private |
Definition at line 527 of file TProof.h.
Referenced by AddChain(), Browse(), Close(), TProofLite::Init(), Init(), InitMembers(), RemoveChain(), and ~TProof().
|
private |
Definition at line 502 of file TProof.h.
Referenced by CheckFile(), HandleInputMessage(), and UploadPackage().
|
private |
|
protected |
Definition at line 617 of file TProof.h.
Referenced by AddDynamicPath(), AddIncludePath(), Archive(), AskParallel(), AskStatistics(), CheckFile(), CleanupSession(), ClearDataSetCache(), ExistsDataSet(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetListOfEnabledPackages(), GetListOfPackages(), GetListOfQueries(), GetLog(), GetMaxQueries(), GetStagingStatusDataSet(), GetTreeHeader(), GoParallel(), TProofLite::Init(), Init(), InitMembers(), ModifyWorkerLists(), TProofLite::PollForNewWorkers(), Print(), Remove(), RemoveDataSet(), RemoveDynamicPath(), RemoveIncludePath(), Retrieve(), SendFile(), SendPrint(), SetParallelSilent(), ShowCache(), ShowDataSetCache(), ShowDataSets(), ShowEnabledPackages(), ShowPackages(), UploadPackage(), and VerifyDataSet().
|
protected |
Definition at line 603 of file TProof.h.
Referenced by GetConfDir(), TProofLite::Init(), Init(), and TProofCondor::StartSlaves().
|
protected |
Definition at line 602 of file TProof.h.
Referenced by GetConfFile(), TXSlave::Init(), TProofLite::Init(), Init(), TProofCondor::StartSlaves(), and StartSlaves().
|
private |
Definition at line 521 of file TProof.h.
Referenced by Collect(), GetCpuTime(), GetStatistics(), HandleInputMessage(), Init(), and InitMembers().
|
private |
Definition at line 518 of file TProof.h.
Referenced by Collect(), CollectInputFrom(), TXSlave::HandleInput(), HandleSubmerger(), TProofLite::Init(), Init(), InitMembers(), TXSlave::Interrupt(), InterruptCurrentMonitor(), MarkBad(), and SetMonitor().
|
protected |
|
protected |
Definition at line 610 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and IsDataReady().
|
private |
Definition at line 555 of file TProof.h.
Referenced by TProofLite::GetListOfQueries(), GetNumberOfDrawQueries(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), and ShowQueries().
|
private |
Definition at line 534 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and SetDSet().
|
protected |
Definition at line 623 of file TProof.h.
Referenced by AddWorkers(), Collect(), TProofLite::Init(), Init(), InitMembers(), LoadPackage(), TProofLite::PollForNewWorkers(), SetParallel(), SetParallelSilent(), SetupWorkersEnv(), UseDynamicStartup(), and VerifyDataSet().
|
protected |
Definition at line 614 of file TProof.h.
Referenced by GetListOfEnabledPackages(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), and ~TProof().
|
private |
Definition at line 566 of file TProof.h.
Referenced by TProofLite::Init(), Init(), InitMembers(), LoadPackageOnClient(), TProofLite::SetQueryRunning(), ShowEnabledPackages(), UnloadPackageOnClient(), UnloadPackages(), and ~TProof().
|
private |
Definition at line 567 of file TProof.h.
Referenced by EnablePackage(), GetEnabledPackages(), TProofLite::Init(), Init(), and InitMembers().
|
private |
Definition at line 561 of file TProof.h.
Referenced by GoParallel(), TProofLite::Init(), Init(), InitMembers(), and IsEndMaster().
|
private |
Definition at line 526 of file TProof.h.
Referenced by AddFeedback(), Browse(), ClearFeedback(), ClearInput(), GetFeedbackList(), TProofLite::Init(), Init(), InitMembers(), RemoveFeedback(), ShowFeedback(), and ~TProof().
|
private |
Definition at line 533 of file TProof.h.
Referenced by CheckFile(), ClearCache(), and RemoveWorkers().
|
private |
Definition at line 588 of file TProof.h.
Referenced by FinalizationDone(), HandleInputMessage(), HandleSubmerger(), and InitMembers().
|
private |
Definition at line 564 of file TProof.h.
Referenced by BuildPackageOnClient(), TProofLite::Init(), Init(), InitMembers(), LoadPackageOnClient(), ShowPackages(), UploadPackage(), and ~TProof().
|
staticprivate |
Definition at line 595 of file TProof.h.
Referenced by LogViewer().
|
staticprivate |
Definition at line 579 of file TProof.h.
Referenced by AddEnvVar(), DelEnvVar(), GetEnvVars(), TProofLite::GetNumberOfWorkers(), ParseConfigField(), ResetEnvVars(), and TProofLite::SetProofServEnv().
|
private |
Definition at line 499 of file TProof.h.
Referenced by GetGroup(), HandleInputMessage(), and Init().
|
protected |
Definition at line 604 of file TProof.h.
Referenced by AddWorkers(), FindUniqueSlaves(), GetImage(), TProofLite::Init(), Init(), TProofLite::PollForNewWorkers(), TProofLite::SetProofServEnv(), TProofLite::SetupWorkers(), TProofSuperMaster::StartSlaves(), and TProofCondor::StartSlaves().
|
private |
Definition at line 511 of file TProof.h.
Referenced by Close(), GetListOfInactiveSlaves(), GetNumberOfInactiveSlaves(), GoMoreParallel(), GoParallel(), TProofLite::Init(), Init(), InitMembers(), MarkBad(), ModifyWorkerLists(), SaveActiveList(), and ~TProof().
|
private |
Definition at line 569 of file TProof.h.
Referenced by AddInputData(), ClearInputData(), TProofLite::Init(), Init(), InitMembers(), PrepareInputDataFile(), and ~TProof().
|
private |
Definition at line 570 of file TProof.h.
Referenced by ClearInputData(), PrepareInputDataFile(), and SetInputDataFile().
|
private |
Definition at line 522 of file TProof.h.
Referenced by Close(), Collect(), TXSlave::HandleError(), TProofLite::Init(), Init(), InitMembers(), StartSlaves(), and ~TProof().
|
private |
Definition at line 506 of file TProof.h.
Referenced by Collect(), and InitMembers().
|
private |
Definition at line 539 of file TProof.h.
Referenced by HandleInputMessage(), Init(), InitMembers(), and IsWaiting().
|
private |
Definition at line 586 of file TProof.h.
Referenced by FindNextFreeMerger(), HandleSubmerger(), and InitMembers().
|
private |
Definition at line 507 of file TProof.h.
Referenced by Collect(), TProofLite::Init(), and InitMembers().
|
private |
Definition at line 578 of file TProof.h.
Referenced by GetLoadedMacros(), TProofLite::Init(), Init(), InitMembers(), Load(), SetupWorkersEnv(), and ~TProof().
|
private |
Definition at line 542 of file TProof.h.
Referenced by DownloadPackage(), TProofPlayerRemote::Finalize(), GetStatistics(), TProofLite::Init(), Init(), TProofPlayerLite::Process(), TProofPlayerRemote::Process(), and ~TProof().
|
private |
Definition at line 544 of file TProof.h.
Referenced by GetLastLog(), TProofLite::Init(), Init(), InitMembers(), LogMessage(), ShowLog(), and ~TProof().
|
private |
Definition at line 543 of file TProof.h.
Referenced by TProofLite::Init(), Init(), InitMembers(), NotifyLogMsg(), RecvLogFile(), TProofPlayerRemote::RedirectOutput(), TProofLite::SetQueryRunning(), ShowPackages(), and ~TProof().
|
private |
Definition at line 500 of file TProof.h.
Referenced by GetLogLevel(), TProofLite::Init(), Init(), SendInitialState(), and SetLogLevel().
|
private |
Definition at line 545 of file TProof.h.
Referenced by TProofLite::Init(), Init(), InitMembers(), NotifyLogMsg(), RecvLogFile(), SendingLogToWindow(), and SendLogToWindow().
|
private |
Definition at line 548 of file TProof.h.
Referenced by Getenv(), GetMacroLog(), GetRC(), HandleOutputOptions(), InitMembers(), RecvLogFile(), and TProof().
|
protected |
Definition at line 621 of file TProof.h.
Referenced by ClearData(), DisablePackage(), DisablePackages(), DownloadPackage(), GetDataPoolUrl(), GetManager(), InitMembers(), MarkBad(), SetDataPoolUrl(), SetManager(), ShowData(), TProof(), and ~TProof().
|
private |
|
protected |
Definition at line 600 of file TProof.h.
Referenced by Init(), InitMembers(), IsMaster(), and TProof().
|
private |
Definition at line 556 of file TProof.h.
Referenced by TProofLite::Init(), Init(), InitMembers(), and SetMaxDrawQueries().
|
private |
Definition at line 550 of file TProof.h.
Referenced by AddWorkers(), AskForOutput(), HandleInputMessage(), HandleSubmerger(), and ResetMergePrg().
|
private |
Definition at line 587 of file TProof.h.
Referenced by CreateMerger(), FindNextFreeMerger(), GetActiveMergersCount(), HandleSubmerger(), InitMembers(), and RedirectWorker().
|
private |
Definition at line 583 of file TProof.h.
Referenced by CreateMerger(), HandleSubmerger(), InitMembers(), and RedirectWorker().
|
private |
Definition at line 584 of file TProof.h.
Referenced by CreateMerger(), HandleSubmerger(), InitMembers(), MarkBad(), and TProofPlayerRemote::SetMerging().
|
private |
Definition at line 582 of file TProof.h.
Referenced by HandleInputMessage(), HandleSubmerger(), InitMembers(), MarkBad(), and ResetMergers().
|
private |
Definition at line 514 of file TProof.h.
Referenced by BuildPackage(), ClearCache(), Close(), DisablePackage(), DisablePackages(), TProofLite::FindUniqueSlaves(), FindUniqueSlaves(), TProofLite::Init(), Init(), InitMembers(), MarkBad(), ShowCache(), ShowPackages(), UploadPackage(), and ~TProof().
|
private |
Definition at line 536 of file TProof.h.
Referenced by HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), IsIdle(), TProofPlayerRemote::JoinProcess(), TProofPlayerLite::Process(), and TProofPlayerRemote::Process().
|
private |
Definition at line 554 of file TProof.h.
Referenced by TProofLite::GetListOfQueries(), GetNumberOfQueries(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), and ShowQueries().
|
private |
Definition at line 572 of file TProof.h.
Referenced by GetOutputList(), TProofLite::Process(), and Process().
|
private |
Definition at line 563 of file TProof.h.
Referenced by BuildPackageOnClient(), TProofLite::CreateSandbox(), DisablePackageOnClient(), DisablePackages(), TProofLite::Init(), Init(), LoadPackageOnClient(), TProofLite::SetProofServEnv(), ShowPackages(), UploadPackage(), and UploadPackageOnClient().
|
private |
Definition at line 565 of file TProof.h.
Referenced by BuildPackage(), DisablePackageOnClient(), DisablePackages(), TProofLite::Init(), Init(), InitMembers(), UploadPackageOnClient(), and ~TProof().
|
private |
Definition at line 591 of file TProof.h.
Referenced by InitMembers(), TProofLite::Process(), Process(), SavePerfTree(), and SetPerfTree().
|
private |
Definition at line 525 of file TProof.h.
Referenced by AddInput(), AddWorkers(), Browse(), ClearInput(), Collect(), CreateDrawFeedback(), DeleteDrawFeedback(), DeleteParameters(), DrawSelect(), Finalize(), GetInputList(), GetOutput(), GetOutputList(), GetParameter(), GetPlayer(), GetQueryResult(), GetQueryResults(), HandleInputMessage(), HandleSubmerger(), TProofLite::Init(), Init(), InitMembers(), TProofLite::MakeQueryResult(), MarkBad(), TProofLite::PollForNewWorkers(), TProofLite::Process(), Process(), TProofLite::Remove(), Remove(), Retrieve(), SavePerfTree(), SetDrawFeedbackOption(), SetMaxDrawQueries(), SetParameter(), SetPlayer(), ShowLog(), ShowParameters(), ShowQueries(), StopProcess(), UpdateDialog(), and ~TProof().
|
protected |
Definition at line 628 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and Process().
|
private |
Definition at line 574 of file TProof.h.
Referenced by Init(), InitMembers(), PrintProgress(), Progress(), and SetPrintProgress().
|
private |
Definition at line 523 of file TProof.h.
Referenced by GetProgressDialog(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), TProofLite::Process(), TProofLite::SetupWorkers(), and StartSlaves().
|
private |
Definition at line 524 of file TProof.h.
Referenced by CloseProgressDialog(), Detach(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), TProofLite::Process(), and ResetProgressDialogStatus().
|
protected |
Definition at line 605 of file TProof.h.
Referenced by CancelStagingDataSet(), ClearDataSetCache(), DrawSelect(), EnablePackage(), ExistsDataSet(), TProofPlayerRemote::Finalize(), GetDataSet(), GetDataSets(), GetRemoteProtocol(), GetStagingStatusDataSet(), GetStatistics(), GetTreeHeader(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), ModifyWorkerLists(), TProofPlayerRemote::Process(), Process(), RegisterDataSet(), RequestStagingDataSet(), SetDataSetTreeName(), TXSlave::SetupServ(), TSlave::SetupServ(), ShowDataSetCache(), ShowDataSetQuota(), ShowDataSets(), TProofSuperMaster::StartSlaves(), StartSlaves(), TSlave::StopProcess(), UploadPackage(), and VerifyDataSet().
|
private |
Definition at line 553 of file TProof.h.
Referenced by TProofLite::GetListOfQueries(), GetListOfQueries(), GetNumberOfQueries(), GetQueryReference(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), ShowLog(), and ShowQueries().
|
protected |
Definition at line 622 of file TProof.h.
Referenced by GetQueryMode(), InitMembers(), SetQueryMode(), and TProof().
|
protected |
Definition at line 627 of file TProof.h.
Referenced by TProofPlayerLite::Finalize(), TProofPlayerRemote::Finalize(), HandleInputMessage(), TProofLite::Process(), and Process().
|
private |
Definition at line 520 of file TProof.h.
Referenced by Collect(), GetRealTime(), GetStatistics(), HandleInputMessage(), Init(), and InitMembers().
|
private |
Definition at line 503 of file TProof.h.
Referenced by Collect(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetStagingStatusDataSet(), GetTreeHeader(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), and ~TProof().
|
private |
Definition at line 589 of file TProof.h.
Referenced by CreateMerger(), and HandleSubmerger().
|
private |
Definition at line 541 of file TProof.h.
Referenced by Collect(), Exec(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), NotifyLogMsg(), PrintProgress(), TProofPlayerLite::Process(), TProofPlayerRemote::Process(), RecvLogFile(), and ShowPackages().
|
protected |
Definition at line 615 of file TProof.h.
Referenced by Init(), InitMembers(), TProofLite::Process(), Process(), and ~TProof().
|
private |
Definition at line 538 of file TProof.h.
Referenced by GetRunStatus(), InitMembers(), and SetRunStatus().
|
private |
Definition at line 547 of file TProof.h.
Referenced by Exec(), InitMembers(), and RecvLogFile().
|
protected |
Definition at line 625 of file TProof.h.
Referenced by InitMembers(), TProofLite::Process(), and Process().
|
private |
list returned by kPROOF_GETSLAVEINFO
Definition at line 505 of file TProof.h.
Referenced by TProofLite::Init(), Init(), InitMembers(), MarkBad(), and SendGroupView().
|
private |
Definition at line 557 of file TProof.h.
Referenced by GetSeqNum(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), TProofPlayerLite::Process(), TProofLite::Process(), and TProofPlayerRemote::Process().
|
protected |
Definition at line 620 of file TProof.h.
Referenced by TXSlave::Init(), IsLite(), IsProofd(), and TProof().
|
private |
Definition at line 559 of file TProof.h.
Referenced by GetSessionID(), TXSlave::Init(), TProofLite::Init(), Init(), and InitMembers().
|
private |
Definition at line 504 of file TProof.h.
Referenced by GetListOfSlaveInfos(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), and ~TProof().
|
protected |
Definition at line 606 of file TProof.h.
Referenced by ActivateAsyncInput(), AddWorkers(), Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), Close(), DeActivateAsyncInput(), FindSlave(), GetListOfSlaves(), GetNumberOfSlaves(), GoMoreParallel(), GoParallel(), HandleSubmerger(), TProofLite::Init(), Init(), InitMembers(), Interrupt(), MarkBad(), Ping(), TProofLite::PollForNewWorkers(), PollForNewWorkers(), TProofLite::Print(), Print(), RemoveWorkers(), SaveWorkerInfo(), TProofLite::SetupWorkers(), TProofSuperMaster::StartSlaves(), TProofCondor::StartSlaves(), StartSlaves(), StopProcess(), TerminateWorker(), Touch(), and ~TProof().
|
private |
Definition at line 501 of file TProof.h.
Referenced by BuildPackage(), CancelStagingDataSet(), ClearPackage(), ClearPackages(), Collect(), DisablePackage(), DisablePackages(), ExistsDataSet(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetStagingStatusDataSet(), GetStatus(), HandleInputMessage(), TProofLite::Init(), Init(), LoadPackage(), ModifyWorkerLists(), RegisterDataSet(), RemoveDataSet(), RequestStagingDataSet(), SendCommand(), SendFile(), SetDataSetTreeName(), ShowDataSetQuota(), ShowDataSets(), UnloadPackage(), UnloadPackages(), and VerifyDataSet().
|
private |
Definition at line 537 of file TProof.h.
Referenced by GoAsynchronous(), HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), IsSync(), TProofLite::Process(), Process(), SendDataSetStatus(), and UpdateDialog().
|
protected |
Definition at line 607 of file TProof.h.
Referenced by AddWorkers(), TProofLite::Init(), Init(), InitMembers(), MarkBad(), SaveWorkerInfo(), and ~TProof().
|
protected |
Definition at line 612 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and IsDataReady().
|
private |
Definition at line 496 of file TProof.h.
Referenced by TProofLite::Init(), Init(), InitMembers(), and IsTty().
|
private |
Definition at line 516 of file TProof.h.
Referenced by Collect(), TProofLite::FindUniqueSlaves(), FindUniqueSlaves(), TProofLite::Init(), Init(), InitMembers(), ReleaseMonitor(), and ~TProof().
|
private |
Definition at line 512 of file TProof.h.
Referenced by Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), Close(), TProofLite::FindUniqueSlaves(), FindUniqueSlaves(), GetListOfUniqueSlaves(), GetNumberOfUniqueSlaves(), TProofLite::Init(), Init(), InitMembers(), Interrupt(), Load(), MarkBad(), Ping(), SendFile(), UploadPackage(), and ~TProof().
|
protected |
Definition at line 601 of file TProof.h.
Referenced by AddWorkers(), GetPort(), GetUrl(), GetUser(), HandleInputMessage(), TXSlave::Init(), TSlave::Init(), Init(), MarkBad(), TProofSuperMaster::StartSlaves(), StartSlaves(), and TProof().
|
private |
Definition at line 495 of file TProof.h.
Referenced by Close(), Detach(), TProofLite::Init(), Init(), InitMembers(), IsValid(), and MarkBad().
|
private |
Definition at line 552 of file TProof.h.
Referenced by HandleInputMessage(), TProofLite::Init(), Init(), InitMembers(), and ~TProof().
|
private |
Definition at line 498 of file TProof.h.
Referenced by TProofLite::CleanupSandbox(), TProofLite::CreateSandbox(), GetWorkDir(), TProofLite::Init(), Init(), TProofLite::PollForNewWorkers(), TProofLite::SetProofServEnv(), and TProofLite::SetupWorkers().
|
private |
Definition at line 585 of file TProof.h.
Referenced by CreateMerger(), HandleSubmerger(), and InitMembers().
|
private |
Definition at line 593 of file TProof.h.
Referenced by Collect(), HandleInputMessage(), InitMembers(), Process(), and ~TProof().
ROOT 6.07/01 - Reference Guide Generated on Wed Dec 9 2015 00:28:48 using Doxygen 1.8.6.