ROOT
6.06/09
Reference Guide
|
Definition at line 34 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 | HandleUrgentData () |
Handle high priority data sent by the master or client. 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 | 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... | |
TProof * | GetProof () const |
const char * | GetService () const |
const char * | GetConfDir () const |
const char * | GetConfFile () const |
const char * | GetUser () const |
const char * | GetGroup () const |
const char * | GetWorkDir () const |
const char * | GetImage () const |
const char * | GetSessionTag () const |
const char * | GetTopSessionTag () const |
const char * | GetSessionDir () const |
const char * | GetPackageDir () const |
const char * | GetCacheDir () const |
const char * | GetDataDir () const |
const char * | GetDataDirOpts () const |
Int_t | GetProtocol () const |
const char * | GetOrdinal () const |
Int_t | GetGroupId () const |
Int_t | GetGroupSize () const |
Int_t | GetLogLevel () const |
TSocket * | GetSocket () const |
Float_t | GetRealTime () const |
Float_t | GetCpuTime () const |
Int_t | GetQuerySeqNum () const |
Int_t | GetTotSessions () const |
Int_t | GetActSessions () const |
Float_t | GetEffSessions () const |
void | GetOptions (Int_t *argc, char **argv) |
Get and handle command line options. More... | |
TList * | GetEnabledPackages () const |
Long64_t | GetMsgSizeHWM () const |
const char * | GetPrefix () const |
void | FlushLogFile () |
Reposition the read pointer in the log file to the very end. More... | |
void | TruncateLogFile () |
Truncate the log file to the 80% of the required max size if this is set. More... | |
TProofLockPath * | GetCacheLock () |
virtual void | HandleException (Int_t sig) |
Exception handler: we do not try to recover here, just exit. More... | |
virtual Int_t | HandleSocketInput (TMessage *mess, Bool_t all) |
Process input coming from the client or from the master server. More... | |
virtual void | HandleSocketInput () |
Handle input coming from the client or from the master server. 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 | Run (Bool_t retrn=kFALSE) |
Main server eventloop. More... | |
void | Print (Option_t *option="") const |
Print status of slave server. More... | |
void | RestartComputeTime () |
Reset the compute time. More... | |
TObject * | Get (const char *namecycle) |
Get object with name "name;cycle" (e.g. More... | |
TDSetElement * | GetNextPacket (Long64_t totalEntries=-1) |
Get next range of entries to be processed on this server. More... | |
void | Reset (const char *dir) |
Reset PROOF environment to be ready for execution of next command. 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 Int_t | 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 | SendStatistics () |
Send statistics of slave server to master or client. More... | |
void | SendParallel (Bool_t async=kFALSE) |
Send number of parallel nodes to master or client. More... | |
Int_t | UpdateSessionStatus (Int_t xst=-1) |
Update the session status in the relevant file. More... | |
void | LogToMaster (Bool_t on=kTRUE) |
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... | |
void | InitializeGraphics () |
Initialize the graphics environment. More... | |
TSignalHandler * | GetSignalHandler () const |
virtual void | SetEchoMode (Bool_t mode) |
Set console echo mode: More... | |
virtual void | HandleIdleTimer () |
Handle idle timeout. More... | |
virtual Bool_t | HandleTermInput () |
virtual void | Init () |
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... | |
virtual Long_t | ProcessFile (const char *file, Int_t *error=0, Bool_t keep=kFALSE) |
Process a file containing a C++ macro. 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... | |
virtual void | RemoveIdleTimer () |
Remove idle timer. Normally called via TROOT::Idle(0). More... | |
const char * | GetIdleCommand () const |
virtual void | StartIdleing () |
Called when system starts idleing. More... | |
virtual void | StopIdleing () |
Called when system stops idleing. More... | |
EExitOnException | ExitOnException (EExitOnException opt=kExit) |
Set the exit on exception option. More... | |
virtual const char * | ApplicationName () const |
virtual void | Show () |
virtual void | Hide () |
virtual void | Iconify () |
virtual void | Open () |
virtual void | Raise () |
virtual void | Lower () |
virtual Bool_t | IsCmdThread () |
virtual TApplicationImp * | GetApplicationImp () |
virtual void | ls (Option_t *option="") const |
Show available sessions. More... | |
Int_t | Argc () const |
char ** | Argv () const |
char * | Argv (Int_t index) const |
Return specified argument. More... | |
Bool_t | NoLogOpt () const |
Bool_t | NoLogoOpt () const |
Bool_t | QuitOpt () const |
TObjArray * | InputFiles () const |
const char * | WorkingDirectory () const |
void | ClearInputFiles () |
Clear list containing macro files passed as program arguments. More... | |
TApplication * | GetAppRemote () const |
Bool_t | IsRunning () const |
Bool_t | ReturnFromRun () const |
void | SetReturnFromRun (Bool_t ret) |
virtual void | LineProcessed (const char *line) |
Emit signal when a line has been processed. More... | |
virtual void | KeyPressed (Int_t key) |
Emit signal when console keyboard key was pressed. More... | |
virtual void | ReturnPressed (char *text) |
Emit signal when return key was pressed. More... | |
virtual Int_t | TabCompletionHook (char *buf, int *pLoc, std::ostream &out) |
What to do when tab is pressed. More... | |
Public Member Functions inherited from TObject | |
TObject () | |
TObject (const TObject &object) | |
TObject copy ctor. More... | |
TObject & | operator= (const TObject &rhs) |
TObject assignment operator. More... | |
virtual | ~TObject () |
TObject destructor. More... | |
virtual void | AppendPad (Option_t *option="") |
Append graphics object to current pad. More... | |
virtual 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 | 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 pad. More... | |
virtual void | Dump () const |
Dump contents of object on stdout. More... | |
virtual void | Execute (const char *method, const char *params, Int_t *error=0) |
Execute method on this object with the given parameter string, e.g. More... | |
virtual void | Execute (TMethod *method, TObjArray *params, Int_t *error=0) |
Execute method on this object with parameters stored in the TObjArray. More... | |
virtual void | ExecuteEvent (Int_t event, Int_t px, Int_t py) |
Execute action corresponding to an event at (px,py). More... | |
virtual TObject * | FindObject (const char *name) const |
Must be redefined in derived classes. More... | |
virtual TObject * | FindObject (const TObject *obj) const |
Must be redefined in derived classes. More... | |
virtual Option_t * | GetDrawOption () const |
Get option used by the graphics system to draw this object. More... | |
virtual UInt_t | GetUniqueID () const |
Return the unique object id. More... | |
virtual const char * | GetName () const |
Returns name of object. More... | |
virtual const char * | GetIconName () const |
Returns mime type name of object. More... | |
virtual Option_t * | GetOption () const |
virtual char * | GetObjectInfo (Int_t px, Int_t py) const |
Returns string containing info about the object at position (px,py). More... | |
virtual const char * | GetTitle () const |
Returns title of object. 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... | |
virtual Bool_t | InheritsFrom (const char *classname) const |
Returns kTRUE if object inherits from class "classname". More... | |
virtual Bool_t | InheritsFrom (const TClass *cl) const |
Returns kTRUE if object inherits from TClass cl. More... | |
virtual void | Inspect () const |
Dump contents of this object in a graphics canvas. More... | |
virtual Bool_t | IsFolder () const |
Returns kTRUE in case object contains browsable objects (like containers or lists of other objects). More... | |
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 | IsSortable () const |
Bool_t | IsOnHeap () const |
Bool_t | IsZombie () const |
virtual Bool_t | Notify () |
This method must be overridden to handle object notification. More... | |
virtual void | Paint (Option_t *option="") |
This method must be overridden if a class wants to paint itself. More... | |
virtual void | Pop () |
Pop on object drawn in a pad to the top of the display list. More... | |
virtual Int_t | Read (const char *name) |
Read contents of object with specified name from the current directory. More... | |
virtual void | RecursiveRemove (TObject *obj) |
Recursively remove this object from a list. More... | |
virtual void | SaveAs (const char *filename="", Option_t *option="") const |
Save this object in the file specified by filename. More... | |
virtual void | SavePrimitive (std::ostream &out, Option_t *option="") |
Save a primitive as a C++ statement(s) on output stream "out". More... | |
virtual void | SetDrawOption (Option_t *option="") |
Set drawing option for object. More... | |
virtual void | SetUniqueID (UInt_t uid) |
Set the unique object id. More... | |
virtual void | UseCurrentStyle () |
Set current style settings in this object This function is called when either TCanvas::UseCurrentStyle or TROOT::ForceStyle have been invoked. More... | |
virtual Int_t | Write (const char *name=0, Int_t option=0, Int_t bufsize=0) |
Write this object to the current directory. More... | |
virtual Int_t | Write (const char *name=0, Int_t option=0, Int_t bufsize=0) const |
Write this object to the current directory. More... | |
void * | operator new (size_t sz) |
void * | operator new[] (size_t sz) |
void * | operator new (size_t sz, void *vp) |
void * | operator new[] (size_t sz, void *vp) |
void | operator delete (void *ptr) |
Operator delete. More... | |
void | operator delete[] (void *ptr) |
Operator delete []. More... | |
void | SetBit (UInt_t f, Bool_t set) |
Set or unset the user status bits as specified in f. More... | |
void | SetBit (UInt_t f) |
void | ResetBit (UInt_t f) |
Bool_t | TestBit (UInt_t f) const |
Int_t | TestBits (UInt_t f) const |
void | InvertBit (UInt_t f) |
virtual void | Info (const char *method, const char *msgfmt,...) const |
Issue info message. More... | |
virtual void | Warning (const char *method, const char *msgfmt,...) const |
Issue warning message. More... | |
virtual void | Error (const char *method, const char *msgfmt,...) const |
Issue error message. More... | |
virtual void | SysError (const char *method, const char *msgfmt,...) const |
Issue system error message. More... | |
virtual void | Fatal (const char *method, const char *msgfmt,...) const |
Issue fatal error message. More... | |
void | AbstractMethod (const char *method) const |
Use this method to implement an "abstract" method that you don't want to leave purely abstract. More... | |
void | MayNotUse (const char *method) const |
Use this method to signal that a method (defined in a base class) may not be called in a derived class (in principle against good design since a child class should not provide less functionality than its parent, however, sometimes it is necessary). More... | |
void | Obsolete (const char *method, const char *asOfVers, const char *removedFromVers) const |
Use this method to declare a method obsolete. More... | |
Public Member Functions inherited from TQObject | |
TQObject () | |
TQObject Constructor. More... | |
virtual | ~TQObject () |
TQObject Destructor. More... | |
TList * | GetListOfClassSignals () const |
Returns pointer to list of signals of this class. More... | |
TList * | GetListOfSignals () const |
TList * | GetListOfConnections () const |
Bool_t | AreSignalsBlocked () const |
Bool_t | BlockSignals (Bool_t b) |
void | CollectClassSignalLists (TList &list, TClass *cls) |
Collect class signal lists from class cls and all its base-classes. More... | |
template<typename... T> | |
void | EmitVA (const char *signal_name, Int_t, const T &...params) |
void | EmitVA (const char *signal, Int_t nargs, va_list va)=delete |
void | Emit (const char *signal) |
Acitvate signal without args. More... | |
void | Emit (const char *signal, Long_t *paramArr) |
Emit a signal with a varying number of arguments, paramArr is an array of the parameters. More... | |
void | Emit (const char *signal, const char *params) |
Activate signal with parameter text string. More... | |
void | Emit (const char *signal, Double_t param) |
Activate signal with single parameter. More... | |
void | Emit (const char *signal, Long_t param) |
Activate signal with single parameter. More... | |
void | Emit (const char *signal, Long64_t param) |
Activate signal with single parameter. More... | |
void | Emit (const char *signal, Bool_t param) |
void | Emit (const char *signal, Char_t param) |
void | Emit (const char *signal, UChar_t param) |
void | Emit (const char *signal, Short_t param) |
void | Emit (const char *signal, UShort_t param) |
void | Emit (const char *signal, Int_t param) |
void | Emit (const char *signal, UInt_t param) |
void | Emit (const char *signal, ULong_t param) |
void | Emit (const char *signal, ULong64_t param) |
void | Emit (const char *signal, Float_t param) |
Bool_t | Connect (const char *signal, const char *receiver_class, void *receiver, const char *slot) |
Non-static method is used to connect from the signal of this object to the receiver slot. More... | |
Bool_t | Disconnect (const char *signal=0, void *receiver=0, const char *slot=0) |
Disconnects signal of this object from slot of receiver. More... | |
virtual void | HighPriority (const char *signal_name, const char *slot_name=0) |
virtual void | LowPriority (const char *signal_name, const char *slot_name=0) |
virtual Bool_t | HasConnection (const char *signal_name) const |
Return true if there is any object connected to this signal. More... | |
virtual Int_t | NumberOfSignals () const |
Return number of signals for this object. More... | |
virtual Int_t | NumberOfConnections () const |
Return number of connections for this object. More... | |
virtual void | Connected (const char *) |
virtual void | Disconnected (const char *) |
virtual void | Destroyed () |
virtual void | ChangedBy (const char *method) |
virtual void | Message (const char *msg) |
Public Member Functions inherited from TXHandler | |
TXHandler () | |
virtual | ~TXHandler () |
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 | |
TXProofServInterruptHandler * | fInterruptHandler |
TXSocketHandler * | fInputHandler |
TString | fSockPath |
Bool_t | fTerminated |
Additional Inherited Members | |
Public Types inherited from TProofServ | |
enum | EStatusBits { kHighMemory = BIT(16) } |
enum | EQueryAction { kQueryOK, kQueryModify, kQueryStop, kQueryEnqueued } |
Public Types inherited from TApplication | |
enum | EStatusBits { kProcessRemotely = BIT(15), kDefaultApplication = BIT(16) } |
enum | EFileBits { kExpression = BIT(14) } |
enum | EExitOnException { kDontExit, kExit, kAbort } |
Public Types inherited from TObject | |
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) } |
enum | { kIsOnHeap = 0x01000000, kNotDeleted = 0x02000000, kZombie = 0x04000000, kBitMask = 0x00ffffff } |
enum | { kSingleKey = BIT(0), kOverwrite = BIT(1), kWriteDelete = BIT(2) } |
Static Public Member Functions inherited from TProofServ | |
static Long_t | GetVirtMemMax () |
VirtMemMax getter. More... | |
static Long_t | GetResMemMax () |
ResMemMax getter. More... | |
static Float_t | GetMemHWM () |
MemHWM getter. More... | |
static Float_t | GetMemStop () |
MemStop getter. More... | |
static FILE * | SetErrorHandlerFile (FILE *ferr) |
Set the file stream where to log (default stderr). More... | |
static void | ErrorHandler (Int_t level, Bool_t abort, const char *location, const char *msg) |
The PROOF error handler function. More... | |
static void | ResolveKeywords (TString &fname, const char *path=0) |
Replace <ord>, <user>, <u>, <group>, <stag>, <qnum>, <file>, <rver> and <build> placeholders in fname. More... | |
static void | SetLastMsg (const char *lastmsg) |
Set the message to be sent back in case of exceptions. More... | |
static void | SetLastEntry (Long64_t lastentry) |
Set the last entry before exception. 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 void | GetLocalServer (TString &dsrv) |
Extract LOCALDATASERVER info in 'dsrv'. 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 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 Bool_t | IsActive () |
Static function that returns kTRUE in case we are a PROOF server. More... | |
static TProofServ * | This () |
Static function returning pointer to global object gProofServ. More... | |
Static Public Member Functions inherited from TApplication | |
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 | CreateApplication () |
Static function used to create a default application environment. More... | |
static void | NeedGraphicsLibs () |
Static method. More... | |
Static Public Member Functions inherited from TObject | |
static Long_t | GetDtorOnly () |
Return destructor only flag. More... | |
static void | SetDtorOnly (void *obj) |
Set destructor only flag. More... | |
static Bool_t | GetObjectStat () |
Get status of object stat flag. More... | |
static void | SetObjectStat (Bool_t stat) |
Turn on/off tracking of objects in the TObjectTable. More... | |
Static Public Member Functions inherited from TQObject | |
static Bool_t | Connect (TQObject *sender, const char *signal, const char *receiver_class, void *receiver, const char *slot) |
Create connection between sender and receiver. More... | |
static Bool_t | Connect (const char *sender_class, const char *signal, const char *receiver_class, void *receiver, const char *slot) |
This method allows to make a connection from any object of the same class to a single slot. More... | |
static Bool_t | Disconnect (TQObject *sender, const char *signal=0, void *receiver=0, const char *slot=0) |
Disconnects signal in object sender from slot_method in object receiver. More... | |
static Bool_t | Disconnect (const char *class_name, const char *signal, void *receiver=0, const char *slot=0) |
Disconnects "class signal". More... | |
static Bool_t | AreAllSignalsBlocked () |
Returns true if all signals are blocked. More... | |
static Bool_t | BlockAllSignals (Bool_t b) |
Block or unblock all signals. Returns the previous block status. More... | |
Protected Member Functions inherited from TProofServ | |
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 | HandleSubmerger (TMessage *mess) |
Handle a message of type kPROOF_SUBMERGER. 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 Int_t | HandleWorkerLists (TMessage *mess) |
Handle here all requests to modify worker lists. More... | |
virtual void | ProcessNext (TString *slb=0) |
process the next query from the queue of submitted jobs. More... | |
Int_t | SetupCommon () |
Common part (between TProofServ and TXProofServ) of the setup phase. More... | |
virtual void | MakePlayer () |
Make player instance. More... | |
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... | |
Bool_t | IsIdle () |
Return the idle status. 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 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 The variable 'dir' is the remote directory to be used as working dir. 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... | |
void | SetSignalHandler (TSignalHandler *sh) |
Protected Member Functions inherited from TObject | |
void | MakeZombie () |
virtual void | DoError (int level, const char *location, const char *fmt, va_list va) const |
Interface to ErrorHandler (protected). More... | |
Protected Member Functions inherited from TQObject | |
virtual void * | GetSender () |
virtual const char * | GetSenderClassName () const |
Static Protected Member Functions inherited from TApplication | |
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 [user@]host[:dir] [-l user] [-d dbg] [script]
The variable 'dir' is the remote directory to be used as working dir. 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 void | Close (TApplication *app) |
Static function used to close a remote application. More... | |
Static Protected Member Functions inherited from TQObject | |
static Bool_t | ConnectToClass (TQObject *sender, const char *signal, TClass *receiver_class, void *receiver, const char *slot) |
Create connection between sender and receiver. More... | |
static Bool_t | ConnectToClass (const char *sender_class, const char *signal, TClass *receiver_class, void *receiver, const char *slot) |
This method allows to make connection from any object of the same class to the receiver object. More... | |
static Int_t | CheckConnectArgs (TQObject *sender, TClass *sender_class, const char *signal, TClass *receiver_class, const char *slot) |
Checking of consitency of sender/receiver methods/arguments. More... | |
static TString | CompressName (const char *method_name) |
Protected Attributes inherited from TApplication | |
TApplication * | fAppRemote |
Protected Attributes inherited from TQObject | |
TList * | fListOfSignals |
TList * | fListOfConnections |
list of signals from this object More... | |
Bool_t | fSignalsBlocked |
list of connections to this object More... | |
Static Protected Attributes inherited from TProofServ | |
static TString | fgLastMsg |
static Long64_t | fgLastEntry = -1 |
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 159 of file TXProofServ.cxx.
|
virtual |
Cleanup.
Not really necessary since after this dtor there is no live anyway.
Definition at line 492 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 182 of file TXProofServ.cxx.
|
virtual |
Disable read timeout on the underlying socket.
Reimplemented from TProofServ.
Definition at line 1048 of file TXProofServ.cxx.
|
virtual |
Enable read timeout on the underlying socket.
Reimplemented from TProofServ.
Definition at line 1057 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 788 of file TXProofServ.cxx.
Handle error on the input socket.
Reimplemented from TXHandler.
Definition at line 934 of file TXProofServ.cxx.
Handle asynchronous input on the input socket.
Reimplemented from TXHandler.
Definition at line 969 of file TXProofServ.cxx.
|
virtual |
Called when the client is not alive anymore; terminate the session.
Reimplemented from TProofServ.
Definition at line 613 of file TXProofServ.cxx.
|
virtual |
Called when the client is not alive anymore; terminate the session.
Reimplemented from TProofServ.
Definition at line 623 of file TXProofServ.cxx.
Referenced by HandleUrgentData().
|
virtual |
Handle high priority data sent by the master or client.
Reimplemented from TProofServ.
Definition at line 500 of file TXProofServ.cxx.
Referenced by HandleInput().
|
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 1152 of file TXProofServ.cxx.
|
virtual |
Send message to intermediate coordinator to release worker of last ordinal ord.
Reimplemented from TProofServ.
Definition at line 1209 of file TXProofServ.cxx.
Referenced by GetWorkers().
|
privatevirtual |
Print the ProofServ logo on standard output.
Return 0 on success, -1 on error
Reimplemented from TProofServ.
Definition at line 658 of file TXProofServ.cxx.
Referenced by CreateServer().
Terminate the proof server.
Reimplemented from TProofServ.
Definition at line 1066 of file TXProofServ.cxx.
Referenced by CreateServer(), HandleError(), and HandleTermination().
|
private |
Definition at line 38 of file TXProofServ.h.
Referenced by CreateServer(), Terminate(), and TXProofServ().
|
private |
Definition at line 37 of file TXProofServ.h.
Referenced by TXProofServ().
|
private |
Definition at line 39 of file TXProofServ.h.
Referenced by CreateServer().
|
private |
Definition at line 41 of file TXProofServ.h.
Referenced by Terminate(), and TXProofServ().