TProof Class Reference

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

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

Definition at line 316 of file TProof.h.

Classes
struct	MD5Mod_t

Public Types
enum	EProofClearData { kPurge = 0x1 , kUnregistered = 0x2 , kDataset = 0x4 , kForceClear = 0x8 }
enum	EQueryMode { kSync = 0 , kAsync = 1 }
enum	ERegisterOpt { kFailIfExists = 0 , kOverwriteIfExists = 1 , kMergeIfExists = 2 }
enum	ERunStatus { kRunning = 0 , kStopped = 1 , kAborted = 2 }
enum	EStatusBits {   kUsingSessionGui = (1ULL << ( 14 )) , kNewInputData = (1ULL << ( 15 )) , kIsClient = (1ULL << ( 16 )) , kIsMaster = (1ULL << ( 17 )) ,   kIsTopMaster = (1ULL << ( 18 )) , kUseProgressDialog = (1ULL << ( 19 )) }
enum	ESubMerger {   kOutputSize = 1 , kSendOutput = 2 , kBeMerger = 3 , kMergerDown = 4 ,   kStopMerging = 5 , kOutputSent = 6 }
enum	EUploadOpt {   kAppend = 0x1 , kOverwriteDataSet = 0x2 , kNoOverwriteDataSet = 0x4 , kOverwriteAllFiles = 0x8 ,   kOverwriteNoFiles = 0x10 , kAskUser = 0x0 }
enum	EUploadPackageOpt { kUntar = 0x0 , kRemoveOld = 0x1 }
Public Types inherited from TObject
enum	{   kIsOnHeap = 0x01000000 , kNotDeleted = 0x02000000 , kZombie = 0x04000000 , kInconsistent = 0x08000000 ,   kBitMask = 0x00ffffff }
enum	{ kSingleKey = (1ULL << ( 0 )) , kOverwrite = (1ULL << ( 1 )) , kWriteDelete = (1ULL << ( 2 )) }
enum	EDeprecatedStatusBits { kObjInCanvas = (1ULL << ( 3 )) }
enum	EStatusBits {   kCanDelete = (1ULL << ( 0 )) , kMustCleanup = (1ULL << ( 3 )) , kIsReferenced = (1ULL << ( 4 )) , kHasUUID = (1ULL << ( 5 )) ,   kCannotPick = (1ULL << ( 6 )) , kNoContextMenu = (1ULL << ( 8 )) , kInvalidObject = (1ULL << ( 13 )) }

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

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

Protected Types
enum	ESlaves { kAll , kActive , kUnique , kAllUnique }
Protected Types inherited from TObject
enum	{ kOnlyPrepStep = (1ULL << ( 3 )) }

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

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

Protected Attributes
TMonitor *	fAllMonitor
TList *	fAvailablePackages
TList *	fBadSlaves
Long64_t	fBytesReady
Int_t	fCollectTimeout
TString	fConfDir
TString	fConfFile
TString	fDataPoolUrl
Bool_t	fDataReady
Bool_t	fDynamicStartup
TList *	fEnabledPackages
TString	fImage
TProofMgr *	fManager
Bool_t	fMasterServ
Float_t	fPrepTime
Int_t	fProtocol
EQueryMode	fQueryMode
TStopwatch	fQuerySTW
TList *	fRunningDSets
TSelector *	fSelector
TProofMgr::EServType	fServType
TList *	fSlaves
TList *	fTerminatedSlaveInfos
Long64_t	fTotalBytes
TUrl	fUrl
Protected Attributes inherited from TNamed
TString	fName
TString	fTitle
Protected Attributes inherited from TQObject
TList *	fListOfConnections
	list of signals from this object
TList *	fListOfSignals
Bool_t	fSignalsBlocked
	list of connections to this object

Private Types
enum	EBuildPackageOpt { kDontBuildOnClient = -2 , kBuildOnSlavesNoWait = -1 , kBuildAll = 0 , kCollectBuildResults = 1 }
enum	EProofCacheCommands {   kShowCache = 1 , kClearCache = 2 , kShowPackages = 3 , kClearPackages = 4 ,   kClearPackage = 5 , kBuildPackage = 6 , kLoadPackage = 7 , kShowEnabledPackages = 8 ,   kShowSubCache = 9 , kClearSubCache = 10 , kShowSubPackages = 11 , kDisableSubPackages = 12 ,   kDisableSubPackage = 13 , kBuildSubPackage = 14 , kUnloadPackage = 15 , kDisablePackage = 16 ,   kUnloadPackages = 17 , kDisablePackages = 18 , kListPackages = 19 , kListEnabledPackages = 20 ,   kLoadMacro = 21 }
enum	EProofDataSetCommands {   kUploadDataSet = 1 , kCheckDataSetName = 2 , kGetDataSets = 3 , kRegisterDataSet = 4 ,   kGetDataSet = 5 , kVerifyDataSet = 6 , kRemoveDataSet = 7 , kMergeDataSet = 8 ,   kShowDataSets = 9 , kGetQuota = 10 , kShowQuota = 11 , kSetDefaultTreeName = 12 ,   kCache = 13 , kRequestStaging = 14 , kStagingStatus = 15 , kCancelStaging = 16 }
enum	EProofShowQuotaOpt { kPerGroup = 0x1 , kPerUser = 0x2 }
enum	EProofWrkListAction { kActivateWorker = 1 , kDeactivateWorker = 2 }
enum	ESendFileOpt {   kAscii = 0x0 , kBinary = 0x1 , kForce = 0x2 , kForward = 0x4 ,   kCpBin = 0x8 , kCp = 0x10 }
enum	EUrgent {   kLocalInterrupt = -1 , kPing = 0 , kHardInterrupt = 1 , kSoftInterrupt ,   kShutdownInterrupt }
typedef std::map< TString, MD5Mod_t >	FileMap_t

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

Static Private Member Functions
static TList *	GetDataSetSrvMaps (const TString &srvmaps)

Private Attributes
TMonitor *	fActiveMonitor
TList *	fActiveSlaves
TString	fActiveSlavesSaved
TMonitor *	fAllUniqueMonitor
TList *	fAllUniqueSlaves
Long64_t	fBytesRead
TList *	fChains
Int_t	fCheckFileStatus
std::recursive_mutex	fCloseMutex
Float_t	fCpuTime
TMonitor *	fCurrentMonitor
Int_t	fDrawQueries
TDSet *	fDSet
TList *	fEnabledPackagesOnCluster
Bool_t	fEndMaster
TList *	fFeedback
FileMap_t	fFileMap
Bool_t	fFinalizationRunning
TString	fGroup
TList *	fInactiveSlaves
TList *	fInputData
TString	fInputDataFile
TSignalHandler *	fIntHandler
Bool_t	fIsPollingWorkers
Bool_t	fIsWaiting
Int_t	fLastAssignedMerger
Long64_t	fLastPollWorkers_s
TList *	fLoadedMacros
TString	fLogFileName
FILE *	fLogFileR
FILE *	fLogFileW
Int_t	fLogLevel
Bool_t	fLogToWindowOnly
TMacro	fMacroLog
TString	fMaster
Int_t	fMaxDrawQueries
TProofMergePrg	fMergePrg
TList *	fMergers
Bool_t	fMergersByHost
Int_t	fMergersCount
Bool_t	fMergersSet
TList *	fNonUniqueMasters
Int_t	fNotIdle
Int_t	fOtherQueries
TProofOutputList	fOutputList
TPackMgr *	fPackMgr
TString	fPerfTree
TVirtualProofPlayer *	fPlayer
PrintProgress_t	fPrintProgress
TPluginHandler *	fProgressDialog
Bool_t	fProgressDialogStarted
TList *	fQueries
Float_t	fRealTime
TList *	fRecvMessages
Int_t	fRedirectNext
Bool_t	fRedirLog
ERunStatus	fRunStatus
Bool_t	fSaveLogToMacro
Bool_t	fSendGroupView
	list returned by kPROOF_GETSLAVEINFO
Int_t	fSeqNum
Int_t	fSessionID
TList *	fSlaveInfo
Int_t	fStatus
Bool_t	fSync
Bool_t	fTty
TMonitor *	fUniqueMonitor
TList *	fUniqueSlaves
Bool_t	fValid
TList *	fWaitingSlaves
TString	fWorkDir
Int_t	fWorkersToMerge
TList *	fWrksOutputReady

Static Private Attributes
static TPluginHandler *	fgLogViewer = 0
static TList *	fgProofEnvList = 0

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

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

#include <TProof.h>

Inheritance diagram for TProof:

Member Typedef Documentation

FileMap_t

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

private

Definition at line 501 of file TProof.h.

Member Enumeration Documentation

EBuildPackageOpt

enum TProof::EBuildPackageOpt

private

Enumerator
kDontBuildOnClient
kBuildOnSlavesNoWait
kBuildAll
kCollectBuildResults

Definition at line 453 of file TProof.h.

EProofCacheCommands

enum TProof::EProofCacheCommands

private

Enumerator
kShowCache
kClearCache
kShowPackages
kClearPackages
kClearPackage
kBuildPackage
kLoadPackage
kShowEnabledPackages
kShowSubCache
kClearSubCache
kShowSubPackages
kDisableSubPackages
kDisableSubPackage
kBuildSubPackage
kUnloadPackage
kDisablePackage
kUnloadPackages
kDisablePackages
kListPackages
kListEnabledPackages
kLoadMacro

Definition at line 400 of file TProof.h.

EProofClearData

enum TProof::EProofClearData

Enumerator
kPurge
kUnregistered
kDataset
kForceClear

Definition at line 385 of file TProof.h.

EProofDataSetCommands

enum TProof::EProofDataSetCommands

private

Enumerator
kUploadDataSet
kCheckDataSetName
kGetDataSets
kRegisterDataSet
kGetDataSet
kVerifyDataSet
kRemoveDataSet
kMergeDataSet
kShowDataSets
kGetQuota
kShowQuota
kSetDefaultTreeName
kCache
kRequestStaging
kStagingStatus
kCancelStaging

Definition at line 423 of file TProof.h.

EProofShowQuotaOpt

enum TProof::EProofShowQuotaOpt

private

Enumerator
kPerGroup
kPerUser

Definition at line 459 of file TProof.h.

EProofWrkListAction

enum TProof::EProofWrkListAction

private

Enumerator
kActivateWorker
kDeactivateWorker

Definition at line 449 of file TProof.h.

EQueryMode

enum TProof::EQueryMode

Enumerator
kSync
kAsync

Definition at line 349 of file TProof.h.

ERegisterOpt

enum TProof::ERegisterOpt

Enumerator
kFailIfExists
kOverwriteIfExists
kMergeIfExists

Definition at line 361 of file TProof.h.

ERunStatus

enum TProof::ERunStatus

Enumerator
kRunning
kStopped
kAborted

Definition at line 370 of file TProof.h.

ESendFileOpt

enum TProof::ESendFileOpt

private

Enumerator
kAscii
kBinary
kForce
kForward
kCpBin
kCp

Definition at line 441 of file TProof.h.

ESlaves

enum TProof::ESlaves

protected

Enumerator
kAll
kActive
kUnique
kAllUnique

Definition at line 564 of file TProof.h.

EStatusBits

enum TProof::EStatusBits

Enumerator
kUsingSessionGui
kNewInputData
kIsClient
kIsMaster
kIsTopMaster
kUseProgressDialog

Definition at line 341 of file TProof.h.

ESubMerger

enum TProof::ESubMerger

Enumerator
kOutputSize
kSendOutput
kBeMerger
kMergerDown
kStopMerging
kOutputSent

Definition at line 376 of file TProof.h.

EUploadOpt

enum TProof::EUploadOpt

Enumerator
kAppend
kOverwriteDataSet
kNoOverwriteDataSet
kOverwriteAllFiles
kOverwriteNoFiles
kAskUser

Definition at line 353 of file TProof.h.

EUploadPackageOpt

enum TProof::EUploadPackageOpt

Enumerator
kUntar
kRemoveOld

Definition at line 366 of file TProof.h.

EUrgent

enum TProof::EUrgent

private

Enumerator
kLocalInterrupt
kPing
kHardInterrupt
kSoftInterrupt
kShutdownInterrupt

Definition at line 393 of file TProof.h.

Constructor & Destructor Documentation

TProof() [1/3]

TProof::TProof ( const TProof &  )

private

TProof() [2/3]

TProof::TProof ( )

protected

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

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

Definition at line 513 of file TProof.cxx.

TProof() [3/3]

TProof::TProof	(	const char *	masterurl,
		const char *	conffile = kPROOF_ConfFile,
		const char *	confdir = kPROOF_ConfDir,
		Int_t	loglevel = 0,
		const char *	alias = 0,
		TProofMgr *	mgr = 0
	)

Create a PROOF environment.

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

Definition at line 387 of file TProof.cxx.

~TProof()

TProof::~TProof ( )

override

Clean up PROOF environment.

Definition at line 652 of file TProof.cxx.

Member Function Documentation

Activate()

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

private

Activate slave server list.

Definition at line 2389 of file TProof.cxx.

ActivateAsyncInput()

void TProof::ActivateAsyncInput ( )

private

Activate the a-sync input handler.

Definition at line 4410 of file TProof.cxx.

ActivateWorker()

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

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

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

Definition at line 11353 of file TProof.cxx.

AddChain()

void TProof::AddChain

(

TChain *

chain

)

Add chain to data set.

Definition at line 10223 of file TProof.cxx.

AddDynamicPath()

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

Add 'libpath' to the lib path search.

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

Definition at line 8843 of file TProof.cxx.

AddEnvVar()

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

static

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

Definition at line 11760 of file TProof.cxx.

AddFeedback()

void TProof::AddFeedback

(

const char *

name

)

Add object to feedback list.

Definition at line 9989 of file TProof.cxx.

AddIncludePath()

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

Add 'incpath' to the inc path search.

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

Definition at line 8888 of file TProof.cxx.

AddInput()

void TProof::AddInput

(

TObject *

obj

)

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

Definition at line 9734 of file TProof.cxx.

AddInputData()

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

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

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

Definition at line 9522 of file TProof.cxx.

AddWorkers()

Int_t TProof::AddWorkers ( TList *  workerList )

protected

Works on the master node only.

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

Definition at line 1320 of file TProof.cxx.

Archive() [1/2]

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

Send archive request for the query specified by ref.

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

Definition at line 6077 of file TProof.cxx.

Archive() [2/2]

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

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

Definition at line 6057 of file TProof.cxx.

AskForOutput()

void TProof::AskForOutput ( TSlave *  sl )

private

Master asks for output from worker sl.

Definition at line 4334 of file TProof.cxx.

AskParallel()

void TProof::AskParallel ( )

private

Ask the for the number of parallel slaves.

Definition at line 2077 of file TProof.cxx.

AskStatistics()

void TProof::AskStatistics ( )

private

Ask the for the statistics of the slaves.

Definition at line 2022 of file TProof.cxx.

AssertDataSet()

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

staticprotected

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

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

Definition at line 12014 of file TProof.cxx.

AssertMacroPath()

void TProof::AssertMacroPath ( const char *  macro )

staticprotected

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

Definition at line 8599 of file TProof.cxx.

AssertPath()

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

protected

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

Definition at line 1269 of file TProof.cxx.

Broadcast() [1/6]

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

private

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

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

Definition at line 2518 of file TProof.cxx.

Broadcast() [2/6]

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

private

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

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

Definition at line 2531 of file TProof.cxx.

Broadcast() [3/6]

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

private

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

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

Definition at line 2502 of file TProof.cxx.

Broadcast() [4/6]

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

private

Broadcast a message to all slaves in the specified list.

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

Definition at line 2475 of file TProof.cxx.

Broadcast() [5/6]

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

inlineprivate

Definition at line 634 of file TProof.h.

Broadcast() [6/6]

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

inlineprivate

Definition at line 633 of file TProof.h.

BroadcastFile() [1/2]

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

private

Broadcast file to all workers in the specified list.

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

Definition at line 2610 of file TProof.cxx.

BroadcastFile() [2/2]

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

private

Broadcast file to all workers in the specified list.

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

Definition at line 2639 of file TProof.cxx.

BroadcastGroupPriority() [1/2]

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

private

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

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

Definition at line 2451 of file TProof.cxx.

BroadcastGroupPriority() [2/2]

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

private

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

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

Definition at line 2424 of file TProof.cxx.

BroadcastObject() [1/2]

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

private

Broadcast an object to all slaves in the specified list.

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

Definition at line 2543 of file TProof.cxx.

BroadcastObject() [2/2]

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

private

Broadcast an object to all slaves in the specified list.

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

Definition at line 2555 of file TProof.cxx.

BroadcastRaw() [1/2]

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

private

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

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

Definition at line 2594 of file TProof.cxx.

BroadcastRaw() [2/2]

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

private

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

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

Definition at line 2567 of file TProof.cxx.

Browse()

void TProof::Browse ( TBrowser *  b )

overridevirtual

Build the PROOF's structure in the browser.

Reimplemented from TObject.

Definition at line 10179 of file TProof.cxx.

BuildPackage()

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

private

Build specified package.

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

Definition at line 7990 of file TProof.cxx.

CancelStagingDataSet()

Bool_t TProof::CancelStagingDataSet ( const char *  dataset )

virtual

Cancels a dataset staging request.

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

Reimplemented in TProofLite.

Definition at line 11046 of file TProof.cxx.

cd()

void TProof::cd

(

Int_t

id = -1

)

Set session with 'id' the default one.

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

Definition at line 10496 of file TProof.cxx.

CheckFile()

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

private

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

Use the following algorithm:

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

Definition at line 6799 of file TProof.cxx.

Class()

static TClass * TProof::Class ( )

static

Returns

TClass describing this class

Class_Name()

static const char * TProof::Class_Name ( )

static

Returns

Name of this class

Class_Version()

static constexpr Version_t TProof::Class_Version ( )

inlinestaticconstexpr

Returns

Version of this class

Definition at line 1073 of file TProof.h.

CleanGDirectory()

void TProof::CleanGDirectory ( TList *  ol )

private

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

Definition at line 3046 of file TProof.cxx.

CleanupSession()

Int_t TProof::CleanupSession

(

const char *

sessiontag

)

Send cleanup request for the session specified by tag.

Definition at line 6092 of file TProof.cxx.

ClearCache()

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

virtual

Remove file from all file caches.

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

Reimplemented in TProofLite.

Definition at line 7714 of file TProof.cxx.

ClearData()

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

Remove files for the data directory.

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

Definition at line 7412 of file TProof.cxx.

ClearDataProgress()

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

private

Progress bar for clear data.

Definition at line 7670 of file TProof.cxx.

ClearDataSetCache()

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

virtual

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

Reimplemented in TProofLite.

Definition at line 10896 of file TProof.cxx.

ClearFeedback()

void TProof::ClearFeedback

(

)

Clear feedback list.

Definition at line 10012 of file TProof.cxx.

ClearInput()

void TProof::ClearInput

(

)

Clear input object list.

Definition at line 9742 of file TProof.cxx.

ClearInputData() [1/2]

void TProof::ClearInputData

(

const char *

name

)

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

Definition at line 9572 of file TProof.cxx.

ClearInputData() [2/2]

void TProof::ClearInputData

(

TObject *

obj = 0

)

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

Definition at line 9538 of file TProof.cxx.

ClearPackage()

Int_t TProof::ClearPackage

(

const char *

package

)

Remove a specific package.

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

Definition at line 7857 of file TProof.cxx.

ClearPackages()

Int_t TProof::ClearPackages

(

)

Remove all packages.

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

Definition at line 7840 of file TProof.cxx.

Close()

void TProof::Close

(

Option_t *

opt = ""

)

Close all open slave servers.

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

Definition at line 1798 of file TProof.cxx.

CloseProgressDialog()

void TProof::CloseProgressDialog

(

)

Close progress dialog.

Definition at line 9283 of file TProof.cxx.

Collect() [1/4]

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

private

Collect responses from slave sl.

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

Definition at line 2669 of file TProof.cxx.

Collect() [2/4]

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

protected

Collect responses from the slave servers.

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

Definition at line 2727 of file TProof.cxx.

Collect() [3/4]

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

protected

Collect responses from the slave servers.

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

Definition at line 2696 of file TProof.cxx.

Collect() [4/4]

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

private

Collect responses from the slave servers.

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

Definition at line 2756 of file TProof.cxx.

CollectInputFrom()

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

private

Collect and analyze available input from socket s.

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

Definition at line 3060 of file TProof.cxx.

CreateDrawFeedback()

TDrawFeedback * TProof::CreateDrawFeedback

(

)

Draw feedback creation proxy.

When accessed via TProof avoids link dependency on libProofPlayer.

Definition at line 10094 of file TProof.cxx.

CreateMerger()

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

private

Create a new merger.

Definition at line 4454 of file TProof.cxx.

CreateSlave()

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

protected

Create a new TSlave of type TSlave::kSlave.

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

Definition at line 1853 of file TProof.cxx.

CreateSubmaster()

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

protected

Create a new TSlave of type TSlave::kMaster.

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

Definition at line 1875 of file TProof.cxx.

DataSetStatus()

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

Send dataset preparation status.

Definition at line 9324 of file TProof.cxx.

DeActivateAsyncInput()

void TProof::DeActivateAsyncInput ( )

private

De-activate a-sync input handler.

Definition at line 4423 of file TProof.cxx.

DeactivateWorker()

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

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

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

Definition at line 11370 of file TProof.cxx.

DeclFileName()

static const char * TProof::DeclFileName ( )

inlinestatic

Returns

Name of the file containing the class declaration

Definition at line 1073 of file TProof.h.

DelEnvVar()

void TProof::DelEnvVar ( const char *  name )

static

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

Definition at line 11782 of file TProof.cxx.

DeleteDrawFeedback()

void TProof::DeleteDrawFeedback

(

TDrawFeedback *

f

)

Delete draw feedback object.

Definition at line 10110 of file TProof.cxx.

DeleteParameters()

void TProof::DeleteParameters

(

const char *

wildcard

)

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

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

Definition at line 9933 of file TProof.cxx.

Detach()

void TProof::Detach

(

Option_t *

opt = ""

)

Detach this instance to its proofserv.

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

Definition at line 10518 of file TProof.cxx.

DisableGoAsyn()

void TProof::DisableGoAsyn

(

)

Signal to disable related switches.

Definition at line 6259 of file TProof.cxx.

DisablePackage()

Int_t TProof::DisablePackage ( const char *  pack )

private

Remove a specific package.

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

Definition at line 7885 of file TProof.cxx.

DisablePackages()

Int_t TProof::DisablePackages ( )

private

Remove all packages.

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

Definition at line 7942 of file TProof.cxx.

DownloadPackage()

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

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

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

Definition at line 8334 of file TProof.cxx.

DrawSelect() [1/2]

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

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

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

Definition at line 6182 of file TProof.cxx.

DrawSelect() [2/2]

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

virtual

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

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

Reimplemented in TProofLite.

Definition at line 6146 of file TProof.cxx.

Echo() [1/2]

Int_t TProof::Echo ( const char *  str )

virtual

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

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

Definition at line 7042 of file TProof.cxx.

Echo() [2/2]

Int_t TProof::Echo ( const TObject *  obj )

virtual

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

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

Definition at line 7028 of file TProof.cxx.

EnablePackage() [1/3]

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

Enable specified package.

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

Definition at line 8175 of file TProof.cxx.

EnablePackage() [2/3]

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

Enable specified package.

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

Definition at line 8197 of file TProof.cxx.

EnablePackage() [3/3]

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

Enable specified package.

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

Definition at line 8258 of file TProof.cxx.

Exec() [1/3]

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

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

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

Definition at line 6521 of file TProof.cxx.

Exec() [2/3]

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

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

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

Definition at line 6589 of file TProof.cxx.

Exec() [3/3]

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

private

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

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

Definition at line 6533 of file TProof.cxx.

ExistsDataSet()

Bool_t TProof::ExistsDataSet ( const char *  dataset )

virtual

Returns kTRUE if 'dataset' exists, kFALSE otherwise.

Reimplemented in TProofLite.

Definition at line 10868 of file TProof.cxx.

Feedback()

void TProof::Feedback

(

TList *

objs

)

Get list of feedback objects.

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

Definition at line 9268 of file TProof.cxx.

FinalizationDone()

void TProof::FinalizationDone ( )

inlineprivate

Definition at line 694 of file TProof.h.

Finalize() [1/2]

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

Finalize query with reference ref.

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

Definition at line 5908 of file TProof.cxx.

Finalize() [2/2]

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

Finalize the qry-th query in fQueries.

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

Definition at line 5883 of file TProof.cxx.

FindDataSets()

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

Find datasets, returns in a TList all found datasets.

Definition at line 11010 of file TProof.cxx.

FindNextFreeMerger()

Int_t TProof::FindNextFreeMerger ( )

private

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

It works on the 'round-robin' basis.

Definition at line 4304 of file TProof.cxx.

FindSlave()

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

private

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

Definition at line 1891 of file TProof.cxx.

FindUniqueSlaves()

void TProof::FindUniqueSlaves ( )

privatevirtual

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

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

Reimplemented in TProofLite.

Definition at line 1912 of file TProof.cxx.

GetActiveMergersCount()

Int_t TProof::GetActiveMergersCount ( )

private

Get the active mergers count.

Definition at line 4436 of file TProof.cxx.

GetBytesRead()

Long64_t TProof::GetBytesRead ( ) const

inline

Definition at line 929 of file TProof.h.

GetClientProtocol()

Int_t TProof::GetClientProtocol ( ) const

inline

Definition at line 914 of file TProof.h.

GetConfDir()

const char * TProof::GetConfDir ( ) const

inline

Definition at line 904 of file TProof.h.

GetConfFile()

const char * TProof::GetConfFile ( ) const

inline

Definition at line 905 of file TProof.h.

GetCpuTime()

Float_t TProof::GetCpuTime ( ) const

inline

Definition at line 931 of file TProof.h.

GetDataPoolUrl()

const char * TProof::GetDataPoolUrl ( ) const

inline

Definition at line 1043 of file TProof.h.

GetDataSet()

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

virtual

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

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

Reimplemented in TProofLite.

Definition at line 10937 of file TProof.cxx.

GetDataSetQuota()

TMap * TProof::GetDataSetQuota

(

const char *

optStr = ""

)

returns a map of the quotas of all groups

Definition at line 11276 of file TProof.cxx.

GetDataSets()

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

virtual

Lists all datasets that match given uri.

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

Reimplemented in TProofLite.

Definition at line 10809 of file TProof.cxx.

GetDataSetSrvMaps()

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

staticprivate

GetEnabledPackages()

TList * TProof::GetEnabledPackages ( ) const

inlineprotected

Definition at line 735 of file TProof.h.

Getenv()

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

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

Definition at line 6644 of file TProof.cxx.

GetEnvVars()

const TList * TProof::GetEnvVars ( )

static

Get environemnt variables.

Definition at line 11751 of file TProof.cxx.

GetFeedbackList()

TList * TProof::GetFeedbackList

(

)

const

Return feedback list.

Definition at line 10033 of file TProof.cxx.

GetFileInCmd()

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

staticprotected

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

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

Definition at line 6495 of file TProof.cxx.

GetGroup()

const char * TProof::GetGroup ( ) const

inline

Definition at line 907 of file TProof.h.

GetImage()

const char * TProof::GetImage ( ) const

inline

Definition at line 910 of file TProof.h.

GetInputData()

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

staticprotected

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

Definition at line 12413 of file TProof.cxx.

GetInputList()

TList * TProof::GetInputList

(

)

Get input list.

Definition at line 9753 of file TProof.cxx.

GetLastLog()

TMacro * TProof::GetLastLog

(

)

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

The returned TMacro must be deleted by the caller.

Definition at line 10257 of file TProof.cxx.

GetListOfActiveSlaves()

TList * TProof::GetListOfActiveSlaves ( ) const

inlineprotected

Definition at line 723 of file TProof.h.

GetListOfBadSlaves()

TList * TProof::GetListOfBadSlaves ( ) const

inlineprivate

Definition at line 657 of file TProof.h.

GetListOfEnabledPackages()

TList * TProof::GetListOfEnabledPackages

(

)

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

Definition at line 9124 of file TProof.cxx.

GetListOfInactiveSlaves()

TList * TProof::GetListOfInactiveSlaves ( ) const

inlineprivate

Definition at line 655 of file TProof.h.

GetListOfPackages()

TList * TProof::GetListOfPackages

(

)

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

Definition at line 9108 of file TProof.cxx.

GetListOfQueries()

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

virtual

Ask the master for the list of queries.

Reimplemented in TProofLite.

Definition at line 2088 of file TProof.cxx.

GetListOfSlaveInfos()

TList * TProof::GetListOfSlaveInfos

(

)

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

Definition at line 2321 of file TProof.cxx.

GetListOfSlaves()

TList * TProof::GetListOfSlaves ( ) const

inlineprivate

Definition at line 654 of file TProof.h.

GetListOfUniqueSlaves()

TList * TProof::GetListOfUniqueSlaves ( ) const

inlineprivate

Definition at line 656 of file TProof.h.

GetLoadedMacros()

TList * TProof::GetLoadedMacros ( ) const

inline

Definition at line 944 of file TProof.h.

GetLog()

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

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

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

Definition at line 10240 of file TProof.cxx.

GetLogLevel()

Int_t TProof::GetLogLevel ( ) const

inline

Definition at line 916 of file TProof.h.

GetMacroLog()

TMacro * TProof::GetMacroLog ( )

inline

Definition at line 1019 of file TProof.h.

GetManager()

TProofMgr * TProof::GetManager ( )

inline

Definition at line 1037 of file TProof.h.

GetMaster()

const char * TProof::GetMaster ( ) const

inline

Definition at line 903 of file TProof.h.

GetMaxQueries()

void TProof::GetMaxQueries

(

)

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

Definition at line 2128 of file TProof.cxx.

GetMissingFiles()

TFileCollection * TProof::GetMissingFiles

(

TQueryResult *

qr = 0

)

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

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

Definition at line 12581 of file TProof.cxx.

GetNumberOfActiveSlaves()

Int_t TProof::GetNumberOfActiveSlaves ( ) const

private

Return number of active slaves, i.e.

slaves that are valid and in the current computing group.

Definition at line 1987 of file TProof.cxx.

GetNumberOfBadSlaves()

Int_t TProof::GetNumberOfBadSlaves ( ) const

private

Return number of bad slaves.

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

Definition at line 2014 of file TProof.cxx.

GetNumberOfDrawQueries()

Int_t TProof::GetNumberOfDrawQueries ( )

inline

Definition at line 979 of file TProof.h.

GetNumberOfInactiveSlaves()

Int_t TProof::GetNumberOfInactiveSlaves ( ) const

private

Return number of inactive slaves, i.e.

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

Definition at line 1996 of file TProof.cxx.

GetNumberOfQueries()

Int_t TProof::GetNumberOfQueries

(

)

Number of queries processed by this session.

Definition at line 2105 of file TProof.cxx.

GetNumberOfSlaves()

Int_t TProof::GetNumberOfSlaves ( ) const

private

Return number of slaves as described in the config file.

Definition at line 1978 of file TProof.cxx.

GetNumberOfUniqueSlaves()

Int_t TProof::GetNumberOfUniqueSlaves ( ) const

private

Return number of unique slaves, i.e.

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

Definition at line 2005 of file TProof.cxx.

GetOutput() [1/2]

TObject * TProof::GetOutput

(

const char *

name

)

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

Definition at line 9762 of file TProof.cxx.

GetOutput() [2/2]

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

static

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

Definition at line 9776 of file TProof.cxx.

GetOutputList()

TList * TProof::GetOutputList

(

)

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

Definition at line 9808 of file TProof.cxx.

GetOutputNames()

TList * TProof::GetOutputNames

(

)

FIXME: to be written.

Definition at line 10118 of file TProof.cxx.

GetParallel()

Int_t TProof::GetParallel

(

)

const

Returns number of slaves active in parallel mode.

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

Definition at line 2304 of file TProof.cxx.

GetParameter() [1/6]

TObject * TProof::GetParameter

(

const char *

par

)

const

Get specified parameter.

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

Definition at line 9918 of file TProof.cxx.

GetParameter() [2/6]

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

static

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

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

Definition at line 11995 of file TProof.cxx.

GetParameter() [3/6]

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

static

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

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

Definition at line 11941 of file TProof.cxx.

GetParameter() [4/6]

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

static

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

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

Definition at line 11977 of file TProof.cxx.

GetParameter() [5/6]

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

static

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

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

Definition at line 11959 of file TProof.cxx.

GetParameter() [6/6]

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

static

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

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

Definition at line 11922 of file TProof.cxx.

GetPlayer()

TVirtualProofPlayer * TProof::GetPlayer ( ) const

inlineprotected

Definition at line 716 of file TProof.h.

GetPort()

Int_t TProof::GetPort ( ) const

inline

Definition at line 912 of file TProof.h.

GetProgressDialog()

TPluginHandler * TProof::GetProgressDialog ( ) const

inlineprotected

Definition at line 742 of file TProof.h.

GetQueryMode()

TProof::EQueryMode TProof::GetQueryMode

(

Option_t *

mode = 0

)

const

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

Definition at line 6119 of file TProof.cxx.

GetQueryReference()

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

private

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

Definition at line 5857 of file TProof.cxx.

GetQueryResult()

TQueryResult * TProof::GetQueryResult

(

const char *

ref = 0

)

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

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

Definition at line 2148 of file TProof.cxx.

GetQueryResults()

TList * TProof::GetQueryResults

(

)

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

Definition at line 2139 of file TProof.cxx.

GetRC() [1/3]

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

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

Definition at line 6691 of file TProof.cxx.

GetRC() [2/3]

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

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

Definition at line 6665 of file TProof.cxx.

GetRC() [3/3]

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

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

Definition at line 6717 of file TProof.cxx.

GetRealTime()

Float_t TProof::GetRealTime ( ) const

inline

Definition at line 930 of file TProof.h.

GetRemoteProtocol()

Int_t TProof::GetRemoteProtocol ( ) const

inline

Definition at line 913 of file TProof.h.

GetRunStatus()

ERunStatus TProof::GetRunStatus ( ) const

inline

Definition at line 943 of file TProof.h.

GetSandbox()

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

protected

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

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

Definition at line 1016 of file TProof.cxx.

GetSeqNum()

Int_t TProof::GetSeqNum ( ) const

inline

Definition at line 918 of file TProof.h.

GetSessionID()

Int_t TProof::GetSessionID ( ) const

inline

Definition at line 919 of file TProof.h.

GetSessionTag()

const char * TProof::GetSessionTag ( ) const

inline

Definition at line 909 of file TProof.h.

GetStagingStatusDataSet()

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

virtual

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

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

Reimplemented in TProofLite.

Definition at line 11073 of file TProof.cxx.

GetStatistics()

void TProof::GetStatistics

(

Bool_t

verbose = kFALSE

)

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

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

Definition at line 2035 of file TProof.cxx.

GetStatus()

Int_t TProof::GetStatus ( ) const

inline

Definition at line 915 of file TProof.h.

GetTreeHeader()

TTree * TProof::GetTreeHeader ( TDSet *  tdset )

virtual

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

Reimplemented in TProofLite.

Definition at line 10042 of file TProof.cxx.

GetUrl()

const char * TProof::GetUrl ( )

inline

Definition at line 911 of file TProof.h.

GetUser()

const char * TProof::GetUser ( ) const

inline

Definition at line 906 of file TProof.h.

GetWorkDir()

const char * TProof::GetWorkDir ( ) const

inline

Definition at line 908 of file TProof.h.

GoAsynchronous()

void TProof::GoAsynchronous

(

)

Send GOASYNC message to the master.

Definition at line 6267 of file TProof.cxx.

GoMoreParallel()

Int_t TProof::GoMoreParallel ( Int_t  nWorkersToAdd )

private

Add nWorkersToAdd workers to current list of workers.

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

Definition at line 7170 of file TProof.cxx.

GoParallel()

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

private

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

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

Definition at line 7273 of file TProof.cxx.

HandleInputMessage()

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

private

Analyze the received message.

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

Definition at line 3105 of file TProof.cxx.

HandleLibIncPath()

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

protected

Handle lib, inc search paths modification request.

Definition at line 8998 of file TProof.cxx.

HandleOutputOptions()

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

protected

Extract from opt information about output handling settings.

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

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

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

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

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

Output file settings are in the form

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

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

Returns 0 on success, -1 on error.

Definition at line 4937 of file TProof.cxx.

HandleSubmerger()

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

private

Process a message of type kPROOF_SUBMERGER.

Definition at line 4014 of file TProof.cxx.

Init()

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

protected

Start the PROOF environment.

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

Definition at line 757 of file TProof.cxx.

InitMembers()

void TProof::InitMembers ( )

protected

Default initializations.

Definition at line 527 of file TProof.cxx.

Interrupt()

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

private

Send interrupt to master or slave servers.

Definition at line 2276 of file TProof.cxx.

InterruptCurrentMonitor()

void TProof::InterruptCurrentMonitor ( )

private

If in active in a monitor set ready state.

Definition at line 11335 of file TProof.cxx.

IsA()

TClass * TProof::IsA ( ) const

inlineoverridevirtual

Returns

TClass describing current object

Reimplemented from TNamed.

Reimplemented in TProofCondor, TProofLite, and TProofSuperMaster.

Definition at line 1073 of file TProof.h.

IsDataReady()

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

See if the data is ready to be analyzed.

Definition at line 2240 of file TProof.cxx.

IsEndMaster()

Bool_t TProof::IsEndMaster ( ) const

inlineprivate

Definition at line 664 of file TProof.h.

IsFolder()

Bool_t TProof::IsFolder ( ) const

inlineoverridevirtual

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

Reimplemented from TObject.

Definition at line 935 of file TProof.h.

IsIdle()

Bool_t TProof::IsIdle ( ) const

inline

Definition at line 940 of file TProof.h.

IsLite()

Bool_t TProof::IsLite ( ) const

inline

Definition at line 933 of file TProof.h.

IsMaster()

Bool_t TProof::IsMaster ( ) const

inline

Definition at line 936 of file TProof.h.

IsParallel()

Bool_t TProof::IsParallel ( ) const

inline

Definition at line 939 of file TProof.h.

IsProofd()

Bool_t TProof::IsProofd ( ) const

inline

Definition at line 934 of file TProof.h.

IsSync()

Bool_t TProof::IsSync ( ) const

inlineprivate

Definition at line 669 of file TProof.h.

IsTty()

Bool_t TProof::IsTty ( ) const

inline

Definition at line 938 of file TProof.h.

IsValid()

Bool_t TProof::IsValid ( ) const

inline

Definition at line 937 of file TProof.h.

IsWaiting()

Bool_t TProof::IsWaiting ( ) const

inline

Definition at line 941 of file TProof.h.

Load()

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

virtual

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

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

Reimplemented in TProofLite.

Definition at line 8628 of file TProof.cxx.

LoadPackage()

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

private

Load specified package.

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

Definition at line 8069 of file TProof.cxx.

LogMessage()

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

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

Definition at line 6414 of file TProof.cxx.

LogViewer()

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

static

Start the log viewer window usign the plugin manager.

Definition at line 12470 of file TProof.cxx.

MakePlayer()

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

protectedvirtual

Construct a TProofPlayer object.

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

Reimplemented in TProofSuperMaster.

Definition at line 10211 of file TProof.cxx.

MarkBad() [1/2]

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

private

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

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

Definition at line 4521 of file TProof.cxx.

MarkBad() [2/2]

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

private

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

Definition at line 4682 of file TProof.cxx.

Mgr()

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

static

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

Definition at line 11724 of file TProof.cxx.

ModifyWorkerLists()

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

private

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

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

Definition at line 11389 of file TProof.cxx.

NotifyLogMsg()

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

private

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

Definition at line 6358 of file TProof.cxx.

Open()

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

static

Start a PROOF session on a specific cluster.

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

Definition at line 11583 of file TProof.cxx.

operator=()

void TProof::operator= ( const TProof &  )

private

ParseConfigField()

void TProof::ParseConfigField ( const char *  config )

private

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

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

Definition at line 1043 of file TProof.cxx.

Ping() [1/2]

Int_t TProof::Ping

(

)

Ping PROOF. Returns 1 if master server responded.

Definition at line 4744 of file TProof.cxx.

Ping() [2/2]

Int_t TProof::Ping ( ESlaves  list )

private

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

Definition at line 4752 of file TProof.cxx.

PollForNewWorkers()

Int_t TProof::PollForNewWorkers ( )

protectedvirtual

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

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

Reimplemented in TProofLite.

Definition at line 2970 of file TProof.cxx.

PrepareInputDataFile()

void TProof::PrepareInputDataFile ( TString &  dataFile )

protected

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

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

Definition at line 9639 of file TProof.cxx.

Print()

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

overridevirtual

Print status of PROOF cluster.

Reimplemented from TNamed.

Reimplemented in TProofLite.

Definition at line 4803 of file TProof.cxx.

PrintProgress()

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

private

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

Definition at line 9140 of file TProof.cxx.

Process() [1/8]

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

virtual

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

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

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5503 of file TProof.cxx.

Process() [2/8]

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

virtual

Process with name of dataset and TSelector object.

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5809 of file TProof.cxx.

Process() [3/8]

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

virtual

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

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

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5721 of file TProof.cxx.

Process() [4/8]

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

virtual

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

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

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5303 of file TProof.cxx.

Process() [5/8]

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

virtual

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

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

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5761 of file TProof.cxx.

Process() [6/8]

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

virtual

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

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

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5412 of file TProof.cxx.

Process() [7/8]

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

virtual

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

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

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5787 of file TProof.cxx.

Process() [8/8]

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

virtual

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

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

Reimplemented in TProofLite, and TProofSuperMaster.

Definition at line 5835 of file TProof.cxx.

Progress() [1/3]

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

Get query progress information.

Connect a slot to this signal to track progress.

Definition at line 9201 of file TProof.cxx.

Progress() [2/3]

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

Get query progress information.

Connect a slot to this signal to track progress.

Definition at line 9224 of file TProof.cxx.

Progress() [3/3]

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

Get query progress information.

Connect a slot to this signal to track progress.

Definition at line 9246 of file TProof.cxx.

Prompt()

Bool_t TProof::Prompt ( const char *  p )

private

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

Definition at line 7649 of file TProof.cxx.

PutLog()

void TProof::PutLog

(

TQueryResult *

qr

)

Display log of query pq into the log window frame.

Definition at line 10321 of file TProof.cxx.

QueryResultReady()

void TProof::QueryResultReady

(

const char *

ref

)

Notify availability of a query result.

Definition at line 9369 of file TProof.cxx.

RecvLogFile()

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

private

Receive the log file of the slave with socket s.

Definition at line 6287 of file TProof.cxx.

RedirectWorker()

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

private

Redirect output of worker sl to some merger.

Definition at line 4258 of file TProof.cxx.

RegisterDataSet()

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

virtual

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

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

Reimplemented in TProofLite.

Definition at line 10707 of file TProof.cxx.

ReleaseMonitor()

void TProof::ReleaseMonitor ( TMonitor *  mon )

private

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

Definition at line 2654 of file TProof.cxx.

Remove() [1/2]

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

Send remove request for the query specified by ref.

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

Definition at line 6034 of file TProof.cxx.

Remove() [2/2]

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

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

Definition at line 6013 of file TProof.cxx.

RemoveChain()

void TProof::RemoveChain

(

TChain *

chain

)

Remove chain from data set.

Definition at line 10231 of file TProof.cxx.

RemoveDataSet()

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

virtual

Remove the specified dataset from the PROOF cluster.

Files are not deleted.

Reimplemented in TProofLite.

Definition at line 10991 of file TProof.cxx.

RemoveDynamicPath()

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

Remove 'libpath' from the lib path search.

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

Definition at line 8933 of file TProof.cxx.

RemoveFeedback()

void TProof::RemoveFeedback

(

const char *

name

)

Remove object from feedback list.

Definition at line 10000 of file TProof.cxx.

RemoveIncludePath()

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

Remove 'incpath' from the inc path search.

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

Definition at line 8967 of file TProof.cxx.

RemoveWorkers()

Int_t TProof::RemoveWorkers ( TList *  workerList )

protected

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

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

Definition at line 1597 of file TProof.cxx.

RequestStagingDataSet()

Bool_t TProof::RequestStagingDataSet ( const char *  dataset )

virtual

Allows users to request staging of a particular dataset.

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

Reimplemented in TProofLite.

Definition at line 11020 of file TProof.cxx.

Reset()

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

static

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

Definition at line 11736 of file TProof.cxx.

ResetEnvVars()

void TProof::ResetEnvVars ( )

static

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

Definition at line 11796 of file TProof.cxx.

ResetMergePrg()

void TProof::ResetMergePrg ( )

private

Reset the merge progress notificator.

Definition at line 2465 of file TProof.cxx.

ResetMergers()

void TProof::ResetMergers ( )

inlineprivate

Definition at line 691 of file TProof.h.

ResetProgressDialog()

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

Reset progress dialog.

Definition at line 9299 of file TProof.cxx.

ResetProgressDialogStatus()

void TProof::ResetProgressDialogStatus ( )

inline

Definition at line 1021 of file TProof.h.

RestoreActiveList()

Int_t TProof::RestoreActiveList ( )

private

Restore saved list of active workers.

Definition at line 11557 of file TProof.cxx.

Retrieve() [1/2]

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

Send retrieve request for the query specified by ref.

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

Definition at line 5967 of file TProof.cxx.

Retrieve() [2/2]

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

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

If path is defined save it to path.

Definition at line 5948 of file TProof.cxx.

SaveActiveList()

void TProof::SaveActiveList ( )

private

Save current list of active workers.

Definition at line 11542 of file TProof.cxx.

SaveInputData()

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

staticprotected

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

Definition at line 12311 of file TProof.cxx.

SavePerfTree()

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

Save performance information from TPerfStats to file 'pf'.

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

Definition at line 12646 of file TProof.cxx.

SaveWorkerInfo()

void TProof::SaveWorkerInfo ( )

protectedvirtual

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

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

Definition at line 11808 of file TProof.cxx.

SendCommand()

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

private

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

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

Definition at line 6631 of file TProof.cxx.

SendCurrentState() [1/2]

Int_t TProof::SendCurrentState ( ESlaves  list = kActive )

private

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

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

Definition at line 6758 of file TProof.cxx.

SendCurrentState() [2/2]

Int_t TProof::SendCurrentState ( TList *  list )

private

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

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

Definition at line 6742 of file TProof.cxx.

SendDataSetStatus()

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

Send or notify data set status.

Definition at line 9336 of file TProof.cxx.

SendFile()

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

protected

Send a file to master or slave servers.

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

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

Definition at line 6894 of file TProof.cxx.

SendGroupView()

Int_t TProof::SendGroupView ( )

private

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

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

Definition at line 6460 of file TProof.cxx.

SendingLogToWindow()

Bool_t TProof::SendingLogToWindow ( ) const

inline

Definition at line 1016 of file TProof.h.

SendInitialState()

Int_t TProof::SendInitialState ( )

private

Transfer the initial (i.e.

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

Definition at line 6774 of file TProof.cxx.

SendInputData()

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

staticprotected

Send the input data file to the workers.

Definition at line 12380 of file TProof.cxx.

SendInputDataFile()

void TProof::SendInputDataFile ( )

protectedvirtual

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

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

Reimplemented in TProofLite.

Definition at line 9612 of file TProof.cxx.

SendLogToWindow()

void TProof::SendLogToWindow ( Bool_t  mode )

inline

Definition at line 1017 of file TProof.h.

SendObject()

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

private

Send object to master or slave servers.

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

Definition at line 7054 of file TProof.cxx.

SendPrint()

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

private

Send print command to master server.

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

Definition at line 7068 of file TProof.cxx.

SetActive()

void TProof::SetActive ( Bool_t  = kTRUE )

inline

Definition at line 988 of file TProof.h.

SetAlias()

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

virtual

Set an alias for this session.

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

Definition at line 10583 of file TProof.cxx.

SetDataPoolUrl()

void TProof::SetDataPoolUrl ( const char *  url )

inline

Definition at line 1044 of file TProof.h.

SetDataSetTreeName()

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

virtual

Set/Change the name of the default tree.

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

Reimplemented in TProofLite.

Definition at line 10766 of file TProof.cxx.

SetDrawFeedbackOption()

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

Set draw feedback option.

Definition at line 10102 of file TProof.cxx.

SetDSet()

void TProof::SetDSet ( TDSet *  dset )

inlineprotected

Definition at line 737 of file TProof.h.

SetFeedback()

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

protected

Extract from opt in optfb information about wanted feedback settings.

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

Feedback requirements are in the form

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

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

Definition at line 5232 of file TProof.cxx.

SetInputDataFile()

void TProof::SetInputDataFile

(

const char *

datafile

)

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

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

Definition at line 9585 of file TProof.cxx.

SetLogLevel()

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

Set server logging level.

Definition at line 7079 of file TProof.cxx.

SetManager()

void TProof::SetManager

(

TProofMgr *

mgr

)

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

Definition at line 1301 of file TProof.cxx.

SetMaxDrawQueries()

void TProof::SetMaxDrawQueries

(

Int_t

max

)

Set max number of draw queries whose results are saved.

Definition at line 2115 of file TProof.cxx.

SetMonitor()

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

private

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

Definition at line 2408 of file TProof.cxx.

SetParallel()

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

Tell PROOF how many slaves to use in parallel.

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

Definition at line 7140 of file TProof.cxx.

SetParallelSilent()

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

private

Tell PROOF how many slaves to use in parallel.

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

Definition at line 7112 of file TProof.cxx.

SetParameter() [1/5]

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

Set input list parameter.

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

Definition at line 9822 of file TProof.cxx.

SetParameter() [2/5]

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

Set an input list parameter.

Definition at line 9898 of file TProof.cxx.

SetParameter() [3/5]

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

Set an input list parameter.

Definition at line 9841 of file TProof.cxx.

SetParameter() [4/5]

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

Set an input list parameter.

Definition at line 9879 of file TProof.cxx.

SetParameter() [5/5]

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

Set an input list parameter.

Definition at line 9860 of file TProof.cxx.

SetPerfTree()

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

Enable/Disable saving of the performance tree.

Definition at line 12624 of file TProof.cxx.

SetPlayer()

void TProof::SetPlayer ( TVirtualProofPlayer *  player )

protected

Set a new PROOF player.

Definition at line 10199 of file TProof.cxx.

SetPrintProgress()

void TProof::SetPrintProgress ( PrintProgress_t  pp )

inline

Definition at line 1046 of file TProof.h.

SetProgressDialog()

void TProof::SetProgressDialog

(

Bool_t

on = kTRUE

)

Enable/Disable the graphic progress dialog.

By default the dialog is enabled

Definition at line 12509 of file TProof.cxx.

SetQueryMode()

void TProof::SetQueryMode

(

EQueryMode

mode

)

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

Definition at line 6107 of file TProof.cxx.

SetRealTimeLog()

void TProof::SetRealTimeLog

(

Bool_t

on = kTRUE

)

Switch ON/OFF the real-time logging facility.

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

Definition at line 7096 of file TProof.cxx.

SetRunStatus()

void TProof::SetRunStatus ( ERunStatus  rst )

inlineprivate

Definition at line 672 of file TProof.h.

SetupWorkersEnv()

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

protected

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

Definition at line 1528 of file TProof.cxx.

ShowCache()

void TProof::ShowCache ( Bool_t  all = kFALSE )

virtual

List contents of file cache.

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

Reimplemented in TProofLite.

Definition at line 7691 of file TProof.cxx.

ShowData()

void TProof::ShowData ( )

virtual

List contents of the data directory in the sandbox.

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

Reimplemented in TProofLite.

Definition at line 7396 of file TProof.cxx.

ShowDataSet()

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

display meta-info for given dataset usi

Definition at line 10977 of file TProof.cxx.

ShowDataSetCache()

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

virtual

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

Reimplemented in TProofLite.

Definition at line 10914 of file TProof.cxx.

ShowDataSetQuota()

void TProof::ShowDataSetQuota

(

Option_t *

opt = 0

)

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

Definition at line 11309 of file TProof.cxx.

ShowDataSets()

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

virtual

Shows datasets in locations that match the uri.

By default shows the user's datasets and global ones

Reimplemented in TProofLite.

Definition at line 10846 of file TProof.cxx.

ShowEnabledPackages()

void TProof::ShowEnabledPackages

(

Bool_t

all = kFALSE

)

List which packages are enabled.

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

Definition at line 7818 of file TProof.cxx.

ShowFeedback()

void TProof::ShowFeedback

(

)

const

Show items in feedback list.

Definition at line 10020 of file TProof.cxx.

ShowLog() [1/2]

void TProof::ShowLog

(

const char *

queryref

)

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

Definition at line 10338 of file TProof.cxx.

ShowLog() [2/2]

void TProof::ShowLog

(

Int_t

qry = -1

)

Display on screen the content of the temporary log file.

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

Definition at line 10371 of file TProof.cxx.

ShowMissingFiles()

void TProof::ShowMissingFiles

(

TQueryResult *

qr = 0

)

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

A short summary is printed in the end.

Definition at line 12522 of file TProof.cxx.

ShowPackages()

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

List contents of package directory.

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

Definition at line 7770 of file TProof.cxx.

ShowParameters()

void TProof::ShowParameters

(

const char *

wildcard = "PROOF_*"

)

const

Show the input list parameters specified by the wildcard.

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

Definition at line 9958 of file TProof.cxx.

ShowQueries()

void TProof::ShowQueries

(

Option_t *

opt = ""

)

Ask the master for the list of queries.

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

Definition at line 2165 of file TProof.cxx.

ShowStagingStatusDataSet()

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

virtual

Like GetStagingStatusDataSet, but displays results immediately.

Definition at line 11116 of file TProof.cxx.

SlaveStartupThread()

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

staticprotected

StartSlaves()

Bool_t TProof::StartSlaves ( Bool_t  attach = kFALSE )

protectedvirtual

Start up PROOF slaves.

Reimplemented in TProofCondor, and TProofSuperMaster.

Definition at line 1660 of file TProof.cxx.

StartupMessage()

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

Send startup message.

Definition at line 9312 of file TProof.cxx.

StopProcess()

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

Send STOPPROCESS message to master and workers.

Definition at line 6224 of file TProof.cxx.

Streamer()

void TProof::Streamer ( TBuffer &  R__b )

overridevirtual

Stream an object of class TObject.

Reimplemented from TNamed.

Reimplemented in TProofCondor, TProofLite, and TProofSuperMaster.

StreamerNVirtual()

void TProof::StreamerNVirtual ( TBuffer &  ClassDef_StreamerNVirtual_b )

inline

Definition at line 1073 of file TProof.h.

SystemCmd()

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

staticprotected

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

Definition at line 7735 of file TProof.cxx.

TerminateWorker() [1/2]

void TProof::TerminateWorker ( const char *  ord )

private

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

Definition at line 4720 of file TProof.cxx.

TerminateWorker() [2/2]

void TProof::TerminateWorker ( TSlave *  wrk )

private

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

Definition at line 4696 of file TProof.cxx.

Touch()

void TProof::Touch

(

)

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

Definition at line 4782 of file TProof.cxx.

UnloadPackage()

Int_t TProof::UnloadPackage ( const char *  package )

private

Unload specified package.

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

Definition at line 8114 of file TProof.cxx.

UnloadPackages()

Int_t TProof::UnloadPackages ( )

private

Unload all packages.

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

Definition at line 8147 of file TProof.cxx.

UpdateDialog()

void TProof::UpdateDialog ( )

protected

Final update of the progress dialog.

Definition at line 4353 of file TProof.cxx.

UploadDataSet() [1/2]

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

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

*** Please use TProofMgr::UploadFiles.

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

Definition at line 10666 of file TProof.cxx.

UploadDataSet() [2/2]

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

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

*** Please use TProofMgr::UploadFiles.

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

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

Definition at line 10635 of file TProof.cxx.

UploadDataSetFromFile()

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

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

*** Please use TProofMgr::UploadFiles.

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

Definition at line 10684 of file TProof.cxx.

UploadPackage()

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

Upload a PROOF archive (PAR file).

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

Definition at line 8441 of file TProof.cxx.

UseDynamicStartup()

Bool_t TProof::UseDynamicStartup ( ) const

inline

Definition at line 921 of file TProof.h.

ValidateDSet()

void TProof::ValidateDSet ( TDSet *  dset )

protectedvirtual

Validate a TDSet.

Reimplemented in TProofSuperMaster.

Definition at line 9380 of file TProof.cxx.

VerifyDataSet()

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

virtual

Verify if all files in the specified dataset are available.

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

Reimplemented in TProofLite.

Definition at line 11130 of file TProof.cxx.

VerifyDataSetParallel()

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

protected

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

Definition at line 11181 of file TProof.cxx.

Friends And Related Symbol Documentation

TDataSetManager

friend class TDataSetManager

friend

Definition at line 322 of file TProof.h.

TPacketizer

friend class TPacketizer

friend

Definition at line 318 of file TProof.h.

TPacketizerAdaptive

friend class TPacketizerAdaptive

friend

Definition at line 320 of file TProof.h.

TPacketizerDev

friend class TPacketizerDev

friend

Definition at line 319 of file TProof.h.

TProofInputHandler

friend class TProofInputHandler

friend

Definition at line 324 of file TProof.h.

TProofInterruptHandler

friend class TProofInterruptHandler

friend

Definition at line 325 of file TProof.h.

TProofLite

friend class TProofLite

friend

Definition at line 321 of file TProof.h.

TProofPlayer

friend class TProofPlayer

friend

Definition at line 326 of file TProof.h.

TProofPlayerLite

friend class TProofPlayerLite

friend

Definition at line 327 of file TProof.h.

TProofPlayerRemote

friend class TProofPlayerRemote

friend

Definition at line 328 of file TProof.h.

TProofProgressDialog

friend class TProofProgressDialog

friend

Definition at line 329 of file TProof.h.

TProofServ

friend class TProofServ

friend

Definition at line 323 of file TProof.h.

TSlave

friend class TSlave

friend

Definition at line 330 of file TProof.h.

TSlaveLite

friend class TSlaveLite

friend

Definition at line 331 of file TProof.h.

TVirtualPacketizer

friend class TVirtualPacketizer

friend

Definition at line 332 of file TProof.h.

TXProofMgr

friend class TXProofMgr

friend

Definition at line 336 of file TProof.h.

TXProofServ

friend class TXProofServ

friend

Definition at line 337 of file TProof.h.

TXSlave

friend class TXSlave

friend

Definition at line 333 of file TProof.h.

TXSocket

friend class TXSocket

friend

Definition at line 334 of file TProof.h.

TXSocketHandler

friend class TXSocketHandler

friend

Definition at line 335 of file TProof.h.

Member Data Documentation

fActiveMonitor

TMonitor* TProof::fActiveMonitor

private

Definition at line 484 of file TProof.h.

fActiveSlaves

TList* TProof::fActiveSlaves

private

Definition at line 477 of file TProof.h.

fActiveSlavesSaved

TString TProof::fActiveSlavesSaved

private

Definition at line 478 of file TProof.h.

fAllMonitor

TMonitor* TProof::fAllMonitor

protected

Definition at line 575 of file TProof.h.

fAllUniqueMonitor

TMonitor* TProof::fAllUniqueMonitor

private

Definition at line 486 of file TProof.h.

fAllUniqueSlaves

TList* TProof::fAllUniqueSlaves

private

Definition at line 482 of file TProof.h.

fAvailablePackages

TList* TProof::fAvailablePackages

protected

Definition at line 579 of file TProof.h.

fBadSlaves

TList* TProof::fBadSlaves

protected

Definition at line 574 of file TProof.h.

fBytesRead

Long64_t TProof::fBytesRead

private

Definition at line 488 of file TProof.h.

fBytesReady

Long64_t TProof::fBytesReady

protected

Definition at line 577 of file TProof.h.

fChains

TList* TProof::fChains

private

Definition at line 496 of file TProof.h.

fCheckFileStatus

Int_t TProof::fCheckFileStatus

private

Definition at line 471 of file TProof.h.

fCloseMutex

std::recursive_mutex TProof::fCloseMutex

private

Definition at line 542 of file TProof.h.

fCollectTimeout

Int_t TProof::fCollectTimeout

protected

Definition at line 583 of file TProof.h.

fConfDir

TString TProof::fConfDir

protected

Definition at line 569 of file TProof.h.

fConfFile

TString TProof::fConfFile

protected

Definition at line 568 of file TProof.h.

fCpuTime

Float_t TProof::fCpuTime

private

Definition at line 490 of file TProof.h.

fCurrentMonitor

TMonitor* TProof::fCurrentMonitor

private

Definition at line 487 of file TProof.h.

fDataPoolUrl

TString TProof::fDataPoolUrl

protected

Definition at line 585 of file TProof.h.

fDataReady

Bool_t TProof::fDataReady

protected

Definition at line 576 of file TProof.h.

fDrawQueries

Int_t TProof::fDrawQueries

private

Definition at line 524 of file TProof.h.

fDSet

TDSet* TProof::fDSet

private

Definition at line 503 of file TProof.h.

fDynamicStartup

Bool_t TProof::fDynamicStartup

protected

Definition at line 589 of file TProof.h.

fEnabledPackages

TList* TProof::fEnabledPackages

protected

Definition at line 580 of file TProof.h.

fEnabledPackagesOnCluster

TList* TProof::fEnabledPackagesOnCluster

private

Definition at line 533 of file TProof.h.

fEndMaster

Bool_t TProof::fEndMaster

private

Definition at line 530 of file TProof.h.

fFeedback

TList* TProof::fFeedback

private

Definition at line 495 of file TProof.h.

fFileMap

FileMap_t TProof::fFileMap

private

Definition at line 502 of file TProof.h.

fFinalizationRunning

Bool_t TProof::fFinalizationRunning

private

Definition at line 554 of file TProof.h.

fgLogViewer

TPluginHandler * TProof::fgLogViewer = 0

staticprivate

Definition at line 561 of file TProof.h.

fgProofEnvList

TList * TProof::fgProofEnvList = 0

staticprivate

Definition at line 545 of file TProof.h.

fGroup

TString TProof::fGroup

private

Definition at line 468 of file TProof.h.

fImage

TString TProof::fImage

protected

Definition at line 570 of file TProof.h.

fInactiveSlaves

TList* TProof::fInactiveSlaves

private

Definition at line 480 of file TProof.h.

fInputData

TList* TProof::fInputData

private

Definition at line 535 of file TProof.h.

fInputDataFile

TString TProof::fInputDataFile

private

Definition at line 536 of file TProof.h.

fIntHandler

TSignalHandler* TProof::fIntHandler

private

Definition at line 491 of file TProof.h.

fIsPollingWorkers

Bool_t TProof::fIsPollingWorkers

private

Definition at line 475 of file TProof.h.

fIsWaiting

Bool_t TProof::fIsWaiting

private

Definition at line 508 of file TProof.h.

fLastAssignedMerger

Int_t TProof::fLastAssignedMerger

private

Definition at line 552 of file TProof.h.

fLastPollWorkers_s

Long64_t TProof::fLastPollWorkers_s

private

Definition at line 476 of file TProof.h.

fLoadedMacros

TList* TProof::fLoadedMacros

private

Definition at line 544 of file TProof.h.

fLogFileName

TString TProof::fLogFileName

private

Definition at line 511 of file TProof.h.

fLogFileR

FILE* TProof::fLogFileR

private

Definition at line 513 of file TProof.h.

fLogFileW

FILE* TProof::fLogFileW

private

Definition at line 512 of file TProof.h.

fLogLevel

Int_t TProof::fLogLevel

private

Definition at line 469 of file TProof.h.

fLogToWindowOnly

Bool_t TProof::fLogToWindowOnly

private

Definition at line 514 of file TProof.h.

fMacroLog

TMacro TProof::fMacroLog

private

Definition at line 517 of file TProof.h.

fManager

TProofMgr* TProof::fManager

protected

Definition at line 587 of file TProof.h.

fMaster

TString TProof::fMaster

private

Definition at line 466 of file TProof.h.

fMasterServ

Bool_t TProof::fMasterServ

protected

Definition at line 566 of file TProof.h.

fMaxDrawQueries

Int_t TProof::fMaxDrawQueries

private

Definition at line 525 of file TProof.h.

fMergePrg

TProofMergePrg TProof::fMergePrg

private

Definition at line 519 of file TProof.h.

fMergers

TList* TProof::fMergers

private

Definition at line 553 of file TProof.h.

fMergersByHost

Bool_t TProof::fMergersByHost

private

Definition at line 549 of file TProof.h.

fMergersCount

Int_t TProof::fMergersCount

private

Definition at line 550 of file TProof.h.

fMergersSet

Bool_t TProof::fMergersSet

private

Definition at line 548 of file TProof.h.

fNonUniqueMasters

TList* TProof::fNonUniqueMasters

private

Definition at line 483 of file TProof.h.

fNotIdle

Int_t TProof::fNotIdle

private

Definition at line 505 of file TProof.h.

fOtherQueries

Int_t TProof::fOtherQueries

private

Definition at line 523 of file TProof.h.

fOutputList

TProofOutputList TProof::fOutputList

private

Definition at line 538 of file TProof.h.

fPackMgr

TPackMgr* TProof::fPackMgr

private

Definition at line 532 of file TProof.h.

fPerfTree

TString TProof::fPerfTree

private

Definition at line 557 of file TProof.h.

fPlayer

TVirtualProofPlayer* TProof::fPlayer

private

Definition at line 494 of file TProof.h.

fPrepTime

Float_t TProof::fPrepTime

protected

Definition at line 594 of file TProof.h.

fPrintProgress

PrintProgress_t TProof::fPrintProgress

private

Definition at line 540 of file TProof.h.

fProgressDialog

TPluginHandler* TProof::fProgressDialog

private

Definition at line 492 of file TProof.h.

fProgressDialogStarted

Bool_t TProof::fProgressDialogStarted

private

Definition at line 493 of file TProof.h.

fProtocol

Int_t TProof::fProtocol

protected

Definition at line 571 of file TProof.h.

fQueries

TList* TProof::fQueries

private

Definition at line 522 of file TProof.h.

fQueryMode

EQueryMode TProof::fQueryMode

protected

Definition at line 588 of file TProof.h.

fQuerySTW

TStopwatch TProof::fQuerySTW

protected

Definition at line 593 of file TProof.h.

fRealTime

Float_t TProof::fRealTime

private

Definition at line 489 of file TProof.h.

fRecvMessages

TList* TProof::fRecvMessages

private

Definition at line 472 of file TProof.h.

fRedirectNext

Int_t TProof::fRedirectNext

private

Definition at line 555 of file TProof.h.

fRedirLog

Bool_t TProof::fRedirLog

private

Definition at line 510 of file TProof.h.

fRunningDSets

TList* TProof::fRunningDSets

protected

Definition at line 581 of file TProof.h.

fRunStatus

ERunStatus TProof::fRunStatus

private

Definition at line 507 of file TProof.h.

fSaveLogToMacro

Bool_t TProof::fSaveLogToMacro

private

Definition at line 516 of file TProof.h.

fSelector

TSelector* TProof::fSelector

protected

Definition at line 591 of file TProof.h.

fSendGroupView

Bool_t TProof::fSendGroupView

private

list returned by kPROOF_GETSLAVEINFO

Definition at line 474 of file TProof.h.

fSeqNum

Int_t TProof::fSeqNum

private

Definition at line 526 of file TProof.h.

fServType

TProofMgr::EServType TProof::fServType

protected

Definition at line 586 of file TProof.h.

fSessionID

Int_t TProof::fSessionID

private

Definition at line 528 of file TProof.h.

fSlaveInfo

TList* TProof::fSlaveInfo

private

Definition at line 473 of file TProof.h.

fSlaves

TList* TProof::fSlaves

protected

Definition at line 572 of file TProof.h.

fStatus

Int_t TProof::fStatus

private

Definition at line 470 of file TProof.h.

fSync

Bool_t TProof::fSync

private

Definition at line 506 of file TProof.h.

fTerminatedSlaveInfos

TList* TProof::fTerminatedSlaveInfos

protected

Definition at line 573 of file TProof.h.

fTotalBytes

Long64_t TProof::fTotalBytes

protected

Definition at line 578 of file TProof.h.

fTty

Bool_t TProof::fTty

private

Definition at line 465 of file TProof.h.

fUniqueMonitor

TMonitor* TProof::fUniqueMonitor

private

Definition at line 485 of file TProof.h.

fUniqueSlaves

TList* TProof::fUniqueSlaves

private

Definition at line 481 of file TProof.h.

fUrl

TUrl TProof::fUrl

protected

Definition at line 567 of file TProof.h.

fValid

Bool_t TProof::fValid

private

Definition at line 464 of file TProof.h.

fWaitingSlaves

TList* TProof::fWaitingSlaves

private

Definition at line 521 of file TProof.h.

fWorkDir

TString TProof::fWorkDir

private

Definition at line 467 of file TProof.h.

fWorkersToMerge

Int_t TProof::fWorkersToMerge

private

Definition at line 551 of file TProof.h.

fWrksOutputReady

TList* TProof::fWrksOutputReady

private

Definition at line 559 of file TProof.h.