#include <TGo4TaskHandlerRunnable.h>

Inheritance diagram for TGo4TaskHandlerRunnable:

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

virtual	~TGo4TaskHandlerRunnable ()

Int_t	Run (void *ptr) override=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=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
TGo4Socket *	fxTransport {nullptr}

TGo4TaskHandler *	fxTaskHandler {nullptr}

Bool_t	fbReceiverMode {kFALSE}

TGo4BufferQueue *	fxBufferQueue {nullptr}

Protected Attributes inherited from TGo4Runnable
TGo4ThreadManager *	fxManager {nullptr}

TGo4Thread *	fxGo4Thread {nullptr}

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() [1/2]

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::~TGo4TaskHandlerRunnable ( )

virtual

Definition at line 32 of file TGo4TaskHandlerRunnable.cxx.

◆ TGo4TaskHandlerRunnable() [2/2]

TGo4TaskHandlerRunnable::TGo4TaskHandlerRunnable ( )

private

Member Function Documentation

◆ CheckStopBuffer()

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

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