#include <TGo4StatusRunnable.h>
Public Member Functions | |
| TGo4StatusRunnable (const char *name, TGo4ThreadManager *man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE) | |
| virtual | ~TGo4StatusRunnable () |
| virtual Int_t | Run (void *ptr) |
Private Member Functions | |
| TGo4StatusRunnable () | |
Runnable responsible for status object exchange between transport (socket) and buffer (queue) In receiver mode, status objects are received from transport and passed to the queue in non receiver mode, runnables waits for the queue and sends all status objects from the queue over the transport thread
Definition at line 30 of file TGo4StatusRunnable.h.
| TGo4StatusRunnable::TGo4StatusRunnable | ( | const char * | name, | |
| TGo4ThreadManager * | man, | |||
| TGo4TaskHandler * | hand, | |||
| Bool_t | receivermode = kTRUE | |||
| ) |
Definition at line 27 of file TGo4StatusRunnable.cxx.
References TGo4TaskHandlerRunnable::fxBufferQueue, TGo4TaskHandlerRunnable::fxTaskHandler, TGo4TaskHandlerRunnable::fxTransport, TGo4TaskHandler::GetStatusQueue(), and TGo4TaskHandler::GetStatusTransport().
| TGo4StatusRunnable::~TGo4StatusRunnable | ( | ) | [virtual] |
Definition at line 35 of file TGo4StatusRunnable.cxx.
| TGo4StatusRunnable::TGo4StatusRunnable | ( | ) | [private] |
| Int_t TGo4StatusRunnable::Run | ( | void * | ptr | ) | [virtual] |
The working function which runs in the thread
Implements TGo4TaskHandlerRunnable.
Definition at line 39 of file TGo4StatusRunnable.cxx.
References TGo4BufferQueue::AddBuffer(), TGo4TaskHandlerRunnable::CheckStopBuffer(), TGo4TaskHandlerRunnable::CheckTransportOpen(), TGo4Log::Debug(), TGo4TaskHandlerRunnable::fbReceiverMode, TGo4BufferQueue::FreeBuffer(), TGo4TaskHandlerRunnable::fxBufferQueue, TGo4Runnable::fxManager, TGo4TaskHandlerRunnable::fxTransport, TGo4Socket::GetBuffer(), TGo4Runnable::GetThread(), TGo4SocketSignalHandler::IsLastSignalWINCH(), TGo4ThreadManager::IsTerminating(), TGo4Socket::ReceiveBuffer(), TGo4Socket::SendBuffer(), TGo4SocketSignalHandler::SetLastSignal(), TGo4Thread::Stop(), and TGo4BufferQueue::WaitBuffer().
1.7.1
