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