TGo4StatusRunnable Class Reference

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. More...

#include <TGo4StatusRunnable.h>

Inheritance diagram for TGo4StatusRunnable:

List of all members.

Public Member Functions
	TGo4StatusRunnable (const char *name, TGo4ThreadManager *man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE)
virtual	~TGo4StatusRunnable ()
virtual Int_t	Run (void *ptr)
	The working function which runs in the thread.
Private Member Functions
	TGo4StatusRunnable ()

---

Detailed Description

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 32 of file TGo4StatusRunnable.h.

---

Constructor & Destructor Documentation

TGo4StatusRunnable::TGo4StatusRunnable (  const char *  name, TGo4ThreadManager *  man, TGo4TaskHandler *  hand, Bool_t  receivermode = kTRUE )

Definition at line 30 of file TGo4StatusRunnable.cxx. References TGo4TaskHandlerRunnable::fxBufferQueue, TGo4TaskHandlerRunnable::fxTaskHandler, TGo4TaskHandlerRunnable::fxTransport, TGo4TaskHandler::GetStatusQueue(), and TGo4TaskHandler::GetStatusTransport().

TGo4StatusRunnable::~TGo4StatusRunnable (   )  [virtual]

Definition at line 38 of file TGo4StatusRunnable.cxx.

TGo4StatusRunnable::TGo4StatusRunnable (   )  [private]

---

Member Function Documentation

Int_t TGo4StatusRunnable::Run (  void *  ptr  )  [virtual]

The working function which runs in the thread. Implements TGo4TaskHandlerRunnable. Definition at line 42 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(), TGo4SocketSignalHandler::GetLastSignal(), TGo4Runnable::GetThread(), TGo4ThreadManager::IsTerminating(), TGo4Socket::ReceiveBuffer(), TGo4Socket::SendBuffer(), TGo4SocketSignalHandler::SetLastSignal(), and TGo4BufferQueue::WaitBuffer().

---

The documentation for this class was generated from the following files:

• Go4TaskHandler/TGo4StatusRunnable.h
• Go4TaskHandler/TGo4StatusRunnable.cxx

---