---

/Go4TaskHandler/TGo4ServerTask.h

Go to the documentation of this file.

//---------------------------------------------------------------
//        Go4 Release Package v2.10-5 (build 21005) 
//                      03-Nov-2005
//---------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//       Experiment Data Processing at DVEE department, GSI
//---------------------------------------------------------------
//
//Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI
//                    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 "Go4ThreadManager/TGo4ThreadManager.h"
#include "Go4CommandsBase/TGo4CommandReceiver.h"
#include "Go4CommandsTaskHandler/Go4CommandsTaskHandler.h"
#include "Go4TaskHandler/TGo4TaskConnectorTimer.h"
#include "TGo4Task.h"
#include "Rtypes.h"
#include <Rtypes.h>

class TGo4TaskManager;
class TGo4TaskHandler;
class TGo4BufferQueue;
class TGo4ObjectQueue;
class TGo4Command;
class TGo4Socket;
class TGo4Status;

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();

      virtual Int_t LaunchClient(const char* name, 
                                 const char* remotehost=0,
                                 const char* remotedir=0, 
                                 const char* remotecommand=0, 
                                 Int_t mode=0);

      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();

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

      Bool_t RemoveCurrentClient();

      Int_t WaitForOpen();

//      /**
//       * Overrides the ThreadManager Initialization; is used to setup the
//       * client connections on demand; checks for fbConnectRequest flag
//       */
//      virtual Int_t Initialization();

      Int_t WaitForClose();

      Int_t WaitForConnection();

      // 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;
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
    };


      static const Text_t fgcLAUNCHPREFSFILE[];
ClassDef(TGo4ServerTask,1)
};

#endif //TGO4SERVERTASK_H

//----------------------------END OF GO4 SOURCE FILE ---------------------

---