TGo4ServerTask.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 TGO4SERVERTASK_H
#define TGO4SERVERTASK_H
 
#include "TGo4Task.h"
 
class TGo4TaskManager;
class TGo4TaskHandler;
class TGo4BufferQueue;
class TGo4ObjectQueue;
class TGo4Command;
class TGo4Socket;
class TGo4Status;
class TGo4TaskConnectorTimer;

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

      void Quit() override;

      void Shutdown();
 
      TGo4TaskManager* GetTaskManager();

      TGo4TaskHandler *GetCurrentTaskHandler();

      TGo4TaskHandler *GetTaskHandler() override;

      TGo4TaskHandler *GetTaskHandler(const char *name);
 
      TGo4BufferQueue *GetCommandQueue(const char *task = nullptr) override;
 
      TGo4BufferQueue *GetStatusQueue(const char *task = nullptr) override;
 
      TGo4BufferQueue *GetDataQueue(const char *task = nullptr) override;

      TGo4Command *NextCommand() override;
 

      void SendStatus(TGo4Status *stat, const char *receiver = nullptr) override;

      void SendStatusBuffer() override;

      virtual Bool_t StartConnectorThread();

      virtual Bool_t StopConnectorThread();

      Bool_t ConnectorThreadIsStopped();

      void SetCurrentTask(const char *name);
 
      void SetConnect(TGo4Socket *trans, const char *host, UInt_t port, Bool_t keepserv = kFALSE);
 
      void SetDisConnect(TGo4Socket *trans);
 
      TGo4Socket *GetConnectTransport();
 
      const char *GetConnectorName() const { return fxConnectorName.Data();}
 
      const char *GetConnectHost() const { return fxConnectHost.Data();}

      virtual Int_t TimerConnect();

      virtual Int_t RemoveAllClients(Bool_t force = false);

      virtual Bool_t RemoveClient(const char *name, Bool_t clientwait=kTRUE, Bool_t isterminating=kFALSE);

      Bool_t RemoveCurrentClient();
 
      Int_t WaitForOpen();
 
      Int_t WaitForClose();
 
      Int_t WaitForConnection();
 
      static const char *Get_fgcLAUNCHPREFSFILE();
 
   protected:
      // public static constants:
      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;

      static const UInt_t fguCONNECTTIMERPERIOD;

      static const char *fgcLAUNCHPREFSFILE;
 
private:

      TString fxConnectorName;

      TGo4TaskManager   *fxTaskManager{nullptr};

      TGo4TaskHandler   *fxCurrentTaskHandler{nullptr}; 

      TGo4Socket    *fxConnectTransport{nullptr}; 

      TGo4Socket    *fxDisConnectTransport{nullptr}; 

      TString fxConnectHost;

      UInt_t fuConnectPort{0};

      Bool_t fbKeepServerSocket{kFALSE};

      Bool_t fbConnectRequest{kFALSE};

      Bool_t fbDisConnectRequest{kFALSE};

      Bool_t fbConnectIsOpen{kFALSE};

      Bool_t fbConnectIsDone{kFALSE};

      Bool_t fbConnectIsClose{kFALSE};

      TGo4TaskConnectorTimer * fxConnectorTimer{nullptr};
public:
 
      enum ELaunchmodes{
         kSecureShell    = BIT(0),     // kTRUE=launch client with ssh, otherwise rsh
         kGuiEmbed       = BIT(1)      // kTRUE=client terminial embedded in gui otherwise in Xterm
    };
 
 
ClassDefOverride(TGo4ServerTask,1)
};
 
#endif //TGO4SERVERTASK_H