TProofServ

class TProofServ : public TApplication

    private:

      Int_t CatMotd()
      Int_t LockCache()
      Int_t LockDir(const TString& lock)
      Int_t LockPackage()
       void RedirectOutput()
       void Setup()
      Int_t UnlockCache()
      Int_t UnlockDir(const TString& lock)
      Int_t UnlockPackage()

    public:

              TProofServ TProofServ(int* argc, char** argv)
              TProofServ TProofServ(const TProofServ&)
            virtual void ~TProofServ()
          static TClass* Class()
                TObject* Get(const char* namecycle)
             const char* GetConfDir() const
             const char* GetConfFile() const
                 Float_t GetCpuTime() const
                  Stat_t GetEntriesProcessed() const
                   Int_t GetGroupId() const
                   Int_t GetGroupSize() const
                    void GetLimits(Int_t dim, Int_t nentries, Int_t* nbins, Double_t* vmin, Double_t* vmax)
                   Int_t GetLogLevel() const
           TDSetElement* GetNextPacket()
            virtual void GetOptions(int* argc, char** argv)
                   Int_t GetOrdinal() const
                   Int_t GetProtocol() const
                 Float_t GetRealTime() const
             const char* GetService() const
                TSocket* GetSocket() const
             const char* GetUser() const
                    void HandleSigPipe()
                    void HandleSocketInput()
                    void HandleUrgentData()
                    void Interrupt()
         virtual TClass* IsA() const
           static Bool_t IsActive()
                  Bool_t IsMaster() const
                  Bool_t IsParallel() const
            virtual void Print(Option_t* option) const
                   Int_t ReceiveFile(const char* file, Bool_t bin, Long_t size)
                    void Reset(const char* dir)
            virtual void Run(Bool_t retrn = kFALSE)
                    void SendLogFile(Int_t status = 0)
                    void SendStatus()
            virtual void ShowMembers(TMemberInspector& insp, char* parent)
            virtual void Streamer(TBuffer& b)
                    void StreamerNVirtual(TBuffer& b)
            virtual void Terminate(int status)
      static TProofServ* This()

Data Members

    private:

       TString fService           service we are running, either "proofserv" or "proofslave"
       TString fUser              user as which we run
       TString fPasswd            encoded passwd info for slaves
       TString fConfDir           directory containing cluster config information
       TString fConfFile          file containing config information
       TString fSessionDir        directory containing session dependent files
       TString fPackageDir        directory containing packages and user libs
       TString fCacheDir          directory containing cache of user files
       TString fPackageLock       package dir lock file
       TString fCacheLock         cache dir lock file
      TSocket* fSocket            socket connection to client
       TProof* fProof             PROOF talking to slave servers
         FILE* fLogFile           log file
         Int_t fPackageLockId     file id of package dir lock
         Int_t fCacheLockId       file id of cache dir lock
         Int_t fProtocol          protocol version number
         Int_t fOrdinal           slave ordinal number, -1 for master
         Int_t fGroupId           slave unique id in the active slave group
         Int_t fGroupSize         size of the active slave group
         Int_t fLogLevel          debug logging level
        Bool_t fMasterServ        true if we are a master server
         Int_t fNcmd              command history number
        Bool_t fInterrupt         if true macro execution will be stopped
       Float_t fRealTime          real time spent executing commands
       Float_t fCpuTime           CPU time spent executing commands
        Stat_t fEntriesProcessed  total number of entries processed (obtained via GetNextPacket)

Class Description

                                                                      
 TProofServ                                                           
                                                                      
 TProofServ is the PROOF server. It can act either as the master      
 server or as a slave server, depending on its startup arguments. It  
 receives and handles message coming from the client or from the      
 master server.                                                       
                                                                      

 Create an application environment. The TProofServ environment provides
 an eventloop via inheritance of TApplication.

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

 Print message of the day (in fConfDir/proof/etc/motd). The motd
 is not shown more than once a dat. If the file fConfDir/proof/etc/noproof
 exists, show its contents and close the connection.

 Get object with name "name;cycle" (e.g. "aap;2") from master or client.
 This method is called by TDirectory::Get() in case the object can not
 be found locally.

 Get limits of histogram from master. This method is called by
 TTree::TakeEstimate().

 Get next range of entries to be processed on this server.

 Get and handle command line options. Fixed format:
 "proofserv"|"proofslave" <confdir>

 Handle input coming from the client or from the master server.

 Handle Out-Of-Band data sent by the master or client.

 Called when the client is not alive anymore (i.e. when kKeepAlive
 has failed).

 True if in parallel mode.

 Lock a directory. Waits if lock is hold by an other process.
 Returns 0 on success, -1 in case of error.

 Unlock a directory. Returns 0 in case of success,
 -1 in case of error.

 Print status of slave server.

 Redirect stdout to a log file. This log file will be flushed to the
 client or master after each command.

 Reset PROOF environment to be ready for execution of next command.

 Receive a file, either sent by a client or a master server.
 If bin is true it is a binary file, other wise it is an ASCII
 file and we need to check for Windows r tokens. Returns -1 in
 case of error, 0 otherwise.

 Main server eventloop.

 Send log file to master.

 Send status of slave server to master or client.

 Print the ProofServ logo on standard output.

 Terminate the proof server.

 Static function that returns kTRUE in case we are a PROOF server.

 Static function returning pointer to global object gProofServ.
 Mainly for use via CINT, where the gProofServ symbol might be
 deleted from the symbol table.

Inline Functions

              Int_t LockCache()
              Int_t UnlockCache()
              Int_t LockPackage()
              Int_t UnlockPackage()
        const char* GetService() const
        const char* GetConfDir() const
        const char* GetConfFile() const
        const char* GetUser() const
              Int_t GetProtocol() const
              Int_t 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
               void Interrupt()
             Bool_t IsMaster() const
             Stat_t GetEntriesProcessed() const
            TClass* Class()
            TClass* IsA() const
               void ShowMembers(TMemberInspector& insp, char* parent)
               void Streamer(TBuffer& b)
               void StreamerNVirtual(TBuffer& b)
         TProofServ TProofServ(const TProofServ&)