#ifndef ROOT_TProofServ
#define ROOT_TProofServ
#ifndef ROOT_TApplication
#include "TApplication.h"
#endif
#ifndef ROOT_TString
#include "TString.h"
#endif
#ifndef ROOT_TSysEvtHandler
#include "TSysEvtHandler.h"
#endif
#ifndef ROOT_TStopwatch
#include "TStopwatch.h"
#endif
#ifndef ROOT_TTimer
#include "TTimer.h"
#endif
#ifndef ROOT_TProofQueryResult
#include "TProofQueryResult.h"
#endif
class TDSet;
class TProof;
class TVirtualProofPlayer;
class TProofLockPath;
class TQueryResultManager;
class TSocket;
class THashList;
class TList;
class TDSetElement;
class TMessage;
class TTimer;
class TReaperTimer;
class TMutex;
class TFileCollection;
class TProofDataSetManager;
class TFileHandler;
typedef Int_t (*OldProofServAuthSetup_t)(TSocket *, Bool_t, Int_t,
TString &, TString &, TString &);
class TProofServ : public TApplication {
friend class TProofServLite;
friend class TXProofServ;
public:
enum EQueryAction { kQueryOK, kQueryModify, kQueryStop };
private:
TString fService;
TString fUser;
TString fGroup;
TString fConfDir;
TString fConfFile;
TString fWorkDir;
TString fImage;
TString fSessionTag;
TString fTopSessionTag;
TString fSessionDir;
TString fPackageDir;
THashList *fGlobalPackageDirList;
TString fCacheDir;
TString fQueryDir;
TString fDataSetDir;
TString fAdminPath;
TProofLockPath *fPackageLock;
TProofLockPath *fCacheLock;
TProofLockPath *fQueryLock;
TString fArchivePath;
TSocket *fSocket;
TProof *fProof;
TVirtualProofPlayer *fPlayer;
FILE *fLogFile;
Int_t fLogFileDes;
TList *fEnabledPackages;
Int_t fProtocol;
TString fOrdinal;
Int_t fGroupId;
Int_t fGroupSize;
Int_t fLogLevel;
Int_t fNcmd;
Int_t fGroupPriority;
Bool_t fEndMaster;
Bool_t fMasterServ;
Bool_t fInterrupt;
Float_t fRealTime;
Float_t fCpuTime;
TStopwatch fLatency;
TStopwatch fCompute;
TFileHandler *fInputHandler;
TQueryResultManager *fQMgr;
TList *fWaitingQueries;
Bool_t fIdle;
TList *fQueuedMsg;
TString fPrefix;
Bool_t fRealTimeLog;
TTimer *fShutdownTimer;
TReaperTimer *fReaperTimer;
Int_t fInflateFactor;
TProofDataSetManager* fDataSetManager;
Bool_t fLogToSysLog;
Bool_t fSendLogToMaster;
Int_t fMaxQueries;
Long64_t fMaxBoxSize;
Long64_t fHWMBoxSize;
Long_t fVirtMemHWM;
Long_t fVirtMemMax;
static FILE *fgErrorHandlerFile;
static Int_t fgRecursive;
void RedirectOutput(const char *dir = 0, const char *mode = "w");
Int_t CatMotd();
Int_t UnloadPackage(const char *package);
Int_t UnloadPackages();
Int_t OldAuthSetup(TString &wconf);
Int_t GetPriority();
TProofQueryResult *MakeQueryResult(Long64_t nentries, const char *opt,
TList *inl, Long64_t first, TDSet *dset,
const char *selec, TObject *elist);
void SetQueryRunning(TProofQueryResult *pq);
protected:
virtual void HandleArchive(TMessage *mess);
virtual Int_t HandleCache(TMessage *mess);
virtual void HandleCheckFile(TMessage *mess);
virtual Int_t HandleDataSets(TMessage *mess);
virtual void HandleFork(TMessage *mess);
virtual void HandleLibIncPath(TMessage *mess);
virtual void HandleProcess(TMessage *mess);
virtual void HandleQueryList(TMessage *mess);
virtual void HandleRemove(TMessage *mess);
virtual void HandleRetrieve(TMessage *mess);
virtual void HandleWorkerLists(TMessage *mess);
virtual Int_t Setup();
Int_t SetupCommon();
virtual void MakePlayer();
virtual void DeletePlayer();
virtual Int_t Fork();
public:
TProofServ(Int_t *argc, char **argv, FILE *flog = 0);
virtual ~TProofServ();
virtual Int_t CreateServer();
TProof *GetProof() const { return fProof; }
const char *GetService() const { return fService; }
const char *GetConfDir() const { return fConfDir; }
const char *GetConfFile() const { return fConfFile; }
const char *GetUser() const { return fUser; }
const char *GetGroup() const { return fGroup; }
const char *GetWorkDir() const { return fWorkDir; }
const char *GetImage() const { return fImage; }
const char *GetSessionTag() const { return fTopSessionTag; }
const char *GetSessionDir() const { return fSessionDir; }
const char *GetPackageDir() const { return fPackageDir; }
Int_t GetProtocol() const { return fProtocol; }
const char *GetOrdinal() const { return fOrdinal; }
Int_t GetGroupId() const { return fGroupId; }
Int_t GetGroupSize() const { return fGroupSize; }
Int_t GetLogLevel() const { return fLogLevel; }
TSocket *GetSocket() const { return fSocket; }
Float_t GetRealTime() const { return fRealTime; }
Float_t GetCpuTime() const { return fCpuTime; }
void GetOptions(Int_t *argc, char **argv);
TList *GetEnabledPackages() const { return fEnabledPackages; }
Int_t GetInflateFactor() const { return fInflateFactor; }
Long_t GetVirtMemHWM() const { return fVirtMemHWM; }
const char *GetPrefix() const { return fPrefix; }
void FlushLogFile();
Int_t CopyFromCache(const char *name, Bool_t cpbin);
Int_t CopyToCache(const char *name, Int_t opt = 0);
virtual EQueryAction GetWorkers(TList *workers, Int_t &prioritychange);
virtual void HandleException(Int_t sig);
virtual Int_t HandleSocketInput(TMessage *mess, Bool_t all);
virtual void HandleSocketInput();
virtual void HandleUrgentData();
virtual void HandleSigPipe();
virtual void HandleTermination() { Terminate(0); }
void Interrupt() { fInterrupt = kTRUE; }
Bool_t IsEndMaster() const { return fEndMaster; }
Bool_t IsMaster() const { return fMasterServ; }
Bool_t IsParallel() const;
Bool_t IsTopMaster() const { return fOrdinal == "0"; }
void Run(Bool_t retrn = kFALSE);
void Print(Option_t *option="") const;
TObject *Get(const char *namecycle);
TDSetElement *GetNextPacket(Long64_t totalEntries = -1);
virtual void ReleaseWorker(const char *) { }
void Reset(const char *dir);
Int_t ReceiveFile(const char *file, Bool_t bin, Long64_t size);
virtual Int_t SendAsynMessage(const char *msg, Bool_t lf = kTRUE);
virtual void SendLogFile(Int_t status = 0, Int_t start = -1, Int_t end = -1);
void SendStatistics();
void SendParallel(Bool_t async = kFALSE);
virtual void DisableTimeout() { }
virtual void EnableTimeout() { }
virtual void Terminate(Int_t status);
Bool_t LogToSysLog() { return fLogToSysLog; }
void LogToMaster(Bool_t on = kTRUE) { fSendLogToMaster = on; }
static FILE *SetErrorHandlerFile(FILE *ferr);
static void ErrorHandler(Int_t level, Bool_t abort, const char *location,
const char *msg);
static Bool_t IsActive();
static TProofServ *This();
ClassDef(TProofServ,0)
};
R__EXTERN TProofServ *gProofServ;
class TProofLockPath : public TNamed {
private:
Int_t fLockId;
public:
TProofLockPath(const char *path) : TNamed(path,path), fLockId(-1) { }
~TProofLockPath() { if (IsLocked()) Unlock(); }
Int_t Lock();
Int_t Unlock();
Bool_t IsLocked() const { return (fLockId > -1); }
};
class TProofLockPathGuard {
private:
TProofLockPath *fLocker;
public:
TProofLockPathGuard(TProofLockPath *l) { fLocker = l; if (fLocker) fLocker->Lock(); }
~TProofLockPathGuard() { if (fLocker) fLocker->Unlock(); }
};
class TProofServLogHandler : public TFileHandler {
private:
TSocket *fSocket;
FILE *fFile;
TString fPfx;
static TString fgPfx;
public:
enum EStatusBits { kFileIsPipe = BIT(23) };
TProofServLogHandler(const char *cmd, TSocket *s, const char *pfx = "");
TProofServLogHandler(FILE *f, TSocket *s, const char *pfx = "");
virtual ~TProofServLogHandler();
Bool_t IsValid() { return ((fFile && fSocket) ? kTRUE : kFALSE); }
Bool_t Notify();
Bool_t ReadNotify() { return Notify(); }
static void SetDefaultPrefix(const char *pfx);
};
class TProofServLogHandlerGuard {
private:
TProofServLogHandler *fExecHandler;
public:
TProofServLogHandlerGuard(const char *cmd, TSocket *s,
const char *pfx = "", Bool_t on = kTRUE);
TProofServLogHandlerGuard(FILE *f, TSocket *s,
const char *pfx = "", Bool_t on = kTRUE);
virtual ~TProofServLogHandlerGuard();
};
class TShutdownTimer : public TTimer {
private:
TProofServ *fProofServ;
public:
TShutdownTimer(TProofServ *p, Int_t delay) : TTimer(delay, kFALSE), fProofServ(p) { }
Bool_t Notify();
};
class TReaperTimer : public TTimer {
private:
TList *fChildren;
public:
TReaperTimer(Long_t frequency = 1000) : TTimer(frequency, kTRUE), fChildren(0) { }
virtual ~TReaperTimer();
void AddPid(Int_t pid);
Bool_t Notify();
};
#endif
Last change: Thu Dec 18 09:31:33 2008
Last generated: 2008-12-18 09:31
This page has been automatically generated. If you have any comments or suggestions about the page layout send a mail to ROOT support, or contact the developers with any questions or problems regarding ROOT.