Main Page   Namespace List   Class Hierarchy   Alphabetical List   Compound List   File List   Compound Members   File Members  

TGo4DataRunnable Class Reference

Runnable responsible for data object exchange between transport (socket) and buffer (queue) In receiver mode, data objects are received from transport and passed to the queue in non receiver mode, runnables waits for the queue and sends all data objects from the queue over the transport @stereotype thread. More...

#include <TGo4DataRunnable.h>

Inheritance diagram for TGo4DataRunnable:

TGo4TaskHandlerRunnable TGo4Runnable List of all members.

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 ()

Detailed Description

Runnable responsible for data object exchange between transport (socket) and buffer (queue) In receiver mode, data objects are received from transport and passed to the queue in non receiver mode, runnables waits for the queue and sends all data objects from the queue over the transport @stereotype thread.

Definition at line 32 of file TGo4DataRunnable.h.


Constructor & Destructor Documentation

TGo4DataRunnable::TGo4DataRunnable const char *    name,
TGo4ThreadManager   man,
TGo4TaskHandler   hand,
Bool_t    receivermode = kTRUE
 

Definition at line 30 of file TGo4DataRunnable.cxx.

References TGo4TaskHandlerRunnable::fxBufferQueue, TGo4TaskHandlerRunnable::fxTaskHandler, TGo4TaskHandlerRunnable::fxTransport, TGo4TaskHandler::GetDataQueue(), and TGo4TaskHandler::GetDataTransport().

TGo4DataRunnable::~TGo4DataRunnable   [virtual]
 

Definition at line 40 of file TGo4DataRunnable.cxx.

TGo4DataRunnable::TGo4DataRunnable   [private]
 


Member Function Documentation

Int_t TGo4DataRunnable::Run void *    ptr [virtual]
 

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().


The documentation for this class was generated from the following files:
Generated on Tue Nov 8 10:56:35 2005 for Go4-v2.10-5 by doxygen1.2.15