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

#include "TNamed.h"
#include "TGo4Command.h"

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

class TGo4TaskManager : public TNamed {
   public:

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

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

      // private members:

      TGo4ServerTask *fxServer{nullptr}; 

      TGo4Socket *fxTransport{nullptr}; 

      TObjArray *fxTaskList{nullptr};    

      TMutex  *fxListMutex{nullptr};      

      TIterator  *fxTaskIter{nullptr}; 

      UInt_t fuTaskCount{0};

      UInt_t fuNegotiationPort{0};

      Bool_t fbClientIsRemoved{kFALSE};

      Bool_t fbHasControllerConnection{kFALSE};
};

#endif //TGO4TASKMANAGER_H