Logo ROOT  
Reference Guide
TProofServ.h
Go to the documentation of this file.
1 // @(#)root/proof:$Id$
2 // Author: Fons Rademakers 16/02/97
3 
4 /*************************************************************************
5  * Copyright (C) 1995-2000, Rene Brun and Fons Rademakers. *
6  * All rights reserved. *
7  * *
8  * For the licensing terms see $ROOTSYS/LICENSE. *
9  * For the list of contributors see $ROOTSYS/README/CREDITS. *
10  *************************************************************************/
11 
12 
13 #ifndef ROOT_TProofServ
14 #define ROOT_TProofServ
15 
16 //////////////////////////////////////////////////////////////////////////
17 // //
18 // TProofServ //
19 // //
20 // TProofServ is the PROOF server. It can act either as the master //
21 // server or as a slave server, depending on its startup arguments. It //
22 // receives and handles message coming from the client or from the //
23 // master server. //
24 // //
25 //////////////////////////////////////////////////////////////////////////
26 
27 #include "TApplication.h"
28 #include "TString.h"
29 #include "TSysEvtHandler.h"
30 #include "TStopwatch.h"
31 #include "TTimer.h"
32 #include "TPackMgr.h"
33 #include "TProofQueryResult.h"
34 
35 #include <mutex>
36 
37 class TDataSetManager;
39 class TDSet;
40 class TDSetElement;
41 class TFileCollection;
42 class TFileHandler;
43 class THashList;
44 class TIdleTOTimer;
45 class TList;
46 class TMap;
47 class TMessage;
48 class TMonitor;
49 class TPackMgr;
50 class TProof;
51 class TProofLockPath;
53 class TReaperTimer;
54 class TServerSocket;
55 class TShutdownTimer;
56 class TSocket;
58 
59 // Hook to external function setting up authentication related stuff
60 // for old versions.
61 // For backward compatibility
63  TString &, TString &, TString &);
64 
65 
66 class TProofServ : public TApplication {
67 
68 friend class TProofServLite;
69 friend class TXProofServ;
70 
71 public:
72  enum EStatusBits { kHighMemory = BIT(17) };
74 
75 private:
76  TString fService; //service we are running, either "proofserv" or "proofslave"
77  TString fUser; //user as which we run
78  TString fGroup; //group the user belongs to
79  TString fConfDir; //directory containing cluster config information
80  TString fConfFile; //file containing config information
81  TString fWorkDir; //directory containing all proof related info
82  TString fImage; //image name of the session
83  TString fSessionTag; //tag for the server session
84  TString fTopSessionTag; //tag for the global session
85  TString fSessionDir; //directory containing session dependent files
86  TPackMgr *fPackMgr; // Default package manager
87  TString fCacheDir; //directory containing cache of user files
88  TString fQueryDir; //directory containing query results and status
89  TString fDataSetDir; //directory containing info about known data sets
90  TString fDataDir; //directory containing data files produced during queries
91  TString fDataDirOpts; //Url type options for fDataDir
92  TString fAdminPath; //admin path for this session
93  TString fOutputFile; //path with the temporary results of the current or last query
94  TProofLockPath *fCacheLock; //cache dir locker
95  TProofLockPath *fQueryLock; //query dir locker
96  TString fArchivePath; //default archive path
97  TSocket *fSocket; //socket connection to client
98  TProof *fProof; //PROOF talking to slave servers
99  TVirtualProofPlayer *fPlayer; //actual player
100  FILE *fLogFile; //log file
101  Int_t fLogFileDes; //log file descriptor
102  Long64_t fLogFileMaxSize; //max size for log files (enabled if > 0)
103  Int_t fProtocol; //protocol version number
104  TString fOrdinal; //slave ordinal number
105  Int_t fGroupId; //slave unique id in the active slave group
106  Int_t fGroupSize; //size of the active slave group
107  Int_t fLogLevel; //debug logging level
108  Int_t fNcmd; //command history number
109  Int_t fGroupPriority; //priority of group the user belongs to (0 - 100)
110  Bool_t fEndMaster; //true for a master in direct contact only with workers
111  Bool_t fMasterServ; //true if we are a master server
112  Bool_t fInterrupt; //if true macro execution will be stopped
113  Float_t fRealTime; //real time spent executing commands
114  Float_t fCpuTime; //CPU time spent executing commands
115  TStopwatch fLatency; //measures latency of packet requests
116  TStopwatch fCompute; //measures time spent processing a packet
117  TStopwatch fSaveOutput; //measures time spent saving the partial result
118  Int_t fQuerySeqNum; //sequential number of the current or last query
119 
120  Int_t fTotSessions; //Total number of PROOF sessions on the cluster
121  Int_t fActSessions; //Total number of active PROOF sessions on the cluster
122  Float_t fEffSessions; //Effective Number of PROOF sessions on the assigned machines
123 
124  TFileHandler *fInputHandler; //Input socket handler
125 
126  TQueryResultManager *fQMgr; //Query-result manager
127 
128  TList *fWaitingQueries; //list of TProofQueryResult waiting to be processed
129  Bool_t fIdle; //TRUE if idle
130  std::recursive_mutex fQMtx; // To protect async msg queue
131 
132  TList *fQueuedMsg; //list of messages waiting to be processed
133 
134  TString fPrefix; //Prefix identifying the node
135 
136  Bool_t fRealTimeLog; //TRUE if log messages should be send back in real-time
137 
138  TShutdownTimer *fShutdownTimer; // Timer used to shutdown out-of-control sessions
139  TReaperTimer *fReaperTimer; // Timer used to control children state
140  TIdleTOTimer *fIdleTOTimer; // Timer used to control children state
141 
142  Int_t fCompressMsg; // Compression level for messages
143 
144  TDataSetManager* fDataSetManager; // dataset manager
145  TDataSetManagerFile *fDataSetStgRepo; // repository for staging requests
146 
147  Bool_t fSendLogToMaster; // On workers, controls logs sending to master
148 
149  TServerSocket *fMergingSocket; // Socket used for merging outputs if submerger
150  TMonitor *fMergingMonitor; // Monitor for merging sockets
151  Int_t fMergedWorkers; // Number of workers merged
152 
153  // Quotas (-1 to disable)
154  Int_t fMaxQueries; //Max number of queries fully kept
155  Long64_t fMaxBoxSize; //Max size of the sandbox
156  Long64_t fHWMBoxSize; //High-Water-Mark on the sandbox size
157 
158  // Memory limits (-1 to disable) set by envs ROOTPROFOASHARD, PROOF_VIRTMEMMAX, PROOF_RESMEMMAX
159  static Long_t fgVirtMemMax; //Hard limit enforced by the system (in kB)
160  static Long_t fgResMemMax; //Hard limit on the resident memory checked
161  //in TProofPlayer::Process (in kB)
162  static Float_t fgMemHWM; // Threshold fraction of max for warning and finer monitoring
163  static Float_t fgMemStop; // Fraction of max for stop processing
164 
165  // In bytes; default is 1MB
166  Long64_t fMsgSizeHWM; //High-Water-Mark on the size of messages with results
167 
168  static FILE *fgErrorHandlerFile; // File where to log
169  static Int_t fgRecursive; // Keep track of recursive inputs during processing
170 
171  // Control sending information to syslog
172  static Int_t fgLogToSysLog; // >0 sent to syslog too
173  static TString fgSysLogService; // name of the syslog service (eg: proofm-0, proofw-0.67)
174  static TString fgSysLogEntity; // logging entity (<user>:<group>)
175 
176  Int_t GetCompressionLevel() const;
177 
178  void RedirectOutput(const char *dir = 0, const char *mode = "w");
179  Int_t CatMotd();
180  Int_t UnloadPackage(const char *package);
182  Int_t OldAuthSetup(TString &wconf);
183  Int_t GetPriority();
184 
185  // Query handlers
187  TList *inl, Long64_t first, TDSet *dset,
188  const char *selec, TObject *elist);
190 
191  // Results handling
192  Int_t SendResults(TSocket *sock, TList *outlist = 0, TQueryResult *pq = 0);
193  Bool_t AcceptResults(Int_t connections, TVirtualProofPlayer *mergerPlayer);
194 
195  // Waiting queries handlers
196  void SetIdle(Bool_t st = kTRUE);
197  Bool_t IsWaiting();
201  Int_t CleanupWaitingQueries(Bool_t del = kTRUE, TList *qls = 0);
202 
203 protected:
204  virtual void HandleArchive(TMessage *mess, TString *slb = 0);
205  virtual Int_t HandleCache(TMessage *mess, TString *slb = 0);
206  virtual void HandleCheckFile(TMessage *mess, TString *slb = 0);
207  virtual Int_t HandleDataSets(TMessage *mess, TString *slb = 0);
208  virtual void HandleSubmerger(TMessage *mess);
209  virtual void HandleFork(TMessage *mess);
210  virtual Int_t HandleLibIncPath(TMessage *mess);
211  virtual void HandleProcess(TMessage *mess, TString *slb = 0);
212  virtual void HandleQueryList(TMessage *mess);
213  virtual void HandleRemove(TMessage *mess, TString *slb = 0);
214  virtual void HandleRetrieve(TMessage *mess, TString *slb = 0);
215  virtual Int_t HandleWorkerLists(TMessage *mess);
216 
217  virtual void ProcessNext(TString *slb = 0);
218  virtual Int_t Setup();
219  Int_t SetupCommon();
220  virtual void MakePlayer();
221  virtual void DeletePlayer();
222 
223  virtual Int_t Fork();
225  Bool_t IsIdle();
226  Bool_t UnlinkDataDir(const char *path);
227 
228  static TString fgLastMsg; // Message about status before exception
229  static Long64_t fgLastEntry; // Last entry before exception
230 
231 public:
232  TProofServ(Int_t *argc, char **argv, FILE *flog = 0);
233  virtual ~TProofServ();
234 
235  virtual Int_t CreateServer();
236 
237  TProof *GetProof() const { return fProof; }
238  const char *GetService() const { return fService; }
239  const char *GetConfDir() const { return fConfDir; }
240  const char *GetConfFile() const { return fConfFile; }
241  const char *GetUser() const { return fUser; }
242  const char *GetGroup() const { return fGroup; }
243  const char *GetWorkDir() const { return fWorkDir; }
244  const char *GetImage() const { return fImage; }
245  const char *GetSessionTag() const { return fSessionTag; }
246  const char *GetTopSessionTag() const { return fTopSessionTag; }
247  const char *GetSessionDir() const { return fSessionDir; }
248  const char *GetCacheDir() const { return fCacheDir; }
249  TPackMgr *GetPackMgr() const { return fPackMgr; }
250  const char *GetDataDir() const { return fDataDir; }
251  const char *GetDataDirOpts() const { return fDataDirOpts; }
252  Int_t GetProtocol() const { return fProtocol; }
253  const char *GetOrdinal() const { return fOrdinal; }
254  Int_t GetGroupId() const { return fGroupId; }
255  Int_t GetGroupSize() const { return fGroupSize; }
256  Int_t GetLogLevel() const { return fLogLevel; }
257  TSocket *GetSocket() const { return fSocket; }
258  Float_t GetRealTime() const { return fRealTime; }
259  Float_t GetCpuTime() const { return fCpuTime; }
260  Int_t GetQuerySeqNum() const { return fQuerySeqNum; }
261 
262  Int_t GetTotSessions() const { return fTotSessions; }
263  Int_t GetActSessions() const { return fActSessions; }
264  Float_t GetEffSessions() const { return fEffSessions; }
265 
266  void GetOptions(Int_t *argc, char **argv);
268 
269  static Long_t GetVirtMemMax();
270  static Long_t GetResMemMax();
271  static Float_t GetMemHWM();
272  static Float_t GetMemStop();
273 
274  Long64_t GetMsgSizeHWM() const { return fMsgSizeHWM; }
275 
276  const char *GetPrefix() const { return fPrefix; }
277 
278  void FlushLogFile();
279  void TruncateLogFile(); // Called also by TDSetProxy::Next()
280 
281  TProofLockPath *GetCacheLock() { return fCacheLock; } //cache dir locker; used by TProofPlayer
282 
283  virtual EQueryAction GetWorkers(TList *workers, Int_t &prioritychange,
284  Bool_t resume = kFALSE);
285  virtual void HandleException(Int_t sig);
286  virtual Int_t HandleSocketInput(TMessage *mess, Bool_t all);
287  virtual void HandleSocketInput();
288  virtual void HandleUrgentData();
289  virtual void HandleSigPipe();
290  virtual void HandleTermination() { Terminate(0); }
291  void Interrupt() { fInterrupt = kTRUE; }
292  Bool_t IsEndMaster() const { return fEndMaster; }
293  Bool_t IsMaster() const { return fMasterServ; }
294  Bool_t IsParallel() const;
295  Bool_t IsTopMaster() const { return fOrdinal == "0"; }
296 
297  void Run(Bool_t retrn = kFALSE);
298 
299  void Print(Option_t *option="") const;
300 
301  void RestartComputeTime();
302 
303  TObject *Get(const char *namecycle);
304  TDSetElement *GetNextPacket(Long64_t totalEntries = -1);
305  virtual void ReleaseWorker(const char *) { }
306  void Reset(const char *dir);
307  Int_t ReceiveFile(const char *file, Bool_t bin, Long64_t size);
308  void SendAsynMessage(const char *msg, Bool_t lf = kTRUE);
309  virtual void SendLogFile(Int_t status = 0, Int_t start = -1, Int_t end = -1);
310  void SendStatistics();
311  void SendParallel(Bool_t async = kFALSE);
312 
313  Int_t UpdateSessionStatus(Int_t xst = -1);
314 
315  // Disable / Enable read timeout
316  virtual void DisableTimeout() { }
317  virtual void EnableTimeout() { }
318 
319  virtual void Terminate(Int_t status);
320 
321  // Log control
323 
324  static FILE *SetErrorHandlerFile(FILE *ferr);
325  static void ErrorHandler(Int_t level, Bool_t abort, const char *location,
326  const char *msg);
327 
328  static void ResolveKeywords(TString &fname, const char *path = 0);
329 
330  static void SetLastMsg(const char *lastmsg);
331  static void SetLastEntry(Long64_t lastentry);
332 
333  // To handle local data server related paths
334  static void FilterLocalroot(TString &path, const char *url = "root://dum/");
335  static void GetLocalServer(TString &dsrv);
336 
337  // To prepara ethe map of files to process
339  static Int_t RegisterDataSets(TList *in, TList *out, TDataSetManager *dsm, TString &e);
340 
341  static Bool_t IsActive();
342  static TProofServ *This();
343 
344  ClassDef(TProofServ,0) //PROOF Server Application Interface
345 };
346 
348 
349 class TProofLockPath : public TNamed {
350 private:
351  Int_t fLockId; //file id of dir lock
352 
353 public:
354  TProofLockPath(const char *path) : TNamed(path,path), fLockId(-1) { }
356 
357  Int_t Lock();
358  Int_t Unlock();
359 
360  Bool_t IsLocked() const { return (fLockId > -1); }
361 };
362 
364 private:
365  TProofLockPath *fLocker; //locker instance
366 
367 public:
370 };
371 
372 //----- Handles output from commands executed externally via a pipe. ---------//
373 //----- The output is redirected one level up (i.e., to master or client). ---//
374 //______________________________________________________________________________
376 private:
377  TSocket *fSocket; // Socket where to redirect the message
378  FILE *fFile; // File connected with the open pipe
379  TString fPfx; // Prefix to be prepended to messages
380 
381  static TString fgPfx; // Default prefix to be prepended to messages
382  static Int_t fgCmdRtn; // Return code of the command execution (available only
383  // after closing the pipe)
384 public:
385  enum EStatusBits { kFileIsPipe = BIT(23) };
386  TProofServLogHandler(const char *cmd, TSocket *s, const char *pfx = "");
387  TProofServLogHandler(FILE *f, TSocket *s, const char *pfx = "");
388  virtual ~TProofServLogHandler();
389 
390  Bool_t IsValid() { return ((fFile && fSocket) ? kTRUE : kFALSE); }
391 
392  Bool_t Notify();
393  Bool_t ReadNotify() { return Notify(); }
394 
395  static void SetDefaultPrefix(const char *pfx);
396  static Int_t GetCmdRtn();
397 };
398 
399 //--- Guard class: close pipe, deactivatethe related descriptor --------------//
400 //______________________________________________________________________________
402 
403 private:
405 
406 public:
407  TProofServLogHandlerGuard(const char *cmd, TSocket *s,
408  const char *pfx = "", Bool_t on = kTRUE);
410  const char *pfx = "", Bool_t on = kTRUE);
411  virtual ~TProofServLogHandlerGuard();
412 };
413 
414 //--- Special timer to control delayed shutdowns
415 //______________________________________________________________________________
416 class TShutdownTimer : public TTimer {
417 private:
420 
421 public:
422  TShutdownTimer(TProofServ *p, Int_t delay);
423 
424  Bool_t Notify();
425 };
426 
427 //--- Synchronous timer used to reap children processes change of state
428 //______________________________________________________________________________
429 class TReaperTimer : public TTimer {
430 private:
431  TList *fChildren; // List of children (forked) processes
432 
433 public:
434  TReaperTimer(Long_t frequency = 1000) : TTimer(frequency, kTRUE), fChildren(0) { }
435  virtual ~TReaperTimer();
436 
437  void AddPid(Int_t pid);
438  Bool_t Notify();
439 };
440 
441 //--- Special timer to terminate idle sessions
442 //______________________________________________________________________________
443 class TIdleTOTimer : public TTimer {
444 private:
446 
447 public:
448  TIdleTOTimer(TProofServ *p, Int_t delay) : TTimer(delay, kTRUE), fProofServ(p) { }
449 
450  Bool_t Notify();
451 };
452 //______________________________________________________________________________
454 
455 private:
457 
458 public:
461 };
462 
463 //______________________________________________________________________________
465 {
466  return (fCompressMsg < 0) ? -1 : fCompressMsg % 100;
467 }
468 
469 #endif
l
auto * l
Definition: textangle.C:4
TProofServ::GetNextPacket
TDSetElement * GetNextPacket(Long64_t totalEntries=-1)
Get next range of entries to be processed on this server.
Definition: TProofServ.cxx:1143
TProofServ::GetCpuTime
Float_t GetCpuTime() const
Definition: TProofServ.h:259
TProofServ::kQueryOK
@ kQueryOK
Definition: TProofServ.h:73
TProofServ::GetSessionTag
const char * GetSessionTag() const
Definition: TProofServ.h:245
TProofServ::HandleRetrieve
virtual void HandleRetrieve(TMessage *mess, TString *slb=0)
Handle retrieve request.
Definition: TProofServ.cxx:4925
TProofServ::HandleSubmerger
virtual void HandleSubmerger(TMessage *mess)
Handle a message of type kPROOF_SUBMERGER.
Definition: TProofServ.cxx:6435
TProofServLogHandler::fFile
FILE * fFile
Definition: TProofServ.h:378
TProofServ::GetMemStop
static Float_t GetMemStop()
MemStop getter.
Definition: TProofServ.cxx:6944
TProofServ::GetEffSessions
Float_t GetEffSessions() const
Definition: TProofServ.h:264
first
Definition: first.py:1
TProofServ::RegisterDataSets
static Int_t RegisterDataSets(TList *in, TList *out, TDataSetManager *dsm, TString &e)
Register TFileCollections in 'out' as datasets according to the rules in 'in'.
Definition: TProofServ.cxx:4700
TProofServLogHandler::Notify
Bool_t Notify()
Handle available message in the open file.
Definition: TProofServ.cxx:305
TProofServ::fDataDirOpts
TString fDataDirOpts
Definition: TProofServ.h:91
kTRUE
const Bool_t kTRUE
Definition: RtypesCore.h:91
TProofServ::GetConfDir
const char * GetConfDir() const
Definition: TProofServ.h:239
TProofServ::UnloadPackages
Int_t UnloadPackages()
TProofServ::GetActSessions
Int_t GetActSessions() const
Definition: TProofServ.h:263
TProofServ::IsEndMaster
Bool_t IsEndMaster() const
Definition: TProofServ.h:292
e
#define e(i)
Definition: RSha256.hxx:121
TDataSetManagerFile
Definition: TDataSetManagerFile.h:30
TProofServ::Interrupt
void Interrupt()
Definition: TProofServ.h:291
TProofServ::fgLogToSysLog
static Int_t fgLogToSysLog
Definition: TProofServ.h:172
TProofServ::fUser
TString fUser
Definition: TProofServ.h:77
TProofServ::Reset
void Reset(const char *dir)
Reset PROOF environment to be ready for execution of next command.
Definition: TProofServ.cxx:2550
TProofServ::HandleCache
virtual Int_t HandleCache(TMessage *mess, TString *slb=0)
Handle here all cache and package requests.
Definition: TProofServ.cxx:5283
TProofServ::fConfDir
TString fConfDir
Definition: TProofServ.h:79
TProofServ::ProcessNext
virtual void ProcessNext(TString *slb=0)
process the next query from the queue of submitted jobs.
Definition: TProofServ.cxx:4419
f
#define f(i)
Definition: RSha256.hxx:122
TProofServ::fShutdownTimer
TShutdownTimer * fShutdownTimer
Definition: TProofServ.h:138
TProofServ::fOrdinal
TString fOrdinal
Definition: TProofServ.h:104
TProofServ::SendResults
Int_t SendResults(TSocket *sock, TList *outlist=0, TQueryResult *pq=0)
Sends all objects from the given list to the specified socket.
Definition: TProofServ.cxx:4247
TProofServ::fRealTime
Float_t fRealTime
Definition: TProofServ.h:113
fc
static struct mg_connection * fc(struct mg_context *ctx)
Definition: civetweb.c:3728
TProofServ::fAdminPath
TString fAdminPath
Definition: TProofServ.h:92
TProofServ::Get
TObject * Get(const char *namecycle)
Get object with name "name;cycle" (e.g.
Definition: TProofServ.cxx:1093
TProofServ::fSaveOutput
TStopwatch fSaveOutput
Definition: TProofServ.h:117
TProofServ::fGroupPriority
Int_t fGroupPriority
Definition: TProofServ.h:109
TProofServ::fEndMaster
Bool_t fEndMaster
Definition: TProofServ.h:110
TProofServ::DisableTimeout
virtual void DisableTimeout()
Definition: TProofServ.h:316
TProofServ::fProtocol
Int_t fProtocol
Definition: TProofServ.h:103
TProofServ::GetGroupId
Int_t GetGroupId() const
Definition: TProofServ.h:254
TProofServ::fgMemStop
static Float_t fgMemStop
Definition: TProofServ.h:163
TStopwatch.h
TTimer::Start
virtual void Start(Long_t milliSec=-1, Bool_t singleShot=kFALSE)
Starts the timer with a milliSec timeout.
Definition: TTimer.cxx:211
Long64_t
long long Long64_t
Definition: RtypesCore.h:73
TProofServ::Run
void Run(Bool_t retrn=kFALSE)
Main server eventloop.
Definition: TProofServ.cxx:2652
TIdleTOTimer::TIdleTOTimer
TIdleTOTimer(TProofServ *p, Int_t delay)
Definition: TProofServ.h:448
TProofServ::kHighMemory
@ kHighMemory
Definition: TProofServ.h:72
TProofQueryResult.h
TIdleTOTimerGuard::~TIdleTOTimerGuard
virtual ~TIdleTOTimerGuard()
Definition: TProofServ.h:460
TReaperTimer::fChildren
TList * fChildren
Definition: TProofServ.h:431
TProofServ::Setup
virtual Int_t Setup()
Print the ProofServ logo on standard output.
Definition: TProofServ.cxx:2805
TPackMgr::GetListOfEnabled
TList * GetListOfEnabled() const
Get list of enabled packages Returns a pointer to a TList object, transferring ownership to the calle...
Definition: TPackMgr.cxx:644
Float_t
float Float_t
Definition: RtypesCore.h:57
TProofServ::GetProof
TProof * GetProof() const
Definition: TProofServ.h:237
TShutdownTimer::fProofServ
TProofServ * fProofServ
Definition: TProofServ.h:418
TProofServ::QueueQuery
Int_t QueueQuery(TProofQueryResult *pq)
Add a query to the waiting list Returns the number of queries in the list.
Definition: TProofServ.cxx:6859
TGeant4Unit::s
static constexpr double s
Definition: TGeant4SystemOfUnits.h:168
TProofLockPath::IsLocked
Bool_t IsLocked() const
Definition: TProofServ.h:360
TProofServ::SetIdle
void SetIdle(Bool_t st=kTRUE)
Change the idle status.
Definition: TProofServ.cxx:6830
TProofServ::fIdleTOTimer
TIdleTOTimer * fIdleTOTimer
Definition: TProofServ.h:140
TProofServ::OldAuthSetup
Int_t OldAuthSetup(TString &wconf)
Setup authentication related stuff for old versions.
Definition: TProofServ.cxx:3495
Int_t
int Int_t
Definition: RtypesCore.h:45
TProofServ::SetLastMsg
static void SetLastMsg(const char *lastmsg)
Set the message to be sent back in case of exceptions.
Definition: TProofServ.cxx:6907
TProofServLogHandler::fPfx
TString fPfx
Definition: TProofServ.h:379
TProofServ::fMergingSocket
TServerSocket * fMergingSocket
Definition: TProofServ.h:149
TMonitor
Definition: TMonitor.h:36
TProofServ::SendLogFile
virtual void SendLogFile(Int_t status=0, Int_t start=-1, Int_t end=-1)
Send log file to master.
Definition: TProofServ.cxx:2667
TProofServ::TruncateLogFile
void TruncateLogFile()
Truncate the log file to the 80% of the required max size if this is set.
Definition: TProofServ.cxx:6026
TProofServ::Print
void Print(Option_t *option="") const
Print status of slave server.
Definition: TProofServ.cxx:2508
TProofServ::GetImage
const char * GetImage() const
Definition: TProofServ.h:244
TProofServ::GetEnabledPackages
TList * GetEnabledPackages() const
Definition: TProofServ.h:267
TProofServ::fCacheDir
TString fCacheDir
Definition: TProofServ.h:87
TProofServ::fQueryDir
TString fQueryDir
Definition: TProofServ.h:88
TProofServLogHandler::IsValid
Bool_t IsValid()
Definition: TProofServ.h:390
TProofServ::IsActive
static Bool_t IsActive()
Static function that returns kTRUE in case we are a PROOF server.
Definition: TProofServ.cxx:3476
TProofServ::fIdle
Bool_t fIdle
Definition: TProofServ.h:129
TProofServ::fTotSessions
Int_t fTotSessions
Definition: TProofServ.h:120
TReaperTimer::Notify
Bool_t Notify()
Check if any of the registered children has changed its state.
Definition: TProofServ.cxx:479
TProofServ::GetPackMgr
TPackMgr * GetPackMgr() const
Definition: TProofServ.h:249
nentries
int nentries
Definition: THbookFile.cxx:91
TProofLockPathGuard
Definition: TProofServ.h:363
TQueryResult
Definition: TQueryResult.h:41
TProofLockPathGuard::TProofLockPathGuard
TProofLockPathGuard(TProofLockPath *l)
Definition: TProofServ.h:368
TProofServ::fgLastMsg
static TString fgLastMsg
Definition: TProofServ.h:228
TProofServ::fMergedWorkers
Int_t fMergedWorkers
Definition: TProofServ.h:151
TProofServ::IsParallel
Bool_t IsParallel() const
True if in parallel mode.
Definition: TProofServ.cxx:2496
TProofServ::MakeQueryResult
TProofQueryResult * MakeQueryResult(Long64_t nentries, const char *opt, TList *inl, Long64_t first, TDSet *dset, const char *selec, TObject *elist)
Create a TProofQueryResult instance for this query.
Definition: TProofServ.cxx:3533
TIdleTOTimer::fProofServ
TProofServ * fProofServ
Definition: TProofServ.h:445
TTimer.h
TProofServ::GetConfFile
const char * GetConfFile() const
Definition: TProofServ.h:240
TProofServLogHandler::kFileIsPipe
@ kFileIsPipe
Definition: TProofServ.h:385
TDataSetManager
Definition: TDataSetManager.h:38
TProofServ::HandleWorkerLists
virtual Int_t HandleWorkerLists(TMessage *mess)
Handle here all requests to modify worker lists.
Definition: TProofServ.cxx:5594
TString
Definition: TString.h:136
TProofServ::RedirectOutput
void RedirectOutput(const char *dir=0, const char *mode="w")
Redirect stdout to a log file.
Definition: TProofServ.cxx:2520
Bool_t
bool Bool_t
Definition: RtypesCore.h:63
TIdleTOTimerGuard::fIdleTOTimer
TIdleTOTimer * fIdleTOTimer
Definition: TProofServ.h:456
TDSetElement
Definition: TDSet.h:66
TProofServLogHandler::TProofServLogHandler
TProofServLogHandler(const char *cmd, TSocket *s, const char *pfx="")
Execute 'cmd' in a pipe and handle output messages from the related file.
Definition: TProofServ.cxx:242
TProofServ::fgLastEntry
static Long64_t fgLastEntry
Definition: TProofServ.h:229
TProofServ::RestartComputeTime
void RestartComputeTime()
Reset the compute time.
Definition: TProofServ.cxx:1128
TProofServ::fSendLogToMaster
Bool_t fSendLogToMaster
Definition: TProofServ.h:147
TProofServ::fMsgSizeHWM
Long64_t fMsgSizeHWM
Definition: TProofServ.h:166
TProofServ::kQueryEnqueued
@ kQueryEnqueued
Definition: TProofServ.h:73
TString.h
TProofServ::fWaitingQueries
TList * fWaitingQueries
Definition: TProofServ.h:128
TProofServ::fTopSessionTag
TString fTopSessionTag
Definition: TProofServ.h:84
TProofServ::GetService
const char * GetService() const
Definition: TProofServ.h:238
TXProofServ
Definition: TXProofServ.h:30
TIdleTOTimer::Notify
Bool_t Notify()
Handle expiration of the idle timer. The session will just be terminated.
Definition: TProofServ.cxx:517
TProofServ::fNcmd
Int_t fNcmd
Definition: TProofServ.h:108
bool
TShutdownTimer::TShutdownTimer
TShutdownTimer(TProofServ *p, Int_t delay)
Construtor.
Definition: TProofServ.cxx:406
TProofServ::fLogLevel
Int_t fLogLevel
Definition: TProofServ.h:107
TProofLockPath
Definition: TProofServ.h:349
TProofServ::SendStatistics
void SendStatistics()
Send statistics of slave server to master or client.
Definition: TProofServ.cxx:2762
TProofServ::EnableTimeout
virtual void EnableTimeout()
Definition: TProofServ.h:317
TProofServ::CleanupWaitingQueries
Int_t CleanupWaitingQueries(Bool_t del=kTRUE, TList *qls=0)
Cleanup the waiting queries list.
Definition: TProofServ.cxx:6883
TProofServ::CreateServer
virtual Int_t CreateServer()
Finalize the server setup.
Definition: TProofServ.cxx:792
TProofServ::GetSessionStatus
Int_t GetSessionStatus()
Return the status of this session: 0 idle 1 running 2 being terminated (currently unused) 3 queued 4 ...
Definition: TProofServ.cxx:6789
TProofServLogHandlerGuard::TProofServLogHandlerGuard
TProofServLogHandlerGuard(const char *cmd, TSocket *s, const char *pfx="", Bool_t on=kTRUE)
Init a guard for executing a command in a pipe.
Definition: TProofServ.cxx:354
TProofServ::IsIdle
Bool_t IsIdle()
Return the idle status.
Definition: TProofServ.cxx:6821
TProofServ::fQuerySeqNum
Int_t fQuerySeqNum
Definition: TProofServ.h:118
TProofServ::CatMotd
Int_t CatMotd()
Print message of the day (in the file pointed by the env PROOFMOTD or from fConfDir/etc/proof/motd).
Definition: TProofServ.cxx:1021
TProofServ::fConfFile
TString fConfFile
Definition: TProofServ.h:80
TProofServ::GetWorkDir
const char * GetWorkDir() const
Definition: TProofServ.h:243
TProofServ::fgSysLogService
static TString fgSysLogService
Definition: TProofServ.h:173
TProofServ::GetOptions
void GetOptions(Int_t *argc, char **argv)
Get and handle command line options.
Definition: TProofServ.cxx:1282
TProofServ::fLogFileDes
Int_t fLogFileDes
Definition: TProofServ.h:101
TProofServLogHandler::ReadNotify
Bool_t ReadNotify()
Notify when something can be read from the descriptor associated with this handler.
Definition: TProofServ.h:393
TProofServ::fGroupSize
Int_t fGroupSize
Definition: TProofServ.h:106
TApplication.h
TIdleTOTimerGuard::TIdleTOTimerGuard
TIdleTOTimerGuard(TIdleTOTimer *t)
Definition: TProofServ.h:459
TIdleTOTimer
Definition: TProofServ.h:443
TProofServ::fCompute
TStopwatch fCompute
Definition: TProofServ.h:116
TProofServ::kQueryStop
@ kQueryStop
Definition: TProofServ.h:73
TProofLockPathGuard::~TProofLockPathGuard
~TProofLockPathGuard()
Definition: TProofServ.h:369
TProofServ::fCacheLock
TProofLockPath * fCacheLock
Definition: TProofServ.h:94
TProofServ::fgSysLogEntity
static TString fgSysLogEntity
Definition: TProofServ.h:174
TProofServ::GetDataSetNodeMap
static TMap * GetDataSetNodeMap(TFileCollection *fc, TString &emsg)
Get a map {server-name, list-of-files} for collection 'fc' to be used in TPacketizerFile.
Definition: TProofServ.cxx:3712
TSocket
Definition: TSocket.h:41
TProofServ::fQueryLock
TProofLockPath * fQueryLock
Definition: TProofServ.h:95
TProofServ::fQMgr
TQueryResultManager * fQMgr
Definition: TProofServ.h:126
TProofLockPath::TProofLockPath
TProofLockPath(const char *path)
Definition: TProofServ.h:354
TProofServ::GetPrefix
const char * GetPrefix() const
Definition: TProofServ.h:276
TProofServ::SetupCommon
Int_t SetupCommon()
Common part (between TProofServ and TXProofServ) of the setup phase.
Definition: TProofServ.cxx:2955
TReaperTimer::AddPid
void AddPid(Int_t pid)
Add an entry for 'pid' in the internal list.
Definition: TProofServ.cxx:463
TTimer
Definition: TTimer.h:51
TProofServ::Terminate
virtual void Terminate(Int_t status)
Terminate the proof server.
Definition: TProofServ.cxx:3372
TProofServ::fEffSessions
Float_t fEffSessions
Definition: TProofServ.h:122
Option_t
const typedef char Option_t
Definition: RtypesCore.h:66
TProofServ::GetTopSessionTag
const char * GetTopSessionTag() const
Definition: TProofServ.h:246
TProofServ::fRealTimeLog
Bool_t fRealTimeLog
Definition: TProofServ.h:136
TProofServ::SetErrorHandlerFile
static FILE * SetErrorHandlerFile(FILE *ferr)
Set the file stream where to log (default stderr).
Definition: TProofServ.cxx:5747
TProofServ::GetUser
const char * GetUser() const
Definition: TProofServ.h:241
TProofServ::UnloadPackage
Int_t UnloadPackage(const char *package)
TProofServ::GetMsgSizeHWM
Long64_t GetMsgSizeHWM() const
Definition: TProofServ.h:274
TProofServ::fgErrorHandlerFile
static FILE * fgErrorHandlerFile
Definition: TProofServ.h:168
TPackMgr
Definition: TPackMgr.h:37
TProofServ::GetGroup
const char * GetGroup() const
Definition: TProofServ.h:242
TProofServ::TProofServ
TProofServ(Int_t *argc, char **argv, FILE *flog=0)
Main constructor.
Definition: TProofServ.cxx:562
TProofServ::fWorkDir
TString fWorkDir
Definition: TProofServ.h:81
THashList
Definition: THashList.h:34
TProofServ::IsMaster
Bool_t IsMaster() const
Definition: TProofServ.h:293
TReaperTimer
Definition: TProofServ.h:429
TProofServ::GetCacheDir
const char * GetCacheDir() const
Definition: TProofServ.h:248
TProofServ::UnlinkDataDir
Bool_t UnlinkDataDir(const char *path)
Scan recursively the datadir and unlink it if empty Return kTRUE if it can be unlinked,...
Definition: TProofServ.cxx:3440
TProofServ::DeletePlayer
virtual void DeletePlayer()
Delete player instance.
Definition: TProofServ.cxx:5910
TProofServ::UpdateSessionStatus
Int_t UpdateSessionStatus(Int_t xst=-1)
Update the session status in the relevant file.
Definition: TProofServ.cxx:6802
TProofServ::GetWorkers
virtual EQueryAction GetWorkers(TList *workers, Int_t &prioritychange, Bool_t resume=kFALSE)
Get list of workers to be used from now on.
Definition: TProofServ.cxx:5695
TProofServ::fGroup
TString fGroup
Definition: TProofServ.h:78
TNamed
Definition: TNamed.h:29
TProofServ::HandleException
virtual void HandleException(Int_t sig)
Exception handler: we do not try to recover here, just exit.
Definition: TProofServ.cxx:6073
TProofServ::GetTotSessions
Int_t GetTotSessions() const
Definition: TProofServ.h:262
TProofServ::fMasterServ
Bool_t fMasterServ
Definition: TProofServ.h:111
kFALSE
const Bool_t kFALSE
Definition: RtypesCore.h:92
TProofServ::HandleLibIncPath
virtual Int_t HandleLibIncPath(TMessage *mess)
Handle lib, inc search paths modification request.
Definition: TProofServ.cxx:5002
TProofServ::EQueryAction
EQueryAction
Definition: TProofServ.h:73
TProofServLogHandler::fgPfx
static TString fgPfx
Definition: TProofServ.h:381
TProofServ::AcceptResults
Bool_t AcceptResults(Int_t connections, TVirtualProofPlayer *mergerPlayer)
Accept and merge results from a set of workers.
Definition: TProofServ.cxx:2240
TProofServ::fLogFile
FILE * fLogFile
Definition: TProofServ.h:100
Long_t
long Long_t
Definition: RtypesCore.h:54
TProofServ::GetDataDir
const char * GetDataDir() const
Definition: TProofServ.h:250
TProofServ::ErrorHandler
static void ErrorHandler(Int_t level, Bool_t abort, const char *location, const char *msg)
The PROOF error handler function.
Definition: TProofServ.cxx:5758
TShutdownTimer
Definition: TProofServ.h:416
TProofServ::GetOrdinal
const char * GetOrdinal() const
Definition: TProofServ.h:253
TProofServ::fReaperTimer
TReaperTimer * fReaperTimer
Definition: TProofServ.h:139
TProofServ::fImage
TString fImage
Definition: TProofServ.h:82
TProofServ::HandleRemove
virtual void HandleRemove(TMessage *mess, TString *slb=0)
Handle remove request.
Definition: TProofServ.cxx:4861
BIT
#define BIT(n)
Definition: Rtypes.h:85
TProofServLogHandlerGuard::~TProofServLogHandlerGuard
virtual ~TProofServLogHandlerGuard()
Close a guard for executing a command in a pipe.
Definition: TProofServ.cxx:394
TProofServ::HandleProcess
virtual void HandleProcess(TMessage *mess, TString *slb=0)
Handle processing request.
Definition: TProofServ.cxx:3759
TProofServ::fPlayer
TVirtualProofPlayer * fPlayer
Definition: TProofServ.h:99
TProofServ::fSessionTag
TString fSessionTag
Definition: TProofServ.h:83
TProofServ::LogToMaster
void LogToMaster(Bool_t on=kTRUE)
Definition: TProofServ.h:322
TProofLockPath::~TProofLockPath
~TProofLockPath()
Definition: TProofServ.h:355
TProofServLite
Definition: TProofServLite.h:30
TProofServ::IsTopMaster
Bool_t IsTopMaster() const
Definition: TProofServ.h:295
TProofServ::GetSocket
TSocket * GetSocket() const
Definition: TProofServ.h:257
TProofServ::GetVirtMemMax
static Long_t GetVirtMemMax()
VirtMemMax getter.
Definition: TProofServ.cxx:6923
TPackMgr.h
TProofServ::fMergingMonitor
TMonitor * fMergingMonitor
Definition: TProofServ.h:150
TProofServ::IsWaiting
Bool_t IsWaiting()
Return kTRUE if the session is waiting for the OK to start processing.
Definition: TProofServ.cxx:6839
TProofServ::WaitingQueries
Int_t WaitingQueries()
Return the number of waiting queries.
Definition: TProofServ.cxx:6849
TProofServ::GetDataDirOpts
const char * GetDataDirOpts() const
Definition: TProofServ.h:251
TProofServ::fgVirtMemMax
static Long_t fgVirtMemMax
Definition: TProofServ.h:159
TDSet
Definition: TDSet.h:153
TProofServ::fgResMemMax
static Long_t fgResMemMax
Definition: TProofServ.h:160
TProofServ::fPrefix
TString fPrefix
Definition: TProofServ.h:134
TProofServ::fMaxQueries
Int_t fMaxQueries
Definition: TProofServ.h:154
TProofServ::SendParallel
void SendParallel(Bool_t async=kFALSE)
Send number of parallel nodes to master or client.
Definition: TProofServ.cxx:2782
TProofServ::GetLogLevel
Int_t GetLogLevel() const
Definition: TProofServ.h:256
TProofServ::HandleArchive
virtual void HandleArchive(TMessage *mess, TString *slb=0)
Handle archive request.
Definition: TProofServ.cxx:3600
TProofServ::fHWMBoxSize
Long64_t fHWMBoxSize
Definition: TProofServ.h:156
TProofLockPathGuard::fLocker
TProofLockPath * fLocker
Definition: TProofServ.h:365
TProofServ::fActSessions
Int_t fActSessions
Definition: TProofServ.h:121
TReaperTimer::~TReaperTimer
virtual ~TReaperTimer()
Destructor.
Definition: TProofServ.cxx:451
TShutdownTimer::fTimeout
Int_t fTimeout
Definition: TProofServ.h:419
TReaperTimer::TReaperTimer
TReaperTimer(Long_t frequency=1000)
Definition: TProofServ.h:434
TProofServ::MakePlayer
virtual void MakePlayer()
Make player instance.
Definition: TProofServ.cxx:5886
TProofServLogHandler::SetDefaultPrefix
static void SetDefaultPrefix(const char *pfx)
Static method to set the default prefix.
Definition: TProofServ.cxx:338
TProofServ::fMaxBoxSize
Long64_t fMaxBoxSize
Definition: TProofServ.h:155
TProofLockPath::Lock
Int_t Lock()
Locks the directory.
Definition: TProofServ.cxx:6989
TProofServ::fLatency
TStopwatch fLatency
Definition: TProofServ.h:115
TProofServ::HandleDataSets
virtual Int_t HandleDataSets(TMessage *mess, TString *slb=0)
Handle here requests about datasets.
Definition: TProofServ.cxx:6090
TProofServ::fDataSetManager
TDataSetManager * fDataSetManager
Definition: TProofServ.h:144
TTimer::Stop
virtual void Stop()
Definition: TTimer.h:99
TProofServ::GetMemHWM
static Float_t GetMemHWM()
MemHWM getter.
Definition: TProofServ.cxx:6937
TProofServ::fLogFileMaxSize
Long64_t fLogFileMaxSize
Definition: TProofServ.h:102
OldProofServAuthSetup_t
Int_t(* OldProofServAuthSetup_t)(TSocket *, Bool_t, Int_t, TString &, TString &, TString &)
Definition: TProofServ.h:62
TProofLockPath::fLockId
Int_t fLockId
Definition: TProofServ.h:351
TProofServ::HandleSocketInput
virtual void HandleSocketInput()
Handle input coming from the client or from the master server.
Definition: TProofServ.cxx:1321
TProofLockPath::Unlock
Int_t Unlock()
Unlock the directory.
Definition: TProofServ.cxx:7025
TProofServ
Definition: TProofServ.h:66
TProofServ::fDataSetStgRepo
TDataSetManagerFile * fDataSetStgRepo
Definition: TProofServ.h:145
TProofServ::GetCacheLock
TProofLockPath * GetCacheLock()
Definition: TProofServ.h:281
TProofServ::fInputHandler
TFileHandler * fInputHandler
Definition: TProofServ.h:124
TProofServ::fQMtx
std::recursive_mutex fQMtx
Definition: TProofServ.h:130
TProofServ::GetRealTime
Float_t GetRealTime() const
Definition: TProofServ.h:258
TProofServ::GetResMemMax
static Long_t GetResMemMax()
ResMemMax getter.
Definition: TProofServ.cxx:6930
file
Definition: file.py:1
TProofServ::NextQuery
TProofQueryResult * NextQuery()
Get the next query from the waiting list.
Definition: TProofServ.cxx:6870
TProofServ::fDataDir
TString fDataDir
Definition: TProofServ.h:90
TProofServ::FilterLocalroot
static void FilterLocalroot(TString &path, const char *url="root://dum/")
If 'path' is local and 'dsrv' is Xrootd, apply 'path.Localroot' settings, if any.
Definition: TProofServ.cxx:6969
TVirtualProofPlayer
Definition: TVirtualProofPlayer.h:43
TProofServ::HandleTermination
virtual void HandleTermination()
Definition: TProofServ.h:290
TStopwatch
Definition: TStopwatch.h:28
TObject
Definition: TObject.h:37
TProofServ::fService
TString fService
Definition: TProofServ.h:76
TShutdownTimer::Notify
Bool_t Notify()
Handle expiration of the shutdown timer.
Definition: TProofServ.cxx:418
TProofServ::HandleQueryList
virtual void HandleQueryList(TMessage *mess)
Handle request for list of queries.
Definition: TProofServ.cxx:4798
ClassDef
#define ClassDef(name, id)
Definition: Rtypes.h:325
TProofServLogHandler::GetCmdRtn
static Int_t GetCmdRtn()
Static method to get the return code from the execution of a command via the pipe.
Definition: TProofServ.cxx:346
TProofServLogHandlerGuard
Definition: TProofServ.h:401
TProofServLogHandler::fSocket
TSocket * fSocket
Definition: TProofServ.h:377
TFileHandler
Definition: TSysEvtHandler.h:65
TProofServLogHandlerGuard::fExecHandler
TProofServLogHandler * fExecHandler
Definition: TProofServ.h:404
TProofServ::fArchivePath
TString fArchivePath
Definition: TProofServ.h:96
TProofServ::fQueuedMsg
TList * fQueuedMsg
Definition: TProofServ.h:132
TProofServLogHandler
Definition: TProofServ.h:375
TProofServ::SetQueryRunning
void SetQueryRunning(TProofQueryResult *pq)
Set query in running state.
Definition: TProofServ.cxx:3567
TProofServ::Fork
virtual Int_t Fork()
Fork a child.
Definition: TProofServ.cxx:6668
TQueryResultManager
Definition: TQueryResultManager.h:35
TProof
Definition: TProof.h:316
R__EXTERN
#define R__EXTERN
Definition: DllImport.h:27
TProofServ::~TProofServ
virtual ~TProofServ()
Cleanup.
Definition: TProofServ.cxx:1002
TProofServLogHandler::fgCmdRtn
static Int_t fgCmdRtn
Definition: TProofServ.h:382
TProofServ::GetGroupSize
Int_t GetGroupSize() const
Definition: TProofServ.h:255
TProofServ::GetQuerySeqNum
Int_t GetQuerySeqNum() const
Definition: TProofServ.h:260
TProofServ::fOutputFile
TString fOutputFile
Definition: TProofServ.h:93
TApplication
Definition: TApplication.h:39
TProofServ::GetProtocol
Int_t GetProtocol() const
Definition: TProofServ.h:252
TProofServ::fSocket
TSocket * fSocket
Definition: TProofServ.h:97
TApplication::EStatusBits
EStatusBits
Definition: TApplication.h:43
TProofServ::GetCompressionLevel
Int_t GetCompressionLevel() const
Definition: TProofServ.h:464
TServerSocket
Definition: TServerSocket.h:42
TProofQueryResult
Definition: TProofQueryResult.h:28
TMessage
Definition: TMessage.h:33
TProofServ::GetSessionDir
const char * GetSessionDir() const
Definition: TProofServ.h:247
TProofServ::fInterrupt
Bool_t fInterrupt
Definition: TProofServ.h:112
TProofServ::kQueryModify
@ kQueryModify
Definition: TProofServ.h:73
TProofServ::ReleaseWorker
virtual void ReleaseWorker(const char *)
Definition: TProofServ.h:305
TProofServ::ResolveKeywords
static void ResolveKeywords(TString &fname, const char *path=0)
Replace <ord>, <user>, <u>, <group>, <stag>, <qnum>, <file>, <rver> and <build> placeholders in fname...
Definition: TProofServ.cxx:6705
TProofServ::HandleCheckFile
virtual void HandleCheckFile(TMessage *mess, TString *slb=0)
Handle file checking request.
Definition: TProofServ.cxx:5132
TProofServ::fgRecursive
static Int_t fgRecursive
Definition: TProofServ.h:169
TProofServ::fCpuTime
Float_t fCpuTime
Definition: TProofServ.h:114
TProofServ::fgMemHWM
static Float_t fgMemHWM
Definition: TProofServ.h:162
TProofServ::This
static TProofServ * This()
Static function returning pointer to global object gProofServ.
Definition: TProofServ.cxx:3486
gProofServ
R__EXTERN TProofServ * gProofServ
Definition: TProofServ.h:347
TProofServ::HandleUrgentData
virtual void HandleUrgentData()
Handle Out-Of-Band data sent by the master or client.
Definition: TProofServ.cxx:2335
TIdleTOTimerGuard
Definition: TProofServ.h:453
TProofServ::GetPriority
Int_t GetPriority()
Get the processing priority for the group the user belongs too.
Definition: TProofServ.cxx:5942
TObject::EStatusBits
EStatusBits
Definition: TObject.h:57
TProofServ::fPackMgr
TPackMgr * fPackMgr
Definition: TProofServ.h:86
TProofServ::SendAsynMessage
void SendAsynMessage(const char *msg, Bool_t lf=kTRUE)
Send an asychronous message to the master / client .
Definition: TProofServ.cxx:5992
TProofServLogHandler::~TProofServLogHandler
virtual ~TProofServLogHandler()
Handle available message in the open file.
Definition: TProofServ.cxx:288
TProofServ::HandleSigPipe
virtual void HandleSigPipe()
Called when the client is not alive anymore (i.e.
Definition: TProofServ.cxx:2470
TProofServ::FlushLogFile
void FlushLogFile()
Reposition the read pointer in the log file to the very end.
Definition: TProofServ.cxx:6016
TList
Definition: TList.h:44
TProofServ::fGroupId
Int_t fGroupId
Definition: TProofServ.h:105
TProofServ::SetLastEntry
static void SetLastEntry(Long64_t lastentry)
Set the last entry before exception.
Definition: TProofServ.cxx:6915
TProofServ::fProof
TProof * fProof
Definition: TProofServ.h:98
TProofServ::ReceiveFile
Int_t ReceiveFile(const char *file, Bool_t bin, Long64_t size)
Receive a file, either sent by a client or a master server.
Definition: TProofServ.cxx:2580
TProofServ::fDataSetDir
TString fDataSetDir
Definition: TProofServ.h:89
int
TFileCollection
Definition: TFileCollection.h:39
TProofServ::fSessionDir
TString fSessionDir
Definition: TProofServ.h:85
TProofServ::GetLocalServer
static void GetLocalServer(TString &dsrv)
Extract LOCALDATASERVER info in 'dsrv'.
Definition: TProofServ.cxx:6952
TMap
Definition: TMap.h:40
TProofServ::HandleFork
virtual void HandleFork(TMessage *mess)
Cloning itself via fork. Not implemented.
Definition: TProofServ.cxx:6657
TProofServ::fCompressMsg
Int_t fCompressMsg
Definition: TProofServ.h:142
TSysEvtHandler.h