ROOT 6.18/05 Reference Guide |
This class implements the XProofD version of TProofServ, with respect to which it differs only for the underlying connection technology.
Definition at line 30 of file TXProofServ.h.
Public Member Functions | |
TXProofServ (Int_t *argc, char **argv, FILE *flog=0) | |
Main constructor. More... | |
virtual | ~TXProofServ () |
Cleanup. More... | |
Int_t | CreateServer () |
Finalize the server setup. More... | |
void | DisableTimeout () |
Disable read timeout on the underlying socket. More... | |
void | EnableTimeout () |
Enable read timeout on the underlying socket. More... | |
EQueryAction | GetWorkers (TList *workers, Int_t &prioritychange, Bool_t resume=kFALSE) |
Get list of workers to be used from now on. More... | |
Bool_t | HandleError (const void *in=0) |
Handle error on the input socket. More... | |
Bool_t | HandleInput (const void *in=0) |
Handle asynchronous input on the input socket. More... | |
void | HandleSigPipe () |
Called when the client is not alive anymore; terminate the session. More... | |
void | HandleTermination () |
Called when the client is not alive anymore; terminate the session. More... | |
void | HandleUrgentData () |
Handle high priority data sent by the master or client. More... | |
void | ReleaseWorker (const char *ord) |
Send message to intermediate coordinator to release worker of last ordinal ord. More... | |
void | Terminate (Int_t status) |
Terminate the proof server. More... | |
Public Member Functions inherited from TProofServ | |
TProofServ (Int_t *argc, char **argv, FILE *flog=0) | |
Main constructor. More... | |
virtual | ~TProofServ () |
Cleanup. More... | |
virtual Int_t | CreateServer () |
Finalize the server setup. More... | |
virtual void | DisableTimeout () |
virtual void | EnableTimeout () |
void | FlushLogFile () |
Reposition the read pointer in the log file to the very end. More... | |
TObject * | Get (const char *namecycle) |
Get object with name "name;cycle" (e.g. More... | |
Int_t | GetActSessions () const |
const char * | GetCacheDir () const |
TProofLockPath * | GetCacheLock () |
const char * | GetConfDir () const |
const char * | GetConfFile () const |
Float_t | GetCpuTime () const |
const char * | GetDataDir () const |
const char * | GetDataDirOpts () const |
Float_t | GetEffSessions () const |
TList * | GetEnabledPackages () const |
const char * | GetGroup () const |
Int_t | GetGroupId () const |
Int_t | GetGroupSize () const |
const char * | GetImage () const |
Int_t | GetLogLevel () const |
Long64_t | GetMsgSizeHWM () const |
TDSetElement * | GetNextPacket (Long64_t totalEntries=-1) |
Get next range of entries to be processed on this server. More... | |
void | GetOptions (Int_t *argc, char **argv) |
Get and handle command line options. More... | |
const char * | GetOrdinal () const |
TPackMgr * | GetPackMgr () const |
const char * | GetPrefix () const |
TProof * | GetProof () const |
Int_t | GetProtocol () const |
Int_t | GetQuerySeqNum () const |
Float_t | GetRealTime () const |
const char * | GetService () const |
const char * | GetSessionDir () const |
const char * | GetSessionTag () const |
TSocket * | GetSocket () const |
const char * | GetTopSessionTag () const |
Int_t | GetTotSessions () const |
const char * | GetUser () const |
const char * | GetWorkDir () const |
virtual EQueryAction | GetWorkers (TList *workers, Int_t &prioritychange, Bool_t resume=kFALSE) |
Get list of workers to be used from now on. More... | |
virtual void | HandleException (Int_t sig) |
Exception handler: we do not try to recover here, just exit. More... | |
virtual void | HandleSigPipe () |
Called when the client is not alive anymore (i.e. More... | |
virtual void | HandleSocketInput () |
Handle input coming from the client or from the master server. More... | |
virtual Int_t | HandleSocketInput (TMessage *mess, Bool_t all) |
Process input coming from the client or from the master server. More... | |
virtual void | HandleTermination () |
virtual void | HandleUrgentData () |
Handle Out-Of-Band data sent by the master or client. More... | |
void | Interrupt () |
Bool_t | IsEndMaster () const |
Bool_t | IsMaster () const |
Bool_t | IsParallel () const |
True if in parallel mode. More... | |
Bool_t | IsTopMaster () const |
void | LogToMaster (Bool_t on=kTRUE) |
void | Print (Option_t *option="") const |
Print status of slave server. More... | |
Int_t | ReceiveFile (const char *file, Bool_t bin, Long64_t size) |
Receive a file, either sent by a client or a master server. More... | |
virtual void | ReleaseWorker (const char *) |
void | Reset (const char *dir) |
Reset PROOF environment to be ready for execution of next command. More... | |
void | RestartComputeTime () |
Reset the compute time. More... | |
void | Run (Bool_t retrn=kFALSE) |
Main server eventloop. More... | |
void | SendAsynMessage (const char *msg, Bool_t lf=kTRUE) |
Send an asychronous message to the master / client . More... | |
virtual void | SendLogFile (Int_t status=0, Int_t start=-1, Int_t end=-1) |
Send log file to master. More... | |
void | SendParallel (Bool_t async=kFALSE) |
Send number of parallel nodes to master or client. More... | |
void | SendStatistics () |
Send statistics of slave server to master or client. More... | |
virtual void | Terminate (Int_t status) |
Terminate the proof server. More... | |
void | TruncateLogFile () |
Truncate the log file to the 80% of the required max size if this is set. More... | |
Int_t | UpdateSessionStatus (Int_t xst=-1) |
Update the session status in the relevant file. More... | |
Public Member Functions inherited from TApplication | |
TApplication (const char *appClassName, Int_t *argc, char **argv, void *options=0, Int_t numOptions=0) | |
Create an application environment. More... | |
virtual | ~TApplication () |
TApplication dtor. More... | |
virtual const char * | ApplicationName () const |
Int_t | Argc () const |
char ** | Argv () const |
char * | Argv (Int_t index) const |
Return specified argument. More... | |
void | ClearInputFiles () |
Clear list containing macro files passed as program arguments. More... | |
EExitOnException | ExitOnException (EExitOnException opt=kExit) |
Set the exit on exception option. More... | |
virtual TApplicationImp * | GetApplicationImp () |
TApplication * | GetAppRemote () const |
const char * | GetIdleCommand () const |
virtual void | GetOptions (Int_t *argc, char **argv) |
Get and handle command line options. More... | |
TSignalHandler * | GetSignalHandler () const |
virtual void | HandleException (Int_t sig) |
Handle exceptions (kSigBus, kSigSegmentationViolation, kSigIllegalInstruction and kSigFloatingException) trapped in TSystem. More... | |
virtual void | HandleIdleTimer () |
Handle idle timeout. More... | |
virtual Bool_t | HandleTermInput () |
virtual void | Hide () |
virtual void | Iconify () |
virtual void | Init () |
void | InitializeGraphics () |
Initialize the graphics environment. More... | |
TObjArray * | InputFiles () const |
virtual Bool_t | IsCmdThread () |
Bool_t | IsRunning () const |
virtual void | KeyPressed (Int_t key) |
Emit signal when console keyboard key was pressed. More... | |
virtual void | LineProcessed (const char *line) |
Emit signal when a line has been processed. More... | |
virtual void | Lower () |
virtual void | ls (Option_t *option="") const |
Show available sessions. More... | |
Bool_t | NoLogoOpt () const |
Bool_t | NoLogOpt () const |
virtual void | Open () |
virtual Long_t | ProcessFile (const char *file, Int_t *error=0, Bool_t keep=kFALSE) |
Process a file containing a C++ macro. More... | |
virtual Long_t | ProcessLine (const char *line, Bool_t sync=kFALSE, Int_t *error=0) |
Process a single command line, either a C++ statement or an interpreter command starting with a ".". More... | |
Bool_t | QuitOpt () const |
virtual void | Raise () |
virtual void | RemoveIdleTimer () |
Remove idle timer. Normally called via TROOT::Idle(0). More... | |
Bool_t | ReturnFromRun () const |
virtual void | ReturnPressed (char *text) |
Emit signal when return key was pressed. More... | |
virtual void | Run (Bool_t retrn=kFALSE) |
Main application eventloop. Calls system dependent eventloop via gSystem. More... | |
virtual void | SetEchoMode (Bool_t mode) |
Set console echo mode: More... | |
virtual void | SetIdleTimer (UInt_t idleTimeInSec, const char *command) |
Set the command to be executed after the system has been idle for idleTimeInSec seconds. More... | |
void | SetReturnFromRun (Bool_t ret) |
virtual void | Show () |
virtual void | StartIdleing () |
Called when system starts idleing. More... | |
virtual void | StopIdleing () |
Called when system stops idleing. More... | |
virtual Int_t | TabCompletionHook (char *buf, int *pLoc, std::ostream &out) |
What to do when tab is pressed. More... | |
virtual void | Terminate (Int_t status=0) |
Terminate the application by call TSystem::Exit() unless application has been told to return from Run(), by a call to SetReturnFromRun(). More... | |
const char * | WorkingDirectory () const |
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... | |
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. More... | |
virtual const char * | ClassName () const |
Returns name of class to which the object belongs. More... | |
virtual void | Clear (Option_t *="") |
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 abstract method. More... | |
virtual void | Copy (TObject &object) const |
Copy this to obj. More... | |
virtual void | Delete (Option_t *option="") |
Delete this object. More... | |
virtual Int_t | DistancetoPrimitive (Int_t px, Int_t py) |
Computes distance from point (px,py) to the object. More... | |
virtual void | Draw (Option_t *option="") |
Default Draw method for all objects. More... | |
virtual void | DrawClass () const |
Draw class inheritance tree of the class to which this object belongs. More... | |
virtual TObject * | DrawClone (Option_t *option="") const |
Draw a clone of this object in the current selected pad for instance with: gROOT->SetSelectedPad(gPad) . More... | |
virtual void | Dump () const |
Dump contents of object on stdout. More... | |
virtual void | Error (const char *method, const char *msgfmt,...) const |
Issue error message. More... | |
virtual void | Execute (const char *method, const char *params, Int_t *error=0) |
Execute method on this object with the given parameter string, e.g. More... | |
virtual void | Execute (TMethod *method, TObjArray *params, Int_t *error=0) |
Execute method on this object with parameters stored in the TObjArray. More... | |
virtual void | ExecuteEvent (Int_t event, Int_t px, Int_t py) |
Execute action corresponding to an event at (px,py). More... | |
virtual void | Fatal (const char *method, const char *msgfmt,...) const |
Issue fatal error message. More... | |
virtual TObject * | FindObject (const char *name) const |
Must be redefined in derived classes. More... | |
virtual TObject * | FindObject (const TObject *obj) const |
Must be redefined in derived classes. More... | |
virtual Option_t * | GetDrawOption () const |
Get option used by the graphics system to draw this object. More... | |
virtual const char * | GetIconName () const |
Returns mime type name of object. More... | |
virtual const char * | GetName () const |
Returns 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 const char * | GetTitle () const |
Returns title of object. More... | |
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 ULong_t | Hash () const |
Return hash value for this object. More... | |
Bool_t | HasInconsistentHash () const |
Return true is the type of this object is known to have an inconsistent setup for Hash and RecursiveRemove (i.e. More... | |
virtual void | Info (const char *method, const char *msgfmt,...) const |
Issue info message. More... | |
virtual Bool_t | InheritsFrom (const char *classname) const |
Returns kTRUE if object inherits from class "classname". More... | |
virtual Bool_t | InheritsFrom (const TClass *cl) const |
Returns kTRUE if object inherits from TClass cl. More... | |
virtual void | Inspect () const |
Dump contents of this object in a graphics canvas. More... | |
void | InvertBit (UInt_t f) |
virtual Bool_t | IsEqual (const TObject *obj) const |
Default equal comparison (objects are equal if they have the same address in memory). More... | |
virtual Bool_t | IsFolder () const |
Returns kTRUE in case object contains browsable objects (like containers or lists of other objects). More... | |
R__ALWAYS_INLINE Bool_t | IsOnHeap () const |
virtual Bool_t | IsSortable () const |
R__ALWAYS_INLINE Bool_t | IsZombie () const |
virtual void | ls (Option_t *option="") const |
The ls function lists the contents of a class on stdout. More... | |
void | MayNotUse (const char *method) const |
Use this method to signal that a method (defined in a base class) may not be called in a derived class (in principle against good design since a child class should not provide less functionality than its parent, however, sometimes it is necessary). More... | |
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 void | Print (Option_t *option="") const |
This method must be overridden when a class wants to print itself. 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) |
void | SetBit (UInt_t f, Bool_t set) |
Set or unset the user status bits as specified in f. More... | |
virtual void | SetDrawOption (Option_t *option="") |
Set drawing option for object. More... | |
virtual void | SetUniqueID (UInt_t uid) |
Set the unique object id. More... | |
virtual void | SysError (const char *method, const char *msgfmt,...) const |
Issue system error message. More... | |
R__ALWAYS_INLINE Bool_t | TestBit (UInt_t f) const |
Int_t | TestBits (UInt_t f) const |
virtual void | UseCurrentStyle () |
Set current style settings in this object This function is called when either TCanvas::UseCurrentStyle or TROOT::ForceStyle have been invoked. More... | |
virtual void | Warning (const char *method, const char *msgfmt,...) const |
Issue warning message. More... | |
virtual Int_t | Write (const char *name=0, Int_t option=0, Int_t bufsize=0) |
Write this object to the current directory. More... | |
virtual Int_t | Write (const char *name=0, Int_t option=0, Int_t bufsize=0) const |
Write this object to the current directory. More... | |
Public Member Functions inherited from TQObject | |
TQObject () | |
TQObject Constructor. More... | |
virtual | ~TQObject () |
TQObject Destructor. More... | |
Bool_t | AreSignalsBlocked () const |
Bool_t | BlockSignals (Bool_t b) |
virtual void | ChangedBy (const char *method) |
void | CollectClassSignalLists (TList &list, TClass *cls) |
Collect class signal lists from class cls and all its base-classes. More... | |
Bool_t | Connect (const char *signal, const char *receiver_class, void *receiver, const char *slot) |
Non-static method is used to connect from the signal of this object to the receiver slot. More... | |
virtual void | Connected (const char *) |
virtual void | Destroyed () |
Bool_t | Disconnect (const char *signal=0, void *receiver=0, const char *slot=0) |
Disconnects signal of this object from slot of receiver. More... | |
virtual void | Disconnected (const char *) |
void | Emit (const char *signal) |
Acitvate signal without args. More... | |
template<typename T > | |
void | Emit (const char *signal, const T &arg) |
Activate signal with single parameter. More... | |
template<typename... T> | |
void | EmitVA (const char *signal_name, Int_t, const T &... params) |
Emit a signal with a varying number of arguments. More... | |
TList * | GetListOfClassSignals () const |
Returns pointer to list of signals of this class. More... | |
TList * | GetListOfConnections () const |
TList * | GetListOfSignals () const |
virtual Bool_t | HasConnection (const char *signal_name) const |
Return true if there is any object connected to this signal. More... | |
virtual void | HighPriority (const char *signal_name, const char *slot_name=0) |
virtual void | LowPriority (const char *signal_name, const char *slot_name=0) |
virtual void | Message (const char *msg) |
virtual Int_t | NumberOfConnections () const |
Return number of connections for this object. More... | |
virtual Int_t | NumberOfSignals () const |
Return number of signals for this object. More... | |
Public Member Functions inherited from TXHandler | |
TXHandler () | |
virtual | ~TXHandler () |
virtual Bool_t | HandleError (const void *in=0) |
Handler of asynchronous error events. More... | |
virtual Bool_t | HandleInput (const void *in=0) |
Handler of asynchronous input events. More... | |
Private Member Functions | |
Int_t | LockSession (const char *sessiontag, TProofLockPath **lck) |
Try locking query area of session tagged sessiontag. More... | |
Int_t | Setup () |
Print the ProofServ logo on standard output. More... | |
Private Attributes | |
TXSocketHandler * | fInputHandler |
TXProofServInterruptHandler * | fInterruptHandler |
TString | fSockPath |
Bool_t | fTerminated |
Additional Inherited Members | |
Public Types inherited from TProofServ | |
enum | EQueryAction { kQueryOK , kQueryModify , kQueryStop , kQueryEnqueued } |
enum | EStatusBits { kHighMemory = BIT(17) } |
Public Types inherited from TApplication | |
enum | EExitOnException { kDontExit , kExit , kAbort } |
enum | EFileBits { kExpression = BIT(14) } |
enum | EStatusBits { kProcessRemotely = BIT(15) , kDefaultApplication = BIT(16) } |
Public Types inherited from TObject | |
enum | { kIsOnHeap = 0x01000000 , kNotDeleted = 0x02000000 , kZombie = 0x04000000 , kInconsistent = 0x08000000 , kBitMask = 0x00ffffff } |
enum | { kSingleKey = BIT(0) , kOverwrite = BIT(1) , kWriteDelete = BIT(2) } |
enum | EDeprecatedStatusBits { kObjInCanvas = BIT(3) } |
enum | EStatusBits { kCanDelete = BIT(0) , kMustCleanup = BIT(3) , kIsReferenced = BIT(4) , kHasUUID = BIT(5) , kCannotPick = BIT(6) , kNoContextMenu = BIT(8) , kInvalidObject = BIT(13) } |
Static Public Member Functions inherited from TProofServ | |
static void | ErrorHandler (Int_t level, Bool_t abort, const char *location, const char *msg) |
The PROOF error handler function. More... | |
static void | FilterLocalroot (TString &path, const char *url="root://dum/") |
If 'path' is local and 'dsrv' is Xrootd, apply 'path.Localroot' settings, if any. More... | |
static TMap * | GetDataSetNodeMap (TFileCollection *fc, TString &emsg) |
Get a map {server-name, list-of-files} for collection 'fc' to be used in TPacketizerFile. More... | |
static void | GetLocalServer (TString &dsrv) |
Extract LOCALDATASERVER info in 'dsrv'. More... | |
static Float_t | GetMemHWM () |
MemHWM getter. More... | |
static Float_t | GetMemStop () |
MemStop getter. More... | |
static Long_t | GetResMemMax () |
ResMemMax getter. More... | |
static Long_t | GetVirtMemMax () |
VirtMemMax getter. More... | |
static Bool_t | IsActive () |
Static function that returns kTRUE in case we are a PROOF server. More... | |
static Int_t | RegisterDataSets (TList *in, TList *out, TDataSetManager *dsm, TString &e) |
Register TFileCollections in 'out' as datasets according to the rules in 'in'. More... | |
static void | ResolveKeywords (TString &fname, const char *path=0) |
Replace <ord>, <user>, , <group>, <stag>, <qnum>, <file>, <rver> and <build> placeholders in fname. More... | |
static FILE * | SetErrorHandlerFile (FILE *ferr) |
Set the file stream where to log (default stderr). More... | |
static void | SetLastEntry (Long64_t lastentry) |
Set the last entry before exception. More... | |
static void | SetLastMsg (const char *lastmsg) |
Set the message to be sent back in case of exceptions. More... | |
static TProofServ * | This () |
Static function returning pointer to global object gProofServ. More... | |
Static Public Member Functions inherited from TApplication | |
static void | CreateApplication () |
Static function used to create a default application environment. More... | |
static Long_t | ExecuteFile (const char *file, Int_t *error=0, Bool_t keep=kFALSE) |
Execute a file containing a C++ macro (static method). More... | |
static TList * | GetApplications () |
Static method returning the list of available applications. More... | |
static void | NeedGraphicsLibs () |
Static method. More... | |
Static Public Member Functions inherited from TObject | |
static Long_t | GetDtorOnly () |
Return destructor only flag. More... | |
static Bool_t | GetObjectStat () |
Get status of object stat flag. More... | |
static void | SetDtorOnly (void *obj) |
Set destructor only flag. More... | |
static void | SetObjectStat (Bool_t stat) |
Turn on/off tracking of objects in the TObjectTable. More... | |
Static Public Member Functions inherited from TQObject | |
static Bool_t | AreAllSignalsBlocked () |
Returns true if all signals are blocked. More... | |
static Bool_t | BlockAllSignals (Bool_t b) |
Block or unblock all signals. Returns the previous block status. More... | |
static Bool_t | Connect (const char *sender_class, const char *signal, const char *receiver_class, void *receiver, const char *slot) |
This method allows to make a connection from any object of the same class to a single slot. More... | |
static Bool_t | Connect (TQObject *sender, const char *signal, const char *receiver_class, void *receiver, const char *slot) |
Create connection between sender and receiver. More... | |
static Bool_t | Disconnect (const char *class_name, const char *signal, void *receiver=0, const char *slot=0) |
Disconnects "class signal". More... | |
static Bool_t | Disconnect (TQObject *sender, const char *signal=0, void *receiver=0, const char *slot=0) |
Disconnects signal in object sender from slot_method in object receiver. More... | |
Protected Member Functions inherited from TProofServ | |
virtual void | DeletePlayer () |
Delete player instance. More... | |
virtual Int_t | Fork () |
Fork a child. More... | |
Int_t | GetSessionStatus () |
Return the status of this session: 0 idle 1 running 2 being terminated (currently unused) 3 queued 4 idle timed-out (not set in here but in TIdleTOTimer::Notify) This is typically run in the reader thread, so access needs to be protected. More... | |
virtual void | HandleArchive (TMessage *mess, TString *slb=0) |
Handle archive request. More... | |
virtual Int_t | HandleCache (TMessage *mess, TString *slb=0) |
Handle here all cache and package requests. More... | |
virtual void | HandleCheckFile (TMessage *mess, TString *slb=0) |
Handle file checking request. More... | |
virtual Int_t | HandleDataSets (TMessage *mess, TString *slb=0) |
Handle here requests about datasets. More... | |
virtual void | HandleFork (TMessage *mess) |
Cloning itself via fork. Not implemented. More... | |
virtual Int_t | HandleLibIncPath (TMessage *mess) |
Handle lib, inc search paths modification request. More... | |
virtual void | HandleProcess (TMessage *mess, TString *slb=0) |
Handle processing request. More... | |
virtual void | HandleQueryList (TMessage *mess) |
Handle request for list of queries. More... | |
virtual void | HandleRemove (TMessage *mess, TString *slb=0) |
Handle remove request. More... | |
virtual void | HandleRetrieve (TMessage *mess, TString *slb=0) |
Handle retrieve request. More... | |
virtual void | HandleSubmerger (TMessage *mess) |
Handle a message of type kPROOF_SUBMERGER. More... | |
virtual Int_t | HandleWorkerLists (TMessage *mess) |
Handle here all requests to modify worker lists. More... | |
Bool_t | IsIdle () |
Return the idle status. More... | |
virtual void | MakePlayer () |
Make player instance. More... | |
virtual void | ProcessNext (TString *slb=0) |
process the next query from the queue of submitted jobs. More... | |
virtual Int_t | Setup () |
Print the ProofServ logo on standard output. More... | |
Int_t | SetupCommon () |
Common part (between TProofServ and TXProofServ) of the setup phase. More... | |
Bool_t | UnlinkDataDir (const char *path) |
Scan recursively the datadir and unlink it if empty Return kTRUE if it can be unlinked, kFALSE otherwise. More... | |
Protected Member Functions inherited from TApplication | |
TApplication () | |
Default ctor. Can be used by classes deriving from TApplication. More... | |
virtual void | Help (const char *line) |
Print help on interpreter. More... | |
virtual void | LoadGraphicsLibs () |
Load shared libs necessary for graphics. More... | |
virtual void | MakeBatch () |
Switch to batch mode. More... | |
virtual Long_t | ProcessRemote (const char *line, Int_t *error=0) |
Process the content of a line starting with ".R" (already stripped-off) The format is. More... | |
void | SetSignalHandler (TSignalHandler *sh) |
Protected Member Functions inherited from TObject | |
virtual void | DoError (int level, const char *location, const char *fmt, va_list va) const |
Interface to ErrorHandler (protected). More... | |
void | MakeZombie () |
Protected Member Functions inherited from TQObject | |
virtual void * | GetSender () |
virtual const char * | GetSenderClassName () const |
Static Protected Member Functions inherited from TApplication | |
static void | Close (TApplication *app) |
Static function used to close a remote application. More... | |
static TApplication * | Open (const char *url, Int_t debug, const char *script) |
Static function used to attach to an existing remote application or to start one. More... | |
static Int_t | ParseRemoteLine (const char *ln, TString &hostdir, TString &user, Int_t &dbg, TString &script) |
Parse the content of a line starting with ".R" (already stripped-off) The format is. More... | |
Static Protected Member Functions inherited from TQObject | |
static Int_t | CheckConnectArgs (TQObject *sender, TClass *sender_class, const char *signal, TClass *receiver_class, const char *slot) |
Checking of consitency of sender/receiver methods/arguments. More... | |
static TString | CompressName (const char *method_name) |
Removes "const" words and blanks from full (with prototype) method name and resolve any typedefs in the method signature. More... | |
static Bool_t | ConnectToClass (const char *sender_class, const char *signal, TClass *receiver_class, void *receiver, const char *slot) |
This method allows to make connection from any object of the same class to the receiver object. More... | |
static Bool_t | ConnectToClass (TQObject *sender, const char *signal, TClass *receiver_class, void *receiver, const char *slot) |
Create connection between sender and receiver. More... | |
Protected Attributes inherited from TApplication | |
TApplication * | fAppRemote |
Protected Attributes inherited from TQObject | |
TList * | fListOfConnections |
list of signals from this object More... | |
TList * | fListOfSignals |
Bool_t | fSignalsBlocked |
list of connections to this object More... | |
Static Protected Attributes inherited from TProofServ | |
static Long64_t | fgLastEntry = -1 |
static TString | fgLastMsg |
Static Protected Attributes inherited from TApplication | |
static TList * | fgApplications = 0 |
Static Protected Attributes inherited from TQObject | |
static Bool_t | fgAllSignalsBlocked = kFALSE |
flag used for suppression of signals More... | |
#include <TXProofServ.h>
TXProofServ::TXProofServ | ( | Int_t * | argc, |
char ** | argv, | ||
FILE * | flog = 0 |
||
) |
Main constructor.
Definition at line 158 of file TXProofServ.cxx.
|
virtual |
Cleanup.
Not really necessary since after this dtor there is no live anyway.
Definition at line 491 of file TXProofServ.cxx.
|
virtual |
Finalize the server setup.
If master, create the TProof instance to talk the worker or submaster nodes. Return 0 on success, -1 on error
Reimplemented from TProofServ.
Definition at line 181 of file TXProofServ.cxx.
|
virtual |
Disable read timeout on the underlying socket.
Reimplemented from TProofServ.
Definition at line 1047 of file TXProofServ.cxx.
|
virtual |
Enable read timeout on the underlying socket.
Reimplemented from TProofServ.
Definition at line 1056 of file TXProofServ.cxx.
|
virtual |
Get list of workers to be used from now on.
The list must be provided by the caller.
Reimplemented from TProofServ.
Definition at line 787 of file TXProofServ.cxx.
Handle error on the input socket.
Reimplemented from TXHandler.
Definition at line 933 of file TXProofServ.cxx.
Handle asynchronous input on the input socket.
Reimplemented from TXHandler.
Definition at line 968 of file TXProofServ.cxx.
|
virtual |
Called when the client is not alive anymore; terminate the session.
Reimplemented from TProofServ.
Definition at line 612 of file TXProofServ.cxx.
|
virtual |
Called when the client is not alive anymore; terminate the session.
Reimplemented from TProofServ.
Definition at line 622 of file TXProofServ.cxx.
|
virtual |
Handle high priority data sent by the master or client.
Reimplemented from TProofServ.
Definition at line 499 of file TXProofServ.cxx.
|
private |
Try locking query area of session tagged sessiontag.
The id of the locking file is returned in fid and must be unlocked via UnlockQueryFile(fid).
Definition at line 1151 of file TXProofServ.cxx.
|
virtual |
Send message to intermediate coordinator to release worker of last ordinal ord.
Reimplemented from TProofServ.
Definition at line 1208 of file TXProofServ.cxx.
|
privatevirtual |
Print the ProofServ logo on standard output.
Return 0 on success, -1 on error
Reimplemented from TProofServ.
Definition at line 657 of file TXProofServ.cxx.
Terminate the proof server.
Reimplemented from TProofServ.
Definition at line 1065 of file TXProofServ.cxx.
|
private |
Definition at line 34 of file TXProofServ.h.
|
private |
Definition at line 33 of file TXProofServ.h.
|
private |
Definition at line 35 of file TXProofServ.h.
|
private |
Definition at line 37 of file TXProofServ.h.