---

/Go4TaskHandler/TGo4ClientTask.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 TGO4CLIENTTASK_H
#define TGO4CLIENTTASK_H

#include "Go4ThreadManager/TGo4ThreadManager.h"
#include "Go4CommandsBase/TGo4CommandReceiver.h"
#include "Go4CommandsBase/TGo4Command.h"
#include "TGo4Task.h"
#include "Go4Queue/TGo4BufferQueue.h"
#include "Go4Queue/TGo4ObjectQueue.h"
#include "TGo4TaskStatus.h"
#include "TString.h"

class TMutex;
class TBuffer;
class TNamed;
class TGo4Command;
class TGo4ClientStatus;
class TGo4Status;
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();

      virtual Int_t Initialization();

      virtual void Quit();
   
      virtual TGo4TaskStatus* CreateStatus();

      TGo4TaskHandler* GetTaskHandler();

      void AddLocalCommand(TGo4Command * com);

      

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

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

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

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

      Bool_t DisconnectServer(Bool_t isterminating=kFALSE);

      const char* GetServerHostName(){return fxServerHostname.Data();}


      Bool_t IsConnected(){return fbServerConnected;}

   protected:

      virtual void UpdateStatus(TGo4TaskStatus* state);

   private:
      TGo4BufferQueue* fxStatusQ; 
      TGo4BufferQueue* fxDataQ; 
      TGo4BufferQueue* fxCommandQ; 

      TGo4TaskHandler* fxTaskHandler; 

      TString fxServerHostname;  
      Bool_t fbAutoConnect;

      Bool_t fbServerConnected;
   ClassDef(TGo4ClientTask,1)
};

#endif //TGO4CLIENTTASK_H

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

---