#include <TGo4TaskHandlerRunnable.h>
Public Member Functions | |
TGo4TaskHandlerRunnable (const char *name, TGo4ThreadManager *man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE) | |
virtual | ~TGo4TaskHandlerRunnable () |
virtual Int_t | Run (void *ptr)=0 |
The working function which runs in the thread. | |
TGo4TaskHandler * | GetTaskHandler () |
Protected Member Functions | |
Bool_t | CheckStopBuffer (TBuffer *buf, Int_t *result=0) |
Test if buffer contains a message to stop this runnable. | |
Bool_t | CheckTransportOpen () |
Test if socket transport exists and is open. | |
Protected Attributes | |
TGo4Socket * | fxTransport |
link to external inter-tasl transport channel | |
TGo4TaskHandler * | fxTaskHandler |
link to external task handler (for server mode) 1 1 | |
Bool_t | fbReceiverMode |
flag indicating operation mode of runnable, depending on client or server mode of task handler | |
TGo4BufferQueue * | fxBufferQueue |
Link to external buffer queue. | |
Private Member Functions | |
TGo4TaskHandlerRunnable () |
Definition at line 31 of file TGo4TaskHandlerRunnable.h.
TGo4TaskHandlerRunnable::TGo4TaskHandlerRunnable | ( | const char * | name, | |
TGo4ThreadManager * | man, | |||
TGo4TaskHandler * | hand, | |||
Bool_t | receivermode = kTRUE | |||
) |
Definition at line 25 of file TGo4TaskHandlerRunnable.cxx.
TGo4TaskHandlerRunnable::~TGo4TaskHandlerRunnable | ( | ) | [virtual] |
Definition at line 32 of file TGo4TaskHandlerRunnable.cxx.
TGo4TaskHandlerRunnable::TGo4TaskHandlerRunnable | ( | ) | [private] |
virtual Int_t TGo4TaskHandlerRunnable::Run | ( | void * | ptr | ) | [pure virtual] |
The working function which runs in the thread.
Implements TGo4Runnable.
Implemented in TGo4CommandRunnable, TGo4DataRunnable, and TGo4StatusRunnable.
TGo4TaskHandler * TGo4TaskHandlerRunnable::GetTaskHandler | ( | ) |
Definition at line 36 of file TGo4TaskHandlerRunnable.cxx.
Bool_t TGo4TaskHandlerRunnable::CheckStopBuffer | ( | TBuffer * | buf, | |
Int_t * | result = 0 | |||
) | [protected] |
Test if buffer contains a message to stop this runnable.
This mechanism is used to properly put taskhandler threads into parking position when connection is discarded. Value of buffer is set to external variable result optionally.
Definition at line 41 of file TGo4TaskHandlerRunnable.cxx.
Bool_t TGo4TaskHandlerRunnable::CheckTransportOpen | ( | ) | [protected] |
Test if socket transport exists and is open.
If not open, sleep a while to avoid deadlooping of Run()
Definition at line 68 of file TGo4TaskHandlerRunnable.cxx.
TGo4Socket* TGo4TaskHandlerRunnable::fxTransport [protected] |
link to external inter-tasl transport channel
Definition at line 57 of file TGo4TaskHandlerRunnable.h.
TGo4TaskHandler* TGo4TaskHandlerRunnable::fxTaskHandler [protected] |
link to external task handler (for server mode) 1 1
Definition at line 62 of file TGo4TaskHandlerRunnable.h.
Bool_t TGo4TaskHandlerRunnable::fbReceiverMode [protected] |
flag indicating operation mode of runnable, depending on client or server mode of task handler
Definition at line 66 of file TGo4TaskHandlerRunnable.h.
TGo4BufferQueue* TGo4TaskHandlerRunnable::fxBufferQueue [protected] |
Link to external buffer queue.
For object sending mode.
Definition at line 69 of file TGo4TaskHandlerRunnable.h.