#include <TGo4TaskOwner.h>
Inheritance diagram for TGo4TaskOwner:
Public Member Functions | |
TGo4TaskOwner () | |
TGo4TaskOwner (Bool_t isserver) | |
virtual | ~TGo4TaskOwner () |
Bool_t | IsServer () |
TGo4Task * | GetTask () |
virtual Int_t | StartWorkThreads () |
Start the working threads of the task owner implementation; this method is used after the current connection has changed, to continue reading/writing the queues. | |
virtual Int_t | StopWorkThreads () |
stop the working threads of the task owne implementation; this method is used before the current connection is changed to prevent reading/writing and waiting for the wrong queues. | |
virtual void | Quit () |
Quit this instance and the owned task; method to be called from command object, may be overridden in user implementation. | |
const char * | GetName () const |
Bool_t | IsConnected () |
TMutex * | GetTaskManagerMutex () |
Access to taskmanager mutex; to be locked outside main mutex. | |
Protected Member Functions | |
void | SetTask (TGo4Task *task, Bool_t delold=kTRUE) |
Private Attributes | |
TGo4Task * | fxTask |
1 1 | |
Bool_t | fbServerMode |
Flag if master uses servertask or client task connection. | |
Friends | |
class | TGo4Task |
class | TGo4ServerTask |
Bridge between client/server functionality and master/slave.
Definition at line 29 of file TGo4TaskOwner.h.
|
Definition at line 27 of file TGo4TaskOwner.cxx. |
|
Definition at line 34 of file TGo4TaskOwner.cxx. |
|
Definition at line 41 of file TGo4TaskOwner.cxx. References fxTask, and TGo4Task::SetOwner(). |
|
Definition at line 41 of file TGo4TaskOwner.h. References fbServerMode. Referenced by TGo4Master::DisconnectSlave(), GetTaskManagerMutex(), TGo4TaskHandlerAbortException::Handle(), IsConnected(), TGo4AnalysisMainRunnable::PostRun(), TGo4Master::TGo4Master(), and TGo4Slave::TGo4Slave(). |
|
|
Start the working threads of the task owner implementation; this method is used after the current connection has changed, to continue reading/writing the queues. To be overridden. Reimplemented in TGo4AnalysisClient. Definition at line 65 of file TGo4TaskOwner.cxx. References TGo4Log::Debug(), fxTask, and TGo4Task::SetWorkIsStopped(). Referenced by TGo4Task::StartWorkThreads(), and TGo4AnalysisClient::StartWorkThreads(). |
|
stop the working threads of the task owne implementation; this method is used before the current connection is changed to prevent reading/writing and waiting for the wrong queues. To be overridden. Reimplemented in TGo4AnalysisClient. Definition at line 71 of file TGo4TaskOwner.cxx. References TGo4Log::Debug(), fxTask, and TGo4Task::SetWorkIsStopped(). Referenced by TGo4Task::StopWorkThreads(), and TGo4AnalysisClient::StopWorkThreads(). |
|
Quit this instance and the owned task; method to be called from command object, may be overridden in user implementation.
Definition at line 60 of file TGo4TaskOwner.cxx. References fxTask, and TGo4Task::Quit(). Referenced by TGo4ComMasterQuit::ExeCom(), and TGo4Task::Quit(). |
|
|
Definition at line 79 of file TGo4TaskOwner.cxx. References TGo4ServerTask::GetCurrentTaskHandler(), GetName(), GetTask(), TGo4ClientTask::IsConnected(), and IsServer(). Referenced by TGo4AnalysisProxy::IsConnected(). |
|
Access to taskmanager mutex; to be locked outside main mutex.
Definition at line 104 of file TGo4TaskOwner.cxx. References GetTask(), TGo4ServerTask::GetTaskManager(), and IsServer(). Referenced by TGo4AnalysisMainRunnable::Run(). |
|
Definition at line 53 of file TGo4TaskOwner.cxx. References fxTask, and TGo4Task::SetOwner(). Referenced by TGo4ServerTask::Shutdown(), TGo4Master::TGo4Master(), TGo4Slave::TGo4Slave(), and TGo4Task::~TGo4Task(). |
|
Definition at line 30 of file TGo4TaskOwner.h. |
|
Definition at line 31 of file TGo4TaskOwner.h. Referenced by TGo4Master::TGo4Master(), and TGo4Slave::TGo4Slave(). |
|
Definition at line 78 of file TGo4TaskOwner.h. Referenced by GetName(), GetTask(), Quit(), SetTask(), StartWorkThreads(), StopWorkThreads(), and ~TGo4TaskOwner(). |
|
Flag if master uses servertask or client task connection.
Definition at line 81 of file TGo4TaskOwner.h. Referenced by IsServer(). |