Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
TProofServLite Class Reference

Version of the PROOF worker server for local running.

The client starts directly the desired number of these workers; the master and daemons are eliminated, optimizing the number of messages exchanged and created / destroyed.

Definition at line 30 of file TProofServLite.h.

Public Member Functions

 TProofServLite (Int_t *argc, char **argv, FILE *flog=0)
 Main constructor.
 
 ~TProofServLite () override
 Cleanup.
 
Int_t CreateServer () override
 Finalize the server setup.
 
void HandleFork (TMessage *mess) override
 Cloning itself via fork.
 
void HandleSigPipe () override
 Called when the client is not alive anymore; terminate the session.
 
void HandleTermination () override
 Called when the client is not alive anymore; terminate the session.
 
TClassIsA () const override
 
void Streamer (TBuffer &) override
 Stream an object of class TObject.
 
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
 
void Terminate (Int_t status) override
 Terminate the proof server.
 
- Public Member Functions inherited from TProofServ
 TProofServ (Int_t *argc, char **argv, FILE *flog=0)
 Main constructor.
 
 ~TProofServ () override
 Cleanup.
 
virtual void DisableTimeout ()
 
virtual void EnableTimeout ()
 
void FlushLogFile ()
 Reposition the read pointer in the log file to the very end.
 
TObjectGet (const char *namecycle)
 Get object with name "name;cycle" (e.g.
 
Int_t GetActSessions () const
 
const char * GetCacheDir () const
 
TProofLockPathGetCacheLock ()
 
const char * GetConfDir () const
 
const char * GetConfFile () const
 
Float_t GetCpuTime () const
 
const char * GetDataDir () const
 
const char * GetDataDirOpts () const
 
Float_t GetEffSessions () const
 
TListGetEnabledPackages () 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
 
TDSetElementGetNextPacket (Long64_t totalEntries=-1)
 Get next range of entries to be processed on this server.
 
void GetOptions (Int_t *argc, char **argv) override
 Get and handle command line options.
 
const char * GetOrdinal () const
 
TPackMgrGetPackMgr () const
 
const char * GetPrefix () const
 
TProofGetProof () 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
 
TSocketGetSocket () 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.
 
void HandleException (Int_t sig) override
 Exception handler: we do not try to recover here, just exit.
 
virtual void HandleSocketInput ()
 Handle input coming from the client or from the master server.
 
virtual Int_t HandleSocketInput (TMessage *mess, Bool_t all)
 Process input coming from the client or from the master server.
 
virtual void HandleUrgentData ()
 Handle Out-Of-Band data sent by the master or client.
 
void Interrupt ()
 
Bool_t IsEndMaster () const
 
Bool_t IsMaster () const
 
Bool_t IsParallel () const
 True if in parallel mode.
 
Bool_t IsTopMaster () const
 
void LogToMaster (Bool_t on=kTRUE)
 
void Print (Option_t *option="") const override
 Print status of slave server.
 
Int_t ReceiveFile (const char *file, Bool_t bin, Long64_t size)
 Receive a file, either sent by a client or a master server.
 
virtual void ReleaseWorker (const char *)
 
void Reset (const char *dir)
 Reset PROOF environment to be ready for execution of next command.
 
void RestartComputeTime ()
 Reset the compute time.
 
void Run (Bool_t retrn=kFALSE) override
 Main server eventloop.
 
void SendAsynMessage (const char *msg, Bool_t lf=kTRUE)
 Send an asychronous message to the master / client .
 
virtual void SendLogFile (Int_t status=0, Int_t start=-1, Int_t end=-1)
 Send log file to master.
 
void SendParallel (Bool_t async=kFALSE)
 Send number of parallel nodes to master or client.
 
void SendStatistics ()
 Send statistics of slave server to master or client.
 
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
 
void TruncateLogFile ()
 Truncate the log file to the 80% of the required max size if this is set.
 
Int_t UpdateSessionStatus (Int_t xst=-1)
 Update the session status in the relevant file.
 
- Public Member Functions inherited from TApplication
 TApplication (const char *appClassName, Int_t *argc, char **argv, void *options=nullptr, Int_t numOptions=0)
 Create an application environment.
 
virtual ~TApplication ()
 TApplication dtor.
 
virtual const char * ApplicationName () const
 
Int_t Argc () const
 
char ** Argv () const
 
char * Argv (Int_t index) const
 Return specified argument.
 
void ClearInputFiles ()
 Clear list containing macro files passed as program arguments.
 
EExitOnException ExitOnException (EExitOnException opt=kExit)
 Set the exit on exception option.
 
virtual TApplicationImpGetApplicationImp ()
 
TApplicationGetAppRemote () const
 
const char * GetIdleCommand () const
 
TString GetSetup ()
 It gets the ROOT installation setup as TString.
 
TSignalHandlerGetSignalHandler () const
 
virtual void HandleIdleTimer ()
 Handle idle timeout.
 
virtual Bool_t HandleTermInput ()
 
virtual void Hide ()
 
virtual void Iconify ()
 
virtual void Init ()
 
void InitializeGraphics (Bool_t only_web=kFALSE)
 Initialize the graphics environment.
 
TObjArrayInputFiles () const
 
virtual Bool_t IsCmdThread ()
 
Bool_t IsRunning () const
 
virtual void KeyPressed (Int_t key)
 Emit signal when console keyboard key was pressed.
 
virtual void LineProcessed (const char *line)
 Emit signal when a line has been processed.
 
virtual void Lower ()
 
void ls (Option_t *option="") const override
 Show available sessions.
 
Bool_t NoLogoOpt () const
 
Bool_t NoLogOpt () const
 
virtual void Open ()
 
void OpenForumTopic (const TString &type)
 It opens a Forum topic in a web browser with prefilled ROOT version.
 
void OpenGitHubIssue (const TString &type)
 It opens a GitHub issue in a web browser with prefilled ROOT version.
 
void OpenInBrowser (const TString &url)
 The function generates and executes a command that loads the Doxygen URL in a browser.
 
void OpenReferenceGuideFor (const TString &strippedClass)
 It opens the online reference guide, generated with Doxygen, for the chosen scope (class/namespace/struct) or member (method/function/ data member/enumeration/enumerator.
 
virtual Longptr_t ProcessFile (const char *file, Int_t *error=nullptr, Bool_t keep=kFALSE)
 Process a file containing a C++ macro.
 
virtual Longptr_t ProcessLine (const char *line, Bool_t sync=kFALSE, Int_t *error=nullptr)
 Process a single command line, either a C++ statement or an interpreter command starting with a ".".
 
Bool_t QuitOpt () const
 
virtual void Raise ()
 
virtual void RemoveIdleTimer ()
 Remove idle timer. Normally called via TROOT::Idle(0).
 
Bool_t ReturnFromRun () const
 
virtual void ReturnPressed (char *text)
 Emit signal when return key was pressed.
 
virtual void SetEchoMode (Bool_t mode)
 Set console echo mode:
 
virtual void SetIdleTimer (UInt_t idleTimeInSec, const char *command)
 Set the command to be executed after the system has been idle for idleTimeInSec seconds.
 
void SetReturnFromRun (Bool_t ret)
 
virtual void Show ()
 
virtual void StartIdleing ()
 Called when system starts idleing.
 
virtual void StopIdleing ()
 Called when system stops idleing.
 
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
 
virtual Int_t TabCompletionHook (char *buf, int *pLoc, std::ostream &out)
 What to do when tab is pressed.
 
const char * WorkingDirectory () const
 
- 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.
 
virtual void Browse (TBrowser *b)
 Browse object. May be overridden for another default action.
 
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 Clear (Option_t *="")
 
virtual TObjectClone (const char *newname="") const
 Make a clone of an object using the Streamer facility.
 
virtual Int_t Compare (const TObject *obj) const
 Compare abstract method.
 
virtual void Copy (TObject &object) const
 Copy this to obj.
 
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 TObjectDrawClone (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 TObjectFindObject (const char *name) const
 Must be redefined in derived classes.
 
virtual TObjectFindObject (const TObject *obj) const
 Must be redefined in derived classes.
 
virtual Option_tGetDrawOption () const
 Get option used by the graphics system to draw this object.
 
virtual const char * GetIconName () const
 Returns mime type name of object.
 
virtual const char * GetName () const
 Returns 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_tGetOption () const
 
virtual const char * GetTitle () const
 Returns title of object.
 
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.
 
virtual ULong_t Hash () const
 Return hash value for this object.
 
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).
 
virtual Bool_t IsFolder () const
 Returns kTRUE in case object contains browsable objects (like containers or lists of other objects).
 
R__ALWAYS_INLINE Bool_t IsOnHeap () const
 
virtual Bool_t IsSortable () 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)
 
TObjectoperator= (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.
 
TListGetListOfClassSignals () const
 Returns pointer to list of signals of this class.
 
TListGetListOfConnections () const
 
TListGetListOfSignals () 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 TClassClass ()
 
static const char * Class_Name ()
 
static constexpr Version_t Class_Version ()
 
static const char * DeclFileName ()
 
- Static Public Member Functions inherited from TProofServ
static TClassClass ()
 
static const char * Class_Name ()
 
static constexpr Version_t Class_Version ()
 
static const char * DeclFileName ()
 
static void ErrorHandler (Int_t level, Bool_t abort, const char *location, const char *msg)
 The PROOF error handler function.
 
static void FilterLocalroot (TString &path, const char *url="root://dum/")
 If 'path' is local and 'dsrv' is Xrootd, apply 'path.Localroot' settings, if any.
 
static TMapGetDataSetNodeMap (TFileCollection *fc, TString &emsg)
 Get a map {server-name, list-of-files} for collection 'fc' to be used in TPacketizerFile.
 
static void GetLocalServer (TString &dsrv)
 Extract LOCALDATASERVER info in 'dsrv'.
 
static Float_t GetMemHWM ()
 MemHWM getter.
 
static Float_t GetMemStop ()
 MemStop getter.
 
static Long_t GetResMemMax ()
 ResMemMax getter.
 
static Long_t GetVirtMemMax ()
 VirtMemMax getter.
 
static Bool_t IsActive ()
 Static function that returns kTRUE in case we are a PROOF server.
 
static Int_t RegisterDataSets (TList *in, TList *out, TDataSetManager *dsm, TString &e)
 Register TFileCollections in 'out' as datasets according to the rules in 'in'.
 
static void ResolveKeywords (TString &fname, const char *path=0)
 Replace <ord>, <user>, <u>, <group>, <stag>, <qnum>, <file>, <rver> and <build> placeholders in fname.
 
static FILE * SetErrorHandlerFile (FILE *ferr)
 Set the file stream where to log (default stderr).
 
static void SetLastEntry (Long64_t lastentry)
 Set the last entry before exception.
 
static void SetLastMsg (const char *lastmsg)
 Set the message to be sent back in case of exceptions.
 
static TProofServThis ()
 Static function returning pointer to global object gProofServ.
 
- Static Public Member Functions inherited from TApplication
static TClassClass ()
 
static const char * Class_Name ()
 
static constexpr Version_t Class_Version ()
 
static void CreateApplication ()
 Static function used to create a default application environment.
 
static const char * DeclFileName ()
 
static Longptr_t ExecuteFile (const char *file, Int_t *error=nullptr, Bool_t keep=kFALSE)
 Execute a file containing a C++ macro (static method).
 
static TListGetApplications ()
 Static method returning the list of available applications.
 
static void NeedGraphicsLibs ()
 Static method.
 
- Static Public Member Functions inherited from TObject
static TClassClass ()
 
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 TClassClass ()
 
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.
 

Private Member Functions

Int_t Setup () override
 Print the ProofServ logo on standard output.
 
Int_t SetupOnFork (const char *ord)
 Finalize the server setup afetr forking.
 

Private Attributes

TProofServLiteInterruptHandlerfInterruptHandler
 
TString fSockPath
 
Bool_t fTerminated
 

Additional Inherited Members

- Public Types inherited from TProofServ
enum  EQueryAction { kQueryOK , kQueryModify , kQueryStop , kQueryEnqueued }
 
enum  EStatusBits { kHighMemory = (1ULL << ( 17 )) }
 
- Public Types inherited from TApplication
enum  EExitOnException { kDontExit , kExit , kAbort }
 
enum  EFileBits { kExpression = (1ULL << ( 14 )) }
 
enum  EStatusBits { kProcessRemotely = (1ULL << ( 15 )) , kDefaultApplication = (1ULL << ( 16 )) }
 
- 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 ))
}
 
- Protected Types inherited from TObject
enum  { kOnlyPrepStep = (1ULL << ( 3 )) }
 
- Protected Member Functions inherited from TProofServ
virtual void DeletePlayer ()
 Delete player instance.
 
virtual Int_t Fork ()
 Fork a child.
 
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.
 
virtual void HandleArchive (TMessage *mess, TString *slb=0)
 Handle archive request.
 
virtual Int_t HandleCache (TMessage *mess, TString *slb=0)
 Handle here all cache and package requests.
 
virtual void HandleCheckFile (TMessage *mess, TString *slb=0)
 Handle file checking request.
 
virtual Int_t HandleDataSets (TMessage *mess, TString *slb=0)
 Handle here requests about datasets.
 
virtual Int_t HandleLibIncPath (TMessage *mess)
 Handle lib, inc search paths modification request.
 
virtual void HandleProcess (TMessage *mess, TString *slb=0)
 Handle processing request.
 
virtual void HandleQueryList (TMessage *mess)
 Handle request for list of queries.
 
virtual void HandleRemove (TMessage *mess, TString *slb=0)
 Handle remove request.
 
virtual void HandleRetrieve (TMessage *mess, TString *slb=0)
 Handle retrieve request.
 
virtual void HandleSubmerger (TMessage *mess)
 Handle a message of type kPROOF_SUBMERGER.
 
virtual Int_t HandleWorkerLists (TMessage *mess)
 Handle here all requests to modify worker lists.
 
Bool_t IsIdle ()
 Return the idle status.
 
virtual void MakePlayer ()
 Make player instance.
 
virtual void ProcessNext (TString *slb=0)
 process the next query from the queue of submitted jobs.
 
Int_t SetupCommon ()
 Common part (between TProofServ and TXProofServ) of the setup phase.
 
Bool_t UnlinkDataDir (const char *path)
 Scan recursively the datadir and unlink it if empty Return kTRUE if it can be unlinked, kFALSE otherwise.
 
- Protected Member Functions inherited from TApplication
 TApplication ()
 Default ctor. Can be used by classes deriving from TApplication.
 
virtual void Forum (const char *line)
 The function (".forum <type>") submits a new post on the ROOT forum via web browser.
 
virtual void GitHub (const char *line)
 The function (".gh <type>") submits a new issue on GitHub via web browser.
 
virtual void Help (const char *line)
 The function lists useful commands (".help") or opens the online reference guide, generated with Doxygen (".help scope" or ".help scope::member").
 
virtual void LoadGraphicsLibs ()
 Load shared libs necessary for graphics.
 
virtual void MakeBatch ()
 Switch to batch mode.
 
virtual Longptr_t ProcessRemote (const char *line, Int_t *error=nullptr)
 Process the content of a line starting with ".R" (already stripped-off) The format is.
 
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).
 
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.
 
static TApplicationOpen (const char *url, Int_t debug, const char *script)
 Static function used to attach to an existing remote application or to start one.
 
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.
 
- 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 inherited from TApplication
TApplicationfAppRemote
 
- Protected Attributes inherited from TQObject
TListfListOfConnections
 list of signals from this object
 
TListfListOfSignals
 
Bool_t fSignalsBlocked
 list of connections to this object
 
- Static Protected Attributes inherited from TProofServ
static Long64_t fgLastEntry = -1
 
static TString fgLastMsg
 
- Static Protected Attributes inherited from TApplication
static TListfgApplications = nullptr
 
- Static Protected Attributes inherited from TQObject
static Bool_t fgAllSignalsBlocked = kFALSE
 flag used for suppression of signals
 

#include <TProofServLite.h>

Inheritance diagram for TProofServLite:
[legend]

Constructor & Destructor Documentation

◆ TProofServLite()

TProofServLite::TProofServLite ( Int_t argc,
char **  argv,
FILE *  flog = 0 
)

Main constructor.

Definition at line 191 of file TProofServLite.cxx.

◆ ~TProofServLite()

TProofServLite::~TProofServLite ( )
override

Cleanup.

Not really necessary since after this dtor there is no live anyway.

Definition at line 313 of file TProofServLite.cxx.

Member Function Documentation

◆ Class()

static TClass * TProofServLite::Class ( )
static
Returns
TClass describing this class

◆ Class_Name()

static const char * TProofServLite::Class_Name ( )
static
Returns
Name of this class

◆ Class_Version()

static constexpr Version_t TProofServLite::Class_Version ( )
inlinestaticconstexpr
Returns
Version of this class

Definition at line 55 of file TProofServLite.h.

◆ CreateServer()

Int_t TProofServLite::CreateServer ( )
overridevirtual

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 203 of file TProofServLite.cxx.

◆ DeclFileName()

static const char * TProofServLite::DeclFileName ( )
inlinestatic
Returns
Name of the file containing the class declaration

Definition at line 55 of file TProofServLite.h.

◆ HandleFork()

void TProofServLite::HandleFork ( TMessage mess)
overridevirtual

Cloning itself via fork.

Reimplemented from TProofServ.

Definition at line 467 of file TProofServLite.cxx.

◆ HandleSigPipe()

void TProofServLite::HandleSigPipe ( )
overridevirtual

Called when the client is not alive anymore; terminate the session.

Reimplemented from TProofServ.

Definition at line 321 of file TProofServLite.cxx.

◆ HandleTermination()

void TProofServLite::HandleTermination ( )
overridevirtual

Called when the client is not alive anymore; terminate the session.

Reimplemented from TProofServ.

Definition at line 329 of file TProofServLite.cxx.

◆ IsA()

TClass * TProofServLite::IsA ( ) const
inlineoverridevirtual
Returns
TClass describing current object

Reimplemented from TProofServ.

Definition at line 55 of file TProofServLite.h.

◆ Setup()

Int_t TProofServLite::Setup ( )
overrideprivatevirtual

Print the ProofServ logo on standard output.

Return 0 on success, -1 on error

Reimplemented from TProofServ.

Definition at line 338 of file TProofServLite.cxx.

◆ SetupOnFork()

Int_t TProofServLite::SetupOnFork ( const char *  ord)
private

Finalize the server setup afetr forking.

Return 0 on success, -1 on error

Definition at line 506 of file TProofServLite.cxx.

◆ Streamer()

void TProofServLite::Streamer ( TBuffer R__b)
overridevirtual

Stream an object of class TObject.

Reimplemented from TProofServ.

◆ StreamerNVirtual()

void TProofServLite::StreamerNVirtual ( TBuffer ClassDef_StreamerNVirtual_b)
inline

Definition at line 55 of file TProofServLite.h.

◆ Terminate()

void TProofServLite::Terminate ( Int_t  status)
overridevirtual

Terminate the proof server.

Reimplemented from TProofServ.

Definition at line 428 of file TProofServLite.cxx.

Member Data Documentation

◆ fInterruptHandler

TProofServLiteInterruptHandler* TProofServLite::fInterruptHandler
private

Definition at line 33 of file TProofServLite.h.

◆ fSockPath

TString TProofServLite::fSockPath
private

Definition at line 34 of file TProofServLite.h.

◆ fTerminated

Bool_t TProofServLite::fTerminated
private

Definition at line 36 of file TProofServLite.h.

  • proof/proof/inc/TProofServLite.h
  • proof/proof/src/TProofServLite.cxx