#include <TGo4TaskHandlerRunnable.h>

Inheritance diagram for TGo4TaskHandlerRunnable:

Public Member Functions
	TGo4TaskHandlerRunnable (const char name, TGo4ThreadManager man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE)

virtual	~TGo4TaskHandlerRunnable ()

virtual Int_t	Run (void *ptr)=0

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

Protected Member Functions
Bool_t	CheckStopBuffer (TBuffer buf, Int_t result=0)

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
TGo4Socket *	fxTransport

TGo4TaskHandler *	fxTaskHandler

Bool_t	fbReceiverMode

TGo4BufferQueue *	fxBufferQueue

Protected Attributes inherited from TGo4Runnable
TGo4ThreadManager *	fxManager

TGo4Thread *	fxGo4Thread

Private Member Functions
	TGo4TaskHandlerRunnable ()

Detailed Description

This is the abstract interface for all runnables associated with the taskhandler class interface

Definition at line 31 of file TGo4TaskHandlerRunnable.h.

Constructor & Destructor Documentation

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

Definition at line 25 of file TGo4TaskHandlerRunnable.cxx.

References fbReceiverMode, and fxTaskHandler.

TGo4TaskHandlerRunnable::~TGo4TaskHandlerRunnable ( )

virtual

Definition at line 32 of file TGo4TaskHandlerRunnable.cxx.

TGo4TaskHandlerRunnable::TGo4TaskHandlerRunnable ( )

private

Member Function Documentation

Bool_t TGo4TaskHandlerRunnable::CheckStopBuffer	(	TBuffer *	buf,
		Int_t *	result = `0`
	)

protected

Test if buffer contains a message to stop this runnable. This mechanism is used to properly put taskhandler threads into parking position when connection is discarded. Value of buffer is set to external variable result optionally.

Definition at line 41 of file TGo4TaskHandlerRunnable.cxx.

References TGo4Log::Debug(), TGo4BufferQueue::DecodeValueBuffer(), TGo4Runnable::GetThread(), kComAbortTask, kComCloseInput, and TGo4Thread::Stop().

Referenced by TGo4StatusRunnable::Run(), TGo4DataRunnable::Run(), and TGo4CommandRunnable::Run().

Bool_t TGo4TaskHandlerRunnable::CheckTransportOpen ( )

protected

Test if socket transport exists and is open. If not open, sleep a while to avoid deadlooping of Run()

Definition at line 68 of file TGo4TaskHandlerRunnable.cxx.

References fxTransport, TGo4TaskHandler::Get_fguPORTWAITTIME(), TGo4Socket::IsOpen(), and TGo4Thread::Sleep().

Referenced by TGo4StatusRunnable::Run(), TGo4DataRunnable::Run(), and TGo4CommandRunnable::Run().

TGo4TaskHandler * TGo4TaskHandlerRunnable::GetTaskHandler ( )

Definition at line 36 of file TGo4TaskHandlerRunnable.cxx.

References fxTaskHandler.