TGo4CommandRunnable Class Reference

#include <TGo4CommandRunnable.h>

Inheritance diagram for TGo4CommandRunnable:

Public Member Functions
	TGo4CommandRunnable (const char *name, TGo4ThreadManager *man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE)
virtual	~TGo4CommandRunnable ()
Int_t	Run (void *ptr) 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
	TGo4CommandRunnable ()
void	RedirectIO ()

Private Attributes
TGo4CommandInvoker *	fxInvoker {nullptr}

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 command exchange between transport (socket) and buffer (queue) In receiver mode, commands are received from transport, checked if sync or not, the command receiver of system (client) commands is set to the clienttask, sync commands are executed directly, async commands are passed to the queue in not receiver mode, runnables waits for the queue and sends all commands from the queue over the transport thread

Definition at line 33 of file TGo4CommandRunnable.h.

Constructor & Destructor Documentation

TGo4CommandRunnable() [1/2]

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

Definition at line 31 of file TGo4CommandRunnable.cxx.

References TGo4TaskHandlerRunnable::fxBufferQueue, fxInvoker, TGo4TaskHandlerRunnable::fxTaskHandler, TGo4TaskHandlerRunnable::fxTransport, TGo4TaskHandler::GetCommandQueue(), TGo4TaskHandler::GetCommandTransport(), and TGo4CommandInvoker::Instance().

~TGo4CommandRunnable()

TGo4CommandRunnable::~TGo4CommandRunnable ( )

virtual

Definition at line 41 of file TGo4CommandRunnable.cxx.

TGo4CommandRunnable() [2/2]

TGo4CommandRunnable::TGo4CommandRunnable ( )

private

Member Function Documentation

RedirectIO()

void TGo4CommandRunnable::RedirectIO ( )

private

for error in socket: redirect std::cout/std::cerr to dummy buffer to avoid trouble if client is running in dying QProcess

Definition at line 199 of file TGo4CommandRunnable.cxx.

Referenced by Run().

Run()

Int_t TGo4CommandRunnable::Run ( void *  ptr )

overridevirtual

The working function which runs in the thread

Implements TGo4TaskHandlerRunnable.

Definition at line 45 of file TGo4CommandRunnable.cxx.

References TGo4BufferQueue::AddBuffer(), TGo4TaskHandlerRunnable::CheckStopBuffer(), TGo4TaskHandlerRunnable::CheckTransportOpen(), TGo4Log::Debug(), TGo4TaskHandlerRunnable::fbReceiverMode, TGo4BufferQueue::FreeBuffer(), TGo4TaskHandlerRunnable::fxBufferQueue, TGo4Runnable::fxManager, TGo4TaskHandlerRunnable::fxTaskHandler, TGo4TaskHandlerRunnable::fxTransport, TGo4TaskHandler::Get_fgcERROR(), TGo4TaskHandler::Get_fgcOK(), TGo4Socket::GetBuffer(), TGo4TaskHandler::GetRole(), TGo4Runnable::GetThread(), TGo4TaskHandler::IsClientMode(), TGo4SocketSignalHandler::IsLastSignalWINCH(), TGo4ThreadManager::IsTerminating(), kComAbortTask, kComCloseInput, kComKillMain, kComQuit, kComRestartMain, kGo4ComModeObserver, TGo4Task::KillMain(), TGo4Socket::ReceiveBuffer(), TGo4Socket::RecvRaw(), RedirectIO(), TGo4Task::RestartMain(), TGo4Socket::Send(), TGo4Socket::SendBuffer(), TGo4ThreadManager::SetBeingQuit(), TGo4SocketSignalHandler::SetLastSignal(), TGo4Thread::Stop(), TGo4Task::SubmitLocalCommand(), and TGo4BufferQueue::WaitBuffer().

Member Data Documentation

fxInvoker

TGo4CommandInvoker* TGo4CommandRunnable::fxInvoker {nullptr}

private

client mode: link to external (static) invoker singleton, that is used to execute the async commands before the command queue server mode: not used

Definition at line 54 of file TGo4CommandRunnable.h.

Referenced by TGo4CommandRunnable().

---

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

• Go4TaskHandler/TGo4CommandRunnable.h
• Go4TaskHandler/TGo4CommandRunnable.cxx