TGo4ServerTask.h

Go to the documentation of this file.

// $Id: TGo4ServerTask.h 1457 2015-05-28 14:59:14Z 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 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();

      virtual void Quit();

      void Shutdown();

      TGo4TaskManager* GetTaskManager();

      TGo4TaskHandler* GetCurrentTaskHandler();

      TGo4TaskHandler* GetTaskHandler();

      TGo4TaskHandler* GetTaskHandler(const char* name);

      TGo4BufferQueue* GetCommandQueue(const char* task=0);

      TGo4BufferQueue* GetStatusQueue(const char* task=0);

      TGo4BufferQueue* GetDataQueue(const char* task=0);

      virtual TGo4Command* NextCommand();


      virtual void SendStatus(TGo4Status * stat, const char* receiver=0);

      virtual void SendStatusBuffer();

      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;

      TGo4TaskHandler * fxCurrentTaskHandler; 

      TGo4Socket * fxConnectTransport; 

      TGo4Socket * fxDisConnectTransport; 

      TString fxConnectHost;

      UInt_t fuConnectPort;

      Bool_t fbKeepServerSocket;

      Bool_t fbConnectRequest;

      Bool_t fbDisConnectRequest;


      Bool_t fbConnectIsOpen;

      Bool_t fbConnectIsDone;

      Bool_t fbConnectIsClose;

      TGo4TaskConnectorTimer * fxConnectorTimer;
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
    };


ClassDef(TGo4ServerTask,1)
};

#endif //TGO4SERVERTASK_H