TGo4AnalysisClientImp.h

Go to the documentation of this file.

// $Id: TGo4AnalysisClientImp.h 1798 2015-11-17 13:13:45Z adamczew $
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum für Schwerionenforschung GmbH
//                     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"

#include "TString.h"

class TTimer;
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 cintmode = kFALSE,
                       Bool_t loadprefs = kTRUE,
                       Bool_t showrate = 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 Quit();

    virtual void KillMain();

    virtual void RestartMain();

    virtual TGo4TaskStatus* CreateStatus();

    virtual Int_t Initialization();

    void SendAnalysisObject(const char* 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 char* basename,  const char* passwd);

    void StopObjectServer();


    virtual Int_t StartWorkThreads();

    virtual Int_t StopWorkThreads();

    virtual void Terminate (Bool_t termapp=kTRUE);

    virtual void TerminateFast ();

    /* submit a analysis server shutdown into local command queue.
     * used by ctrl-c handler of analysis server*/
    void SubmitShutdown();

    virtual void SendStatusMessage(Int_t level, Bool_t printout, const TString& text);

    virtual void ExecuteString(const char* command);

    void SetCintMode(Bool_t on=kTRUE);

    Bool_t IsCintMode() const { return fbCintMode; }

    static const char* fgcMAINTHREAD; 

    static const char* 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;                   

    TString fcMainName;                          

    TString fcWatchName;                         

    Double_t fdBufferUpdateTime;

    TGo4Ratemeter* fxRatemeter;                  

    TGo4HistogramServer* fxHistoServer;          

    Bool_t fbAutoStart;

    Bool_t fbCintMode;

    Bool_t fbLoadPrefs; 

    Bool_t fbShowRate; 



    TGo4AnalysisClient();

  ClassDef(TGo4AnalysisClient,1)

};

#endif //TGO4ANALYSISCLIENT_H