TGo4HistogramServer.h

Go to the documentation of this file.

// $Id: TGo4HistogramServer.h 478 2009-10-29 12:26:09Z linev $
//-----------------------------------------------------------------------
//       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 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:

      virtual ~TGo4HistogramServer();

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

      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;
      TGo4Analysis* fxAnalysis;
      TGo4ThreadHandler* fxThreadHandler;

      TString fxServerName;    

      TString fxServerPass;    

      TString fxConnectorName; 

      TString fxObjectThreadName; 

      Int_t fiServerPort;

      TGo4Socket* fxTransport; 

      UInt_t fuObjectPort;

      TGo4Socket * fxConnectTransport; 

      TGo4Socket * fxDisConnectTransport; 

      TString fcConnectHost; 

      UInt_t fuConnectPort;

      Bool_t fbConnectRequest;

      Bool_t fbDisConnectRequest;

      Bool_t fbConnectIsOpen;

      Bool_t fbConnectIsDone;

      Bool_t fbConnectIsClose;

      TGo4ObjConnectorTimer * fxConnectorTimer; 

      Bool_t fbUseObjectServer;


  ClassDef(TGo4HistogramServer,1)
};

#endif //TGO4HISTOGRAMSERVER_H