---

/Go4TaskHandler/TGo4Task.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.
//----------------------------------------------------------------
/* Generated by Together */

#ifndef TGO4TASK_H
#define TGO4TASK_H

#include "Rtypes.h"
#include "TObject.h"
#include "TString.h"
#include "Go4CommandsBase/TGo4Command.h"
#include "Go4CommandsBase/TGo4CommandReceiver.h"
#include "Go4ThreadManager/TGo4ThreadManager.h"
#include "Go4StatusBase/TGo4Status.h"
#include "Go4CommandsTaskHandler/TGo4TaskHandlerCommandList.h"
#include "Go4CommandsTaskHandler/Go4CommandsTaskHandler.h"

#include "TGo4TaskHandler.h"

//#include "Go4Queue/TGo4BufferQueue.h"
//#include "Go4Queue/TGo4ObjectQueue.h"

#include "TGo4TaskStatus.h"
#include <Rtypes.h>
class TGo4TaskOwner;
class TGo4Slave;
class TGo4Master;
class TMutex;
class TBuffer;
class TGo4BufferQueue;
class TGo4ObjectQueue;

class TGo4Task : public TGo4ThreadManager, public TGo4CommandReceiver{

public:
    friend class TGo4LocalCommandRunnable; // access to command queue
    friend class TGo4Slave; // access to UpdateStatus
    friend class TGo4TaskOwner; // set workisstopped flag
    
    TGo4Task(const char* name, Bool_t blockingmode,
                               Bool_t autostart=kFALSE,
                               Bool_t autocreate=kTRUE,
                               Bool_t ismaster=kFALSE);

    virtual ~TGo4Task();

    virtual void Start();

    virtual void Stop();

    virtual void Quit();

    virtual void KillMain();

    virtual void RestartMain();

    virtual void Terminate (Bool_t termapp=kTRUE);

    virtual void TerminateFast ();

    virtual void ExecuteString(const Text_t* command);

    Bool_t IsMaster()
        {
           return fbCommandMaster;   
        }
    
    void SetOwner(TGo4TaskOwner* owner);
    
    virtual TGo4TaskHandler* GetTaskHandler();

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

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

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

    void AddUserCommand(TGo4Command* com);

    void AddUserCommandList(TGo4CommandProtoList * comlist);

    TGo4Status * NextStatus(Bool_t wait=kTRUE);

    TObject * NextObject(Bool_t wait=kTRUE);

    virtual TGo4Command* NextCommand();

    void SendObject(TObject * obj, const char* receiver=0);

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

    virtual void SendStatusBuffer();

    void SendStatusMessage(Int_t level, Bool_t printout, const char* text, ...);

    void UpdateStatusBuffer();  
   
    virtual Int_t Initialization();

    virtual TGo4TaskStatus* CreateStatus();

    Bool_t SubmitCommand(const char* name);

    Bool_t SubmitEmergencyCommand(Go4EmergencyCommand_t val);

    Bool_t SubmitEmergencyData(Go4EmergencyCommand_t val, const char* receiver=0);


    Bool_t SubmitLocalCommand(TGo4Command* com);

    Bool_t SubmitCommand(TGo4Command* com);

    TGo4Command* MakeCommand(const char* name);

    void WakeCommandQueue(Int_t id=0);

    virtual Int_t StartWorkThreads();

    virtual Int_t StopWorkThreads();


    Bool_t IsWorkStopped(){return fbWorkIsStopped;}

 
    virtual void GetStatus();


    const char* GetCommanderName() const { return fxCommanderName.Data(); }

    TGo4Master* GetMaster()
        {
           return fxMaster;   
        }

    TGo4Slave* GetSlave()
        {
           return fxSlave;   
        }


    void SendStopBuffers(const char* taskname=0);



      static const Int_t fgiTERMID;

protected:

    virtual TGo4TaskHandlerCommandList*  CreateCommandList();

    TGo4TaskHandlerCommandList * GetPrototype();

    virtual void UpdateStatus(TGo4TaskStatus* state);

    TGo4ObjectQueue* GetLocalCommandQueue()
        {
           return fxLocalCommandQueue;
        }

    void SetMaster(Bool_t on=kTRUE)
        {
            fbCommandMaster=on;   
        }

    void SetWorkIsStopped(Bool_t on){fbWorkIsStopped=on;}

    TMutex * fxStatusMutex;

    TBuffer* fxStatusBuffer;



private:


  
    void SetMaster(TGo4Master* m)
        {
            if(m) SetMaster(kTRUE);
            fxMaster=m;
        }

    void SetSlave(TGo4Slave* s)
        {
            if(s) SetMaster(kFALSE);
            fxSlave=s;
        }


private:

    TGo4TaskHandlerCommandList * fxCommandPrototype;
    
    TGo4ObjectQueue* fxLocalCommandQueue;

    Bool_t fbCommandMaster;

    TString fxCommanderName;



    TGo4Master * fxMaster; 

    TGo4Slave * fxSlave; 

    TGo4TaskOwner * fxOwner;

    Bool_t fbWorkIsStopped;


    TBuffer* fxStopBuffer; 
    
    TBuffer* fxQuitBuffer; 
        
ClassDef(TGo4Task,1)    
};
#endif //TGO4TASK_H

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

---