48 TBuffer *buf =
const_cast<TBuffer *
> (
fxTransport->GetBuffer());
78 TGo4Log::Debug(
"Receive Error in %s during threadmanager termination. Ignored.",GetName());
Class containing a pointer queue for TBuffers.
master command: current slave is removed (disconnected) from server
This is the Go4 Abstract Command Class; part of the Base command pattern.
virtual ~TGo4DataRunnable()
Int_t Run(void *) override
The working function which runs in the thread.
static void Debug(const char *text,...) GO4_PRINTF_ARGS
User shortcut for message with prio 0.
TGo4Thread * GetThread() const
TGo4ThreadManager * fxManager
The threadmanager which is responsible for our thread.
static bool IsLastSignalWINCH()
static void SetLastSignal(Int_t v=0)
Bool_t fbReceiverMode
flag indicating operation mode of runnable, depending on client or server mode of task handler
Bool_t CheckTransportOpen()
Test if socket transport exists and is open.
Bool_t CheckStopBuffer(TBuffer *buf, Int_t *result=nullptr)
Test if buffer contains a message to stop this runnable.
TGo4TaskHandler * fxTaskHandler
link to external task handler (for server mode) 1 1
TGo4Socket * fxTransport
link to external inter-tasl transport channel
TGo4TaskHandlerRunnable(const char *name, TGo4ThreadManager *man, TGo4TaskHandler *hand, Bool_t receivermode=kTRUE)
TGo4BufferQueue * fxBufferQueue
Link to external buffer queue.
This class is responsible for the interconnection of two tasks: provided are three communication chan...
Bool_t SubmitLocalCommand(TGo4Command *com)
Send given command to the current client task.
Bool_t Stop()
resets running flag for runnable