#include <TGo4DataRunnable.h>
Inheritance diagram for TGo4DataRunnable:
Public Methods | |
TGo4DataRunnable (const char *name, TGo4ThreadManager *man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE) | |
virtual | ~TGo4DataRunnable () |
virtual Int_t | Run (void *ptr) |
The working function which runs in the thread. More... | |
Private Methods | |
TGo4DataRunnable () |
Definition at line 32 of file TGo4DataRunnable.h.
|
Definition at line 30 of file TGo4DataRunnable.cxx. References TGo4TaskHandlerRunnable::fxBufferQueue, TGo4TaskHandlerRunnable::fxTaskHandler, TGo4TaskHandlerRunnable::fxTransport, TGo4TaskHandler::GetDataQueue(), and TGo4TaskHandler::GetDataTransport(). |
|
Definition at line 40 of file TGo4DataRunnable.cxx. |
|
|
|
The working function which runs in the thread.
Implements TGo4TaskHandlerRunnable. Definition at line 44 of file TGo4DataRunnable.cxx. References TGo4BufferQueue::AddBuffer(), TGo4TaskHandlerRunnable::CheckStopBuffer(), TGo4TaskHandlerRunnable::CheckTransportOpen(), TGo4Log::Debug(), TGo4SocketSignalHandler::fgiLastSignal, TGo4BufferQueue::FreeBuffer(), TGo4TaskHandlerRunnable::fxBufferQueue, TGo4Runnable::fxManager, TGo4TaskHandlerRunnable::fxTaskHandler, TGo4TaskHandlerRunnable::fxTransport, TGo4Socket::GetBuffer(), TGo4Runnable::GetThread(), Go4EmergencyCommand_t, TGo4ThreadManager::IsTerminating(), kComQuit, TGo4Socket::ReceiveBuffer(), TGo4Socket::SendBuffer(), TGo4Thread::Stop(), TGo4Task::SubmitLocalCommand(), and TGo4BufferQueue::WaitBuffer(). |