TGo4ClientTask.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 TGO4CLIENTTASK_H
#define TGO4CLIENTTASK_H
 
#include "TGo4Task.h"
 
#include "TGo4Command.h"
#include "TString.h"
 
class TMutex;
class TGo4Command;
class TGo4BufferQueue;
class TGo4TaskHandler;

class TGo4ClientTask : public TGo4Task {
 
   public:
 
      TGo4ClientTask(const char *name,
                     const char *serverhost = "localhost",
                     UInt_t negotiationport = 0,
                     Bool_t blockingmode = kTRUE,
                     Bool_t standalone = kFALSE,
                     Bool_t autostart = kFALSE,
                     Bool_t autocreate = kTRUE,
                     Bool_t ismaster = kFALSE,
                     Bool_t autoconnect = kTRUE);
 
      virtual ~TGo4ClientTask();

      Int_t Initialization() override;

      void Quit() override;

      TGo4TaskStatus *CreateStatus() override;
 
      TGo4TaskHandler *GetTaskHandler() override;

      void AddLocalCommand(TGo4Command *com);
 
      TGo4BufferQueue *GetCommandQueue(const char *task = nullptr) override;
 
      TGo4BufferQueue *GetStatusQueue(const char *task = nullptr) override;
 
      TGo4BufferQueue *GetDataQueue(const char *task = nullptr) override;

      Bool_t ConnectServer(const char *node, UInt_t negport,
                            Go4CommandMode_t role=kGo4ComModeRefused,
                            const char *passwd = nullptr);

      Bool_t DisconnectServer(Bool_t isterminating=kFALSE);
 
      const char *GetServerHostName() const { return fxServerHostname.Data(); }
 
      Bool_t IsConnected() const { return fbServerConnected; }
 
   protected:

      void UpdateStatus(TGo4TaskStatus *state) override;
 
   private:
      TGo4BufferQueue *fxStatusQ{nullptr}; 
      TGo4BufferQueue *fxDataQ{nullptr}; 
      TGo4BufferQueue *fxCommandQ{nullptr}; 

      TGo4TaskHandler *fxTaskHandler{nullptr}; 

      TString fxServerHostname;
      Bool_t fbAutoConnect{kFALSE};

      Bool_t fbServerConnected{kFALSE};
 
   ClassDefOverride(TGo4ClientTask,1)
};
 
#endif //TGO4CLIENTTASK_H