TGo4DataRunnable Class Reference

#include <TGo4DataRunnable.h>

Inheritance diagram for TGo4DataRunnable:

Public Member Functions
	TGo4DataRunnable (const char *name, TGo4ThreadManager *man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE)
virtual	~TGo4DataRunnable ()
Int_t	Run (void *) override
Public Member Functions inherited from TGo4TaskHandlerRunnable
	TGo4TaskHandlerRunnable (const char *name, TGo4ThreadManager *man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE)
virtual	~TGo4TaskHandlerRunnable ()
TGo4TaskHandler *	GetTaskHandler ()
Public Member Functions inherited from TGo4Runnable
	TGo4Runnable (const TGo4Runnable &right)
	TGo4Runnable (const char *name, TGo4ThreadManager *man)
virtual	~TGo4Runnable ()
void	SetThread (TGo4Thread *gthread)
TGo4Thread *	GetThread () const
TGo4ThreadManager *	GetThreadManager () const

Private Member Functions
	TGo4DataRunnable ()

Additional Inherited Members
Protected Member Functions inherited from TGo4TaskHandlerRunnable
Bool_t	CheckStopBuffer (TBuffer *buf, Int_t *result=nullptr)
Bool_t	CheckTransportOpen ()
Protected Member Functions inherited from TGo4Runnable
	TGo4Runnable ()
virtual Int_t	PreRun (void *ptr)
virtual Int_t	PostRun (void *ptr)
virtual void	ThreadCatch (TGo4Exception &ex)
virtual void	UnexpectedCatch ()
Protected Attributes inherited from TGo4TaskHandlerRunnable
TGo4Socket *	fxTransport {nullptr}
TGo4TaskHandler *	fxTaskHandler {nullptr}
Bool_t	fbReceiverMode {kFALSE}
TGo4BufferQueue *	fxBufferQueue {nullptr}
Protected Attributes inherited from TGo4Runnable
TGo4ThreadManager *	fxManager {nullptr}
TGo4Thread *	fxGo4Thread {nullptr}

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 thread

Definition at line 30 of file TGo4DataRunnable.h.

Constructor & Destructor Documentation

TGo4DataRunnable() [1/2]

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

Definition at line 26 of file TGo4DataRunnable.cxx.

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

~TGo4DataRunnable()

TGo4DataRunnable::~TGo4DataRunnable ( )

virtual

Definition at line 36 of file TGo4DataRunnable.cxx.

TGo4DataRunnable() [2/2]

TGo4DataRunnable::TGo4DataRunnable ( )

private

Member Function Documentation

Run()

Int_t TGo4DataRunnable::Run ( void *  ptr )

overridevirtual

The working function which runs in the thread

Implements TGo4TaskHandlerRunnable.

Definition at line 40 of file TGo4DataRunnable.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(), kComQuit, TGo4Socket::ReceiveBuffer(), TGo4Socket::SendBuffer(), TGo4SocketSignalHandler::SetLastSignal(), TGo4Thread::Stop(), TGo4Task::SubmitLocalCommand(), and TGo4BufferQueue::WaitBuffer().

---

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

• Go4TaskHandler/TGo4DataRunnable.h
• Go4TaskHandler/TGo4DataRunnable.cxx