TGo4HistogramServer.h

Go to the documentation of this file.

// $Id$
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum fuer 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 TGO4HISTOGRAMSERVER_H
#define TGO4HISTOGRAMSERVER_H

#include "TGo4CommandReceiver.h"
#include "TString.h"

class TGo4AnalysisClient;
class TGo4Analysis;
class TGo4ThreadHandler;
class TGo4ObjConnectorTimer;
class TGo4Socket;

class TGo4HistogramServer : public TGo4CommandReceiver {

   friend class TGo4HisConnectorRunnable;

   public:

      TGo4HistogramServer();

      TGo4HistogramServer(TGo4AnalysisClient *owner,
                          const char *servername = "localhost",
                          const char *password = "go4",
                          Bool_t useobjectserver = kFALSE);

      virtual ~TGo4HistogramServer();

      Int_t ServeObjectClient();

      UInt_t GetObjPort();

      virtual Int_t TimerConnect();

      TGo4AnalysisClient *GetAnalysisClient() const { return fxAnalysisClient; }

      TGo4Analysis *GetAnalysis() const { return fxAnalysis; }

      static const char *fgcCONTHREADNAME; 

      static const char *fgcOBJTHREADNAME; 

      static const char *fgcSHUTDOWNNAME; 

      static const char *fgcCOMGETLIST; 

      static const UInt_t fguTIMERPERIOD;         

      static const Int_t fgiOPENWAITCYCLES;        

      static const UInt_t fguOPENWAITCYCLETIME;   

      static const Int_t fgiCLOSEWAITCYCLES;      

      static const UInt_t fguCLOSEWAITCYCLETIME;  

      static const Int_t fgiCONNECTWAITCYCLES;    

      static const UInt_t fguCONNECTWAITCYCLETIME;  

   private:

      const char *ConnectorName() const { return fxConnectorName.Data(); }

      const char *ObjectThreadName() const { return fxObjectThreadName.Data(); }

      const char *ConnectHost() const { return fcConnectHost.Data(); }

      void SetConnect(TGo4Socket *trans, const char *host, UInt_t port);

      void SetDisConnect(TGo4Socket *trans);

      Int_t WaitForOpen();

      Int_t WaitForClose();

      Int_t WaitForConnection();

      void DisconnectObjectClient();

      Bool_t CheckLogin();

      Int_t ConnectObjectClient();

      Bool_t HandleObjectRequest();

      Bool_t SendObject(TObject *obj);

      TGo4AnalysisClient  *fxAnalysisClient{nullptr};
      TGo4Analysis        *fxAnalysis{nullptr};
      TGo4ThreadHandler   *fxThreadHandler{nullptr};

      TString fxServerName;    

      TString fxServerPass;    

      TString fxConnectorName; 

      TString fxObjectThreadName; 

      Int_t fiServerPort{0};

      TGo4Socket  *fxTransport{nullptr}; 

      UInt_t fuObjectPort{0};

      TGo4Socket  *fxConnectTransport{nullptr}; 

      TGo4Socket *fxDisConnectTransport{nullptr}; 

      TString fcConnectHost; 

      UInt_t fuConnectPort{0};

      Bool_t fbConnectRequest{kFALSE};

      Bool_t fbDisConnectRequest{kFALSE};

      Bool_t fbConnectIsOpen{kFALSE};

      Bool_t fbConnectIsDone{kFALSE};

      Bool_t fbConnectIsClose{kFALSE};

      TGo4ObjConnectorTimer *fxConnectorTimer{nullptr}; 

      Bool_t fbUseObjectServer{kFALSE};

   ClassDef(TGo4HistogramServer,1)
};

#endif //TGO4HISTOGRAMSERVER_H