---

/Go4TaskHandler/TGo4TaskManager.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 TGO4TASKMANAGER_H
#define TGO4TASKMANAGER_H

#include "TNamed.h"
#include "Go4CommandsBase/TGo4Command.h"

class TObjArray;
class TMutex;
class TGo4ServerTask;
class TGo4Socket;
class TGo4TaskHandler;

class TGo4TaskManager : public TNamed {
   public:

      TGo4TaskManager(const char* name, TGo4ServerTask * server, UInt_t negotiationport=0);

      virtual ~TGo4TaskManager();

      Int_t ServeClient();

      Go4CommandMode_t ClientLogin();  

      Int_t ConnectClient(const char* client, const char* host, Go4CommandMode_t role=kGo4ComModeController);

      Int_t DisConnectClient(const char* name , Bool_t clientwait=kTRUE);

      Int_t DisConnectClient(TGo4TaskHandler * taskhandler, Bool_t clientwait=kTRUE);

      Bool_t AddClient(const char* client, const char* host, Go4CommandMode_t role);

      Bool_t AddTaskHandler(TGo4TaskHandler* han);

      TGo4TaskHandler* NewTaskHandler(const char* name);

      Bool_t RemoveTaskHandler(const char* name);

      TGo4TaskHandler* GetTaskHandler(const char* name);

      TGo4TaskHandler* GetLastTaskHandler();

      TGo4TaskHandler* NextTaskHandler(Bool_t reset=kFALSE);

      TMutex* GetMutex(){return fxListMutex;}  

      UInt_t GetTaskCount() const { return fuTaskCount; }

      UInt_t GetNegotiationPort();


     Int_t WaitForClientRemoved();

     Bool_t HasControllerTask(){return fbHasControllerConnection;}
    
      static const Int_t fgiDISCONCYCLES;

      static const UInt_t fguDISCONTIME;
   private:
      // do not use this ctors and assignment operators:

      TGo4TaskManager();

      TGo4TaskManager(const TGo4TaskManager &right);

      TGo4TaskManager & operator=(const TGo4TaskManager &right);

      // private members:

      TGo4ServerTask* fxServer; 

      TGo4Socket* fxTransport; 

      TObjArray* fxTaskList;    

      TMutex* fxListMutex;      

      TIterator* fxTaskIter; 

      /*#  TGo4TaskHandler lnkTGo4TaskHandler1; */
      UInt_t fuTaskCount;

      UInt_t fuNegotiationPort;

      Bool_t fbClientIsRemoved;
      
      Bool_t fbHasControllerConnection;
};

#endif //TGO4TASKMANAGER_H


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

---