TGo4AnalysisClientImp.h

Go to the documentation of this file.

//-------------------------------------------------------------
//        Go4 Release Package v3.04-01 (build 30401)
//                      28-November-2008
//---------------------------------------------------------------
//   The GSI Online Offline Object Oriented (Go4) Project
//   Experiment Data Processing at EE department, GSI
//---------------------------------------------------------------
//
//Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI
//                    Planckstr. 1, 64291 Darmstadt, Germany
//Contact:            http://go4.gsi.de
//----------------------------------------------------------------
//This software can be used under the license agreements as stated
//in Go4License.txt file which is part of the distribution.
//----------------------------------------------------------------
#ifndef TGO4ANALYSISCLIENTIMP_H
#define TGO4ANALYSISCLIENTIMP_H

#include "TGo4Slave.h"

class TTimer;
class TStopwatch;
class TGo4Analysis;
class TGo4ClientStatus;
class TGo4Ratemeter;
class TGo4HistogramServer;
class TGo4TaskStatus;
class TGo4InterruptHandler;

class TGo4AnalysisClient : public TGo4Slave {

  public:
    TGo4AnalysisClient(const char* name,
                       TGo4Analysis* analysis,
                       const char* host="localhost",
                       UInt_t negport=0,
                       Bool_t histoserver=kFALSE,
                       const char* basename="Go4",
                       const char* passwd="abcd",
                       Bool_t servermode=kFALSE,
                       Bool_t autorun=kFALSE,
                       Bool_t clientmode = kFALSE);

    TGo4AnalysisClient(int argc, char** argv,
                       TGo4Analysis* analysis,
                       Bool_t histoserver=kFALSE,
                       const char* basename="Go4",
                       const char* passwd="abcd",
                       Bool_t servermode=kFALSE,
                       Bool_t autorun=kFALSE);

    virtual ~TGo4AnalysisClient();

    TGo4Analysis* GetAnalysis() const { return fxAnalysis; }

    virtual void Start();

    virtual void Stop();

    virtual void KillMain();

    virtual void RestartMain();

    virtual TGo4TaskStatus* CreateStatus();

    virtual Int_t Initialization();

    void SendAnalysisObject(const Text_t* name);

    void SendAnalysisStatus();

    void SendAnalysisClientStatus();

    void SendNamesList();

    void UpdateRate(Int_t counts=1);

    UInt_t GetCurrentCount();

    Bool_t TestRatemeter();

    Bool_t TestBufferUpdateConditions();

    void StartObjectServer(const Text_t* basename,  const Text_t* passwd);

    void StopObjectServer();


    virtual Int_t StartWorkThreads();

    virtual Int_t StopWorkThreads();

    virtual void Terminate (Bool_t termapp=kTRUE);

    virtual void TerminateFast ();

    virtual void ExecuteString(const Text_t* command);

    void SetCintMode(Bool_t on=kTRUE);

    Bool_t& IsCintMode(){ return fbCintMode;}

    void LockAll();

    void UnLockAll();

    static const Text_t fgcMAINTHREAD[]; 

    static const Text_t fgcWATCHTHREAD[]; 

    static const UInt_t fguSTATUSUPDATE;

    static const Double_t fgdSTATUSTIMEOUT;

    static const UInt_t fguCINTTIMERPERIOD;

  private:

    void Constructor(Bool_t starthistserv=kFALSE, const char* basename="Go4", const char* passwd="abcd");

    void UpdateStatus(TGo4TaskStatus * state);



private:

    TGo4Analysis* fxAnalysis;                   

    Text_t* fcMainName;                          

    Text_t* fcWatchName;                         

    Double_t fdBufferUpdateTime;

    TStopwatch* fxUpdateWatch;                   

    TGo4Ratemeter* fxRatemeter;                  

    TGo4HistogramServer* fxHistoServer;          

    Bool_t fbAutoStart;

    Bool_t fbCintMode;

    TTimer* fxCintLockTimer; 

    TGo4InterruptHandler* fxInterruptHandler; 

    TGo4AnalysisClient();

  ClassDef(TGo4AnalysisClient,1)

};

#endif //TGO4ANALYSISCLIENT_H

//----------------------------END OF GO4 SOURCE FILE ---------------------

---