ROOT 6.08/07 Reference Guide |
Implementation of the functionality provided by TProofMgr in the case of a xproofd-based session.
Definition at line 46 of file TXProofMgr.h.
Public Member Functions | |
TXProofMgr (const char *url, Int_t loglevel=-1, const char *alias="") | |
Create a PROOF manager for the standard (old) environment. More... | |
virtual | ~TXProofMgr () |
Destructor: close the connection. More... | |
TProof * | AttachSession (Int_t id, Bool_t gui=kFALSE) |
Dummy version provided for completeness. More... | |
TProof * | AttachSession (TProofDesc *d, Bool_t gui=kFALSE) |
Dummy version provided for completeness. More... | |
Int_t | Cp (const char *src, const char *dst=0, const char *opts=0) |
Copy files in/out of the sandbox. More... | |
void | DetachSession (Int_t, Option_t *="") |
Detach session with 'id' from its proofserv. More... | |
void | DetachSession (TProof *, Option_t *="") |
Detach session 'p' from its proofserv. More... | |
void | Find (const char *what="~/", const char *how="-type f", const char *where=0) |
Run 'find' on the nodes. More... | |
Int_t | GetFile (const char *remote, const char *local, const char *opt=0) |
Get file 'remote' into 'local' from the master. More... | |
const char * | GetMssUrl (Bool_t=kFALSE) |
Gets the URL to be prepended to paths when accessing the MSS associated with the connected cluster, if any. More... | |
TProofLog * | GetSessionLogs (Int_t ridx=0, const char *stag=0, const char *pattern="-v \ SvcMsg\, Bool_t rescan=kFALSE) |
Get logs or log tails from last session associated with this manager instance. More... | |
void | Grep (const char *what, const char *how=0, const char *where=0) |
Run 'grep' on the nodes. More... | |
Bool_t | HandleError (const void *in=0) |
Handle error on the input socket. More... | |
Bool_t | HandleInput (const void *) |
Handle asynchronous input on the socket. More... | |
Bool_t | IsValid () const |
void | Ls (const char *what="~/", const char *how=0, const char *where=0) |
Run 'ls' on the nodes. More... | |
Bool_t | MatchUrl (const char *url) |
Checks if 'url' refers to the same 'user:port' entity as the URL in memory. More... | |
Int_t | Md5sum (const char *what, TString &sum, const char *where=0) |
Run 'md5sum' on one of the nodes. More... | |
void | More (const char *what, const char *how=0, const char *where=0) |
Run 'more' on the nodes. More... | |
Int_t | PutFile (const char *local, const char *remote, const char *opt=0) |
Put file 'local'to 'remote' to the master If opt is "force", the file, if it exists remotely, is copied in all cases, otherwise a check is done on the MD5sum. More... | |
TList * | QuerySessions (Option_t *opt="S") |
Get list of sessions accessible to this manager. More... | |
TObjString * | ReadBuffer (const char *file, Long64_t ofs, Int_t len) |
Read, via the coordinator, 'len' bytes from offset 'ofs' of 'file'. More... | |
TObjString * | ReadBuffer (const char *file, const char *pattern) |
Read, via the coordinator, 'fin' filtered. More... | |
Int_t | Reset (Bool_t hard=kFALSE, const char *usr=0) |
Send a cleanup request for the sessions associated with the current user. More... | |
Int_t | Rm (const char *what, const char *how=0, const char *where=0) |
Run 'rm' on the nodes. More... | |
Int_t | SendMsgToUsers (const char *msg, const char *usr=0) |
Send a message to connected users. More... | |
void | SetInvalid () |
Invalidate this manager by closing the connection. More... | |
Int_t | SetROOTVersion (const char *tag) |
Set the default ROOT version to be used. More... | |
void | ShowROOTVersions () |
Display what ROOT versions are available on the cluster. More... | |
void | ShowWorkers () |
Show available workers. More... | |
Int_t | Stat (const char *what, FileStat_t &st, const char *where=0) |
Run 'stat' on one of the nodes. More... | |
void | Tail (const char *what, const char *how=0, const char *where=0) |
Run 'tail' on the nodes. More... | |
Public Member Functions inherited from TProofMgr | |
TProofMgr (const char *url, Int_t loglevel=-1, const char *alias="") | |
Create a PROOF manager for the standard (old) environment. More... | |
virtual | ~TProofMgr () |
Destroy a TProofMgr instance. More... | |
void | Close () |
virtual TProof * | CreateSession (const char *=0, const char *=0, Int_t=-1) |
Create a new remote session (master and associated workers). More... | |
virtual void | DiscardSession (TProof *p) |
Discard TProofDesc of session 'p' from the internal list. More... | |
virtual TProofDesc * | GetProofDesc (Int_t id) |
Get TProofDesc instance corresponding to 'id'. More... | |
virtual TProofDesc * | GetProofDesc (TProof *p) |
Get TProofDesc instance corresponding to TProof object 'p'. More... | |
virtual Int_t | GetRemoteProtocol () const |
virtual const char * | GetUrl () |
virtual Bool_t | IsLite () const |
virtual Bool_t | IsProofd () const |
virtual void | SetAlias (const char *alias="") |
virtual void | SetMssUrl (const char *mss) |
virtual void | ShutdownSession (Int_t id) |
virtual void | ShutdownSession (TProof *p) |
Public Member Functions inherited from TNamed | |
TNamed () | |
TNamed (const char *name, const char *title) | |
TNamed (const TString &name, const TString &title) | |
TNamed (const TNamed &named) | |
TNamed copy ctor. More... | |
virtual | ~TNamed () |
virtual void | Clear (Option_t *option="") |
Set name and title to empty strings (""). More... | |
virtual TObject * | Clone (const char *newname="") const |
Make a clone of an object using the Streamer facility. More... | |
virtual Int_t | Compare (const TObject *obj) const |
Compare two TNamed objects. More... | |
virtual void | Copy (TObject &named) const |
Copy this to obj. More... | |
virtual void | FillBuffer (char *&buffer) |
Encode TNamed into output buffer. More... | |
virtual const char * | GetName () const |
Returns name of object. More... | |
virtual const char * | GetTitle () const |
Returns title of object. More... | |
virtual ULong_t | Hash () const |
Return hash value for this object. More... | |
virtual Bool_t | IsSortable () const |
virtual void | ls (Option_t *option="") const |
List TNamed name and title. More... | |
TNamed & | operator= (const TNamed &rhs) |
TNamed assignment operator. More... | |
virtual void | Print (Option_t *option="") const |
Print TNamed name and title. More... | |
virtual void | SetName (const char *name) |
Set the name of the TNamed. More... | |
virtual void | SetNameTitle (const char *name, const char *title) |
Set all the TNamed parameters (name and title). More... | |
virtual void | SetTitle (const char *title="") |
Set the title of the TNamed. More... | |
virtual Int_t | Sizeof () const |
Return size of the TNamed part of the TObject. More... | |
Public Member Functions inherited from TObject | |
TObject () | |
TObject constructor. More... | |
TObject (const TObject &object) | |
TObject copy ctor. More... | |
virtual | ~TObject () |
TObject destructor. More... | |
void | AbstractMethod (const char *method) const |
Use this method to implement an "abstract" method that you don't want to leave purely abstract. More... | |
virtual void | AppendPad (Option_t *option="") |
Append graphics object to current pad. More... | |
virtual void | Browse (TBrowser *b) |
Browse object. May be overridden for another default action. More... | |
virtual const char * | ClassName () const |
Returns name of class to which the object belongs. More... | |
virtual void | Delete (Option_t *option="") |
Delete this object. More... | |
virtual Int_t | DistancetoPrimitive (Int_t px, Int_t py) |
Computes distance from point (px,py) to the object. More... | |
virtual void | Draw (Option_t *option="") |
Default Draw method for all objects. More... | |
virtual void | DrawClass () const |
Draw class inheritance tree of the class to which this object belongs. More... | |
virtual TObject * | DrawClone (Option_t *option="") const |
Draw a clone of this object in the current pad. More... | |
virtual void | Dump () const |
Dump contents of object on stdout. More... | |
virtual void | Error (const char *method, const char *msgfmt,...) const |
Issue error message. More... | |
virtual void | Execute (const char *method, const char *params, Int_t *error=0) |
Execute method on this object with the given parameter string, e.g. More... | |
virtual void | Execute (TMethod *method, TObjArray *params, Int_t *error=0) |
Execute method on this object with parameters stored in the TObjArray. More... | |
virtual void | ExecuteEvent (Int_t event, Int_t px, Int_t py) |
Execute action corresponding to an event at (px,py). More... | |
virtual void | Fatal (const char *method, const char *msgfmt,...) const |
Issue fatal error message. More... | |
virtual TObject * | FindObject (const char *name) const |
Must be redefined in derived classes. More... | |
virtual TObject * | FindObject (const TObject *obj) const |
Must be redefined in derived classes. More... | |
virtual Option_t * | GetDrawOption () const |
Get option used by the graphics system to draw this object. More... | |
virtual const char * | GetIconName () const |
Returns mime type name of object. More... | |
virtual char * | GetObjectInfo (Int_t px, Int_t py) const |
Returns string containing info about the object at position (px,py). More... | |
virtual Option_t * | GetOption () const |
virtual UInt_t | GetUniqueID () const |
Return the unique object id. More... | |
virtual Bool_t | HandleTimer (TTimer *timer) |
Execute action in response of a timer timing out. More... | |
virtual void | Info (const char *method, const char *msgfmt,...) const |
Issue info message. More... | |
virtual Bool_t | InheritsFrom (const char *classname) const |
Returns kTRUE if object inherits from class "classname". More... | |
virtual Bool_t | InheritsFrom (const TClass *cl) const |
Returns kTRUE if object inherits from TClass cl. More... | |
virtual void | Inspect () const |
Dump contents of this object in a graphics canvas. More... | |
void | InvertBit (UInt_t f) |
virtual Bool_t | IsEqual (const TObject *obj) const |
Default equal comparison (objects are equal if they have the same address in memory). More... | |
virtual Bool_t | IsFolder () const |
Returns kTRUE in case object contains browsable objects (like containers or lists of other objects). More... | |
Bool_t | IsOnHeap () const |
Bool_t | IsZombie () const |
void | MayNotUse (const char *method) const |
Use this method to signal that a method (defined in a base class) may not be called in a derived class (in principle against good design since a child class should not provide less functionality than its parent, however, sometimes it is necessary). More... | |
virtual Bool_t | Notify () |
This method must be overridden to handle object notification. More... | |
void | Obsolete (const char *method, const char *asOfVers, const char *removedFromVers) const |
Use this method to declare a method obsolete. More... | |
void | operator delete (void *ptr) |
Operator delete. More... | |
void | operator delete[] (void *ptr) |
Operator delete []. More... | |
void * | operator new (size_t sz) |
void * | operator new (size_t sz, void *vp) |
void * | operator new[] (size_t sz) |
void * | operator new[] (size_t sz, void *vp) |
TObject & | operator= (const TObject &rhs) |
TObject assignment operator. More... | |
virtual void | Paint (Option_t *option="") |
This method must be overridden if a class wants to paint itself. More... | |
virtual void | Pop () |
Pop on object drawn in a pad to the top of the display list. More... | |
virtual Int_t | Read (const char *name) |
Read contents of object with specified name from the current directory. More... | |
virtual void | RecursiveRemove (TObject *obj) |
Recursively remove this object from a list. More... | |
void | ResetBit (UInt_t f) |
virtual void | SaveAs (const char *filename="", Option_t *option="") const |
Save this object in the file specified by filename. More... | |
virtual void | SavePrimitive (std::ostream &out, Option_t *option="") |
Save a primitive as a C++ statement(s) on output stream "out". More... | |
void | SetBit (UInt_t f, Bool_t set) |
Set or unset the user status bits as specified in f. More... | |
void | SetBit (UInt_t f) |
virtual void | SetDrawOption (Option_t *option="") |
Set drawing option for object. More... | |
virtual void | SetUniqueID (UInt_t uid) |
Set the unique object id. More... | |
virtual void | SysError (const char *method, const char *msgfmt,...) const |
Issue system error message. More... | |
Bool_t | TestBit (UInt_t f) const |
Int_t | TestBits (UInt_t f) const |
virtual void | UseCurrentStyle () |
Set current style settings in this object This function is called when either TCanvas::UseCurrentStyle or TROOT::ForceStyle have been invoked. More... | |
virtual void | Warning (const char *method, const char *msgfmt,...) const |
Issue warning message. More... | |
virtual Int_t | Write (const char *name=0, Int_t option=0, Int_t bufsize=0) |
Write this object to the current directory. More... | |
virtual Int_t | Write (const char *name=0, Int_t option=0, Int_t bufsize=0) const |
Write this object to the current directory. More... | |
Public Member Functions inherited from TXHandler | |
TXHandler () | |
virtual | ~TXHandler () |
Private Member Functions | |
void | CpProgress (const char *pfx, Long64_t bytes, Long64_t size, TStopwatch *watch, Bool_t cr=kFALSE) |
Print file copy progress. More... | |
TObjString * | Exec (Int_t action, const char *what, const char *how, const char *where) |
Execute 'action' (see EAdminExecType in 'XProofProtocol.h') at 'where' (default master), with options 'how', on 'what'. More... | |
Int_t | Init (Int_t loglevel=-1) |
Do real initialization: open the connection and set the relevant variables. More... | |
Private Attributes | |
TXSocket * | fSocket |
Additional Inherited Members | |
Public Types inherited from TProofMgr | |
enum | EServType { kProofd = 0, kXProofd = 1, kProofLite = 2 } |
Public Types inherited from TObject | |
enum | { kIsOnHeap = 0x01000000, kNotDeleted = 0x02000000, kZombie = 0x04000000, kBitMask = 0x00ffffff } |
enum | { kSingleKey = BIT(0), kOverwrite = BIT(1), kWriteDelete = BIT(2) } |
enum | EStatusBits { kCanDelete = BIT(0), kMustCleanup = BIT(3), kObjInCanvas = BIT(3), kIsReferenced = BIT(4), kHasUUID = BIT(5), kCannotPick = BIT(6), kNoContextMenu = BIT(8), kInvalidObject = BIT(13) } |
Static Public Member Functions inherited from TProofMgr | |
static TProofMgr * | Create (const char *url, Int_t loglevel=-1, const char *alias=0, Bool_t xpd=kTRUE) |
Static method returning the appropriate TProofMgr object using the plugin manager. More... | |
static TList * | GetListOfManagers () |
Extract pointers to PROOF managers from TROOT::fProofs. More... | |
static Int_t | Ping (const char *url, Bool_t checkxrd=kFALSE) |
Non-blocking check for a PROOF (or Xrootd, if checkxrd) service at 'url' Return 0 if a XProofd (or Xrootd, if checkxrd) daemon is listening at 'url' -1 if nothing is listening on the port (connection cannot be open) 1 if something is listening but not XProofd (or not Xrootd, if checkxrd) More... | |
static void | SetTXProofMgrHook (TProofMgr_t pmh) |
Set hook to TXProofMgr ctor. More... | |
static TFileCollection * | UploadFiles (TList *src, const char *mss, const char *dest=0) |
Upload files provided via the list 'src' (as TFileInfo or TObjString) to 'mss'. More... | |
static TFileCollection * | UploadFiles (const char *txtfile, const char *mss, const char *dest=0) |
Upload to 'mss' the files listed in the text file 'srcfiles' or contained in the directory 'srcfiles'. More... | |
Static Public Member Functions inherited from TObject | |
static Long_t | GetDtorOnly () |
Return destructor only flag. More... | |
static Bool_t | GetObjectStat () |
Get status of object stat flag. More... | |
static void | SetDtorOnly (void *obj) |
Set destructor only flag. More... | |
static void | SetObjectStat (Bool_t stat) |
Turn on/off tracking of objects in the TObjectTable. More... | |
Protected Member Functions inherited from TProofMgr | |
TProofMgr () | |
Protected Member Functions inherited from TObject | |
virtual void | DoError (int level, const char *location, const char *fmt, va_list va) const |
Interface to ErrorHandler (protected). More... | |
void | MakeZombie () |
Protected Attributes inherited from TProofMgr | |
TSignalHandler * | fIntHandler |
TString | fMssUrl |
Int_t | fRemoteProtocol |
EServType | fServType |
TList * | fSessions |
TUrl | fUrl |
Protected Attributes inherited from TNamed | |
TString | fName |
TString | fTitle |
Static Protected Attributes inherited from TProofMgr | |
static TList | fgListOfManagers |
#include <TXProofMgr.h>
TXProofMgr::TXProofMgr | ( | const char * | url, |
Int_t | loglevel = -1 , |
||
const char * | alias = "" |
||
) |
Create a PROOF manager for the standard (old) environment.
Definition at line 101 of file TXProofMgr.cxx.
|
virtual |
Destructor: close the connection.
Definition at line 159 of file TXProofMgr.cxx.
Dummy version provided for completeness.
Just returns a pointer to existing session 'id' (as shown by TProof::QuerySessions) or 0 if 'id' is not valid. The boolena 'gui' should be kTRUE when invoked from the GUI.
Reimplemented from TProofMgr.
Definition at line 69 of file TXProofMgr.h.
|
virtual |
Dummy version provided for completeness.
Just returns a pointer to existing session 'id' (as shown by TProof::QuerySessions) or 0 if 'id' is not valid. The boolena 'gui' should be kTRUE when invoked from the GUI.
Reimplemented from TProofMgr.
Definition at line 184 of file TXProofMgr.cxx.
|
virtual |
Copy files in/out of the sandbox.
Either 'src' or 'dst' must be in the sandbox. Return 0 on success, -1 on error
Reimplemented from TProofMgr.
Definition at line 1750 of file TXProofMgr.cxx.
|
private |
Print file copy progress.
Definition at line 1716 of file TXProofMgr.cxx.
Detach session with 'id' from its proofserv.
The 'id' is the number shown by QuerySessions. The correspondent TProof object is deleted. If id == 0 all the known sessions are detached. Option opt="S" or "s" forces session shutdown.
Reimplemented from TProofMgr.
Definition at line 236 of file TXProofMgr.cxx.
Detach session 'p' from its proofserv.
The instance 'p' is invalidated and should be deleted by the caller
Reimplemented from TProofMgr.
Definition at line 280 of file TXProofMgr.cxx.
|
private |
Execute 'action' (see EAdminExecType in 'XProofProtocol.h') at 'where' (default master), with options 'how', on 'what'.
The option specified by 'how' are typically unix option for the relate commands. In addition to the unix authorizations, the limitations are:
action = kRm limited to the sandbox (but basic dirs cannot be removed) and on files owned by the user in the allowed directories action = kTail option '-f' is not supported and will be ignored
Definition at line 1203 of file TXProofMgr.cxx.
|
virtual |
Run 'find' on the nodes.
Reimplemented from TProofMgr.
Definition at line 909 of file TXProofMgr.cxx.
|
virtual |
Get file 'remote' into 'local' from the master.
If opt contains "force", the file, if it exists remotely, is copied in all cases, otherwise a check is done on the MD5sum. If opt contains "silent" standard notificatons are not printed (errors and warnings and prompts still are). Return 0 on success, -1 on error.
Reimplemented from TProofMgr.
Definition at line 1281 of file TXProofMgr.cxx.
Gets the URL to be prepended to paths when accessing the MSS associated with the connected cluster, if any.
The information is retrieved from the cluster the first time or if retrieve is true.
Reimplemented from TProofMgr.
Definition at line 369 of file TXProofMgr.cxx.
|
virtual |
Get logs or log tails from last session associated with this manager instance.
The arguments allow to specify a session different from the last one: isess specifies a position relative to the last one, i.e. 1 for the next to last session; the absolute value is taken so -1 and 1 are equivalent. stag specifies the unique tag of the wanted session The special value stag = "NR" allows to just initialize the TProofLog object w/o retrieving the files; this may be useful when the number of workers is large and only a subset of logs is required. If 'stag' is specified 'isess' is ignored (unless stag = "NR"). If 'pattern' is specified only the lines containing it are retrieved (remote grep functionality); to filter out a pattern 'pat' use pattern = "-v pat". If 'rescan' is TRUE, masters will rescan the worker sandboxes for the exact paths, instead of using the save information; may be useful when the ssave information looks wrong or incomplete. Returns a TProofLog object (to be deleted by the caller) on success, 0 if something wrong happened.
Reimplemented from TProofMgr.
Definition at line 592 of file TXProofMgr.cxx.
|
virtual |
Run 'grep' on the nodes.
Reimplemented from TProofMgr.
Definition at line 883 of file TXProofMgr.cxx.
Handle error on the input socket.
Reimplemented from TXHandler.
Definition at line 513 of file TXProofMgr.cxx.
Handle asynchronous input on the socket.
Reimplemented from TXHandler.
Definition at line 485 of file TXProofMgr.cxx.
Do real initialization: open the connection and set the relevant variables.
Login and authentication are dealt with at this level, if required. Return 0 in case of success, 1 if the remote server is a 'proofd', -1 in case of error.
Definition at line 122 of file TXProofMgr.cxx.
|
inlinevirtual |
Reimplemented from TProofMgr.
Definition at line 66 of file TXProofMgr.h.
|
virtual |
|
virtual |
Checks if 'url' refers to the same 'user:port' entity as the URL in memory.
TProofMgr::MatchUrl cannot be used here because of the 'double' default port, implying an additional check on the port effectively open.
Reimplemented from TProofMgr.
Definition at line 308 of file TXProofMgr.cxx.
Run 'md5sum' on one of the nodes.
Reimplemented from TProofMgr.
Definition at line 1078 of file TXProofMgr.cxx.
|
virtual |
Run 'more' on the nodes.
Reimplemented from TProofMgr.
Definition at line 962 of file TXProofMgr.cxx.
|
virtual |
Put file 'local'to 'remote' to the master If opt is "force", the file, if it exists remotely, is copied in all cases, otherwise a check is done on the MD5sum.
Return 0 on success, -1 on error
Reimplemented from TProofMgr.
Definition at line 1515 of file TXProofMgr.cxx.
Get list of sessions accessible to this manager.
Reimplemented from TProofMgr.
Definition at line 403 of file TXProofMgr.cxx.
|
virtual |
Read, via the coordinator, 'len' bytes from offset 'ofs' of 'file'.
Returns a TObjString with the content or 0, in case of failure
Reimplemented from TProofMgr.
Definition at line 680 of file TXProofMgr.cxx.
|
virtual |
Read, via the coordinator, 'fin' filtered.
If 'pattern' starts with '|', it represents a command filtering the output. Elsewhere, it is a grep pattern. Returns a TObjString with the content or 0 in case of failure
Reimplemented from TProofMgr.
Definition at line 697 of file TXProofMgr.cxx.
Send a cleanup request for the sessions associated with the current user.
If 'hard' is true sessions are signalled for termination and moved to terminate at all stages (top master, sub-master, workers). Otherwise (default) only top-master sessions are asked to terminate, triggering a gentle session termination. In all cases all sessions should be gone after a few (2 or 3) session checking cycles. A user with superuser privileges can also asks cleaning for an different user, specified by 'usr', or for all users (usr = *) Return 0 on success, -1 in case of error.
Reimplemented from TProofMgr.
Definition at line 557 of file TXProofMgr.cxx.
|
virtual |
Run 'rm' on the nodes.
The user is prompted before removal, unless 'how' contains "--force" or a combination of single letter options including 'f', e.g. "-fv".
Reimplemented from TProofMgr.
Definition at line 990 of file TXProofMgr.cxx.
|
virtual |
Send a message to connected users.
Only superusers can do this. The first argument specifies the message or the file from where to take the message. The second argument specifies the user to which to send the message: if empty or null the message is send to all the connected users. return 0 in case of success, -1 in case of error
Reimplemented from TProofMgr.
Definition at line 780 of file TXProofMgr.cxx.
|
virtual |
Invalidate this manager by closing the connection.
Reimplemented from TProofMgr.
Definition at line 167 of file TXProofMgr.cxx.
|
virtual |
Set the default ROOT version to be used.
Reimplemented from TProofMgr.
Definition at line 757 of file TXProofMgr.cxx.
|
virtual |
Display what ROOT versions are available on the cluster.
Reimplemented from TProofMgr.
Definition at line 731 of file TXProofMgr.cxx.
|
virtual |
Show available workers.
Reimplemented from TProofMgr.
Definition at line 343 of file TXProofMgr.cxx.
|
virtual |
Run 'stat' on one of the nodes.
Reimplemented from TProofMgr.
Definition at line 1115 of file TXProofMgr.cxx.
|
virtual |
Run 'tail' on the nodes.
Reimplemented from TProofMgr.
Definition at line 1052 of file TXProofMgr.cxx.
|
private |
Definition at line 50 of file TXProofMgr.h.