Go4TaskHandler
Class TGo4ServerTask

Direct Known Subclasses:

TGo4ExampleServer

class TGo4ServerTask

derived from TGo4Task

Fields inherited from class Go4ThreadManager.TGo4ThreadManager

fbAppBlocking, fbAutoCreate, fbAutoStart, fbInitDone, fbTerminateApplication, fbTerminating, fglTIMERPERIOD, fguTEXTLENGTH, fxBlocker, fxWorkHandler

Fields inherited from class TNamed

fName, fTitle

Constructor Summary

TGo4ServerTask(const char * name, UInt_t negotiationport, Bool_t blockingmode, Bool_t standalone, Bool_t autostart, Bool_t autocreate, Bool_t ismaster)

Destructor Summary
virtual synchronized	~TGo4ServerTask()

Method Summary
Bool_t	ConnectorThreadIsStopped()           Returns the waiting state fbIsWaiting of the Connector Thread;
TGo4BufferQueue*	GetCommandQueue(const char * task)
const const char *	GetConnectHost()
const const char *	GetConnectorName()
TGo4Socket*	GetConnectTransport()
TGo4TaskHandler*	GetCurrentTaskHandler()           Get task handler of the currently activated client connection
TGo4BufferQueue*	GetDataQueue(const char * task)
TGo4BufferQueue*	GetStatusQueue(const char * task)
TGo4TaskHandler*	GetTaskHandler()           Get task handler for client specified by name
TGo4TaskHandler*	GetTaskHandler(const char * name)           Get task handler for client specified by name
TGo4TaskManager*	GetTaskManager()
virtual Int_t	LaunchClient(const char * name, const char * remotehost, const char * remotedir, const char * remotecommand, Int_t mode)           method using a shell script to create a new linux xterm with a client executable.
virtual TGo4Command*	NextCommand()           Delivers next command.
virtual void	Quit()           Quit method used by quit command; may be overridden in special application
virtual Int_t	RemoveAllClients()           Remove all connected client task from this server
virtual Bool_t	RemoveClient(const char * name, Bool_t clientwait, Bool_t isterminating)           Remove the client task specified by name from this server.
Bool_t	RemoveCurrentClient()           removes the currently active client from server (disconnect)
virtual void	SendStatus(TGo4Status* stat, const char * receiver)           Send status object via status channel to the master.
virtual void	SendStatusBuffer()           Send internal status buffer to the master(s).
void	SetConnect(TGo4Socket* trans, const char * host, UInt_t port, Bool_t keepserv)
void	SetCurrentTask(const char * name)           sets current client task (i.e. taskhandler) by name
void	SetDisConnect(TGo4Socket* trans)
void	Shutdown()           Fast Quit() without waiting for proper disconnection.
virtual Bool_t	StartConnectorThread()           starts the thread that listens to the connector port for a client negotiation request; used after launching an rsh client from server
virtual Bool_t	StopConnectorThread()           stops the thread that listens to the connector port for a client negotiation request; used before launching an rsh client from server.
virtual Int_t	TimerConnect()           this method is used by the connectortimer Notify to connect or disconnect a transportchannel (TSocket) on demand; the connection process itself is handled by the connector runnable which uses services of the TaskManager class
Int_t	WaitForClose()
Int_t	WaitForConnection()
Int_t	WaitForOpen()

Methods inherited from class Go4TaskHandler.TGo4Task

AddUserCommand, AddUserCommandList, CreateCommandList, CreateStatus, ExecuteString, GetCommanderName, GetLocalCommandQueue, GetMaster, GetPrototype, GetSlave, GetStatus, Initialization, IsMaster, IsWorkStopped, KillMain, MakeCommand, NextObject, NextStatus, RestartMain, SendObject, SendStatusMessage, SendStopBuffers, SetMaster, SetOwner, SetWorkIsStopped, Start, StartWorkThreads, Stop, StopWorkThreads, SubmitCommand, SubmitCommand, SubmitEmergencyCommand, SubmitEmergencyData, SubmitLocalCommand, Terminate, TerminateFast, UpdateStatus, UpdateStatusBuffer, WakeCommandQueue

Methods inherited from class Go4ThreadManager.TGo4ThreadManager

BlockApp, GetWorkHandler, IsAppBlocking, IsInitDone, IsTerminateApp, IsTerminating, Launch, operator=, SetTimer, UnBlockApp

Methods inherited from class TNamed

operator=, Clear, Clone, Compare, Copy, FillBuffer, GetName, GetTitle, Hash, IsSortable, SetName, SetNameTitle, SetTitle, ls, Print, Sizeof, Class, Class_Name, Class_Version, Dictionary, IsA, ShowMembers, Streamer, StreamerNVirtual, DeclFileName, ImplFileLine, ImplFileName, DeclFileLine

Field Detail

fbConnectIsClose

private Bool_t fbConnectIsClose

True if fxConnectTransport has returned from Close(),
i.e. connection was established

private Bool_t fbConnectIsDone

True if fxConnectTransport has returned from Open(),
i.e. connection was established

private Bool_t fbConnectIsOpen

True if fxConnectTransport waits in server Open() call

private Bool_t fbConnectRequest

True if fxConnectTransport shall be Open() by AppControlTimer

private Bool_t fbDisConnectRequest

True if fxConnectTransport shall be Close() by AppControlTimer

private Bool_t fbKeepServerSocket

True if open in server mode shall keep the server socket instance

public const static const Text_t[] fgcLAUNCHPREFSFILE

Name of the Preferences file for the client startup

public const static const Int_t fgiCLOSEWAITCYCLES

maximum cycles to wait until transport is closed

public const static const Int_t fgiCONNECTWAITCYCLES

maximum cycles to wait until transport is connected

public const static const Int_t fgiOPENWAITCYCLES

maximum cycles to wait until transport is open

public const static const UInt_t fguCLOSEWAITCYCLETIME

time for each close wait cycle

public const static const UInt_t fguCONNECTTIMERPERIOD

period of task connector timer

public const static const UInt_t fguCONNECTWAITCYCLETIME

time for each connect wait cycle

public const static const UInt_t fguOPENWAITCYCLETIME

time for each open wait cycle

private UInt_t fuConnectPort

port number for timer connect

private TString fxConnectHost

hostname for timer connect

private TString fxConnectorName

remember name of connector thread

private TGo4TaskConnectorTimer* fxConnectorTimer

timer responsible for the connection/disconnection of clients;
independent of application control timer

supplierCardinality 1

link aggregationByValue

private TGo4Socket* fxConnectTransport

link to the next TaskHandler transport instance that shall be connected
by the Application Control Timer with the client

private TGo4TaskHandler* fxCurrentTaskHandler

supplierCardinality 1

private TGo4Socket* fxDisConnectTransport

link to the next TaskHandler transport instance that shall be disconnected
by the Application Control Timer with the client

private TGo4TaskManager* fxTaskManager

supplierCardinality 1

link aggregationByValue

public TGo4ServerTask(const char * name, UInt_t negotiationport, Bool_t blockingmode, Bool_t standalone, Bool_t autostart, Bool_t autocreate, Bool_t ismaster)

public virtual synchronized ~TGo4ServerTask()

public Bool_t ConnectorThreadIsStopped()

Returns the waiting state fbIsWaiting of the Connector
Thread;

public TGo4BufferQueue* GetCommandQueue(const char * task)

public const const char * GetConnectHost()

public const const char * GetConnectorName()

public TGo4Socket* GetConnectTransport()

public TGo4TaskHandler* GetCurrentTaskHandler()

Get task handler of the currently activated client connection

public TGo4BufferQueue* GetDataQueue(const char * task)

public TGo4BufferQueue* GetStatusQueue(const char * task)

public TGo4TaskHandler* GetTaskHandler()

Get task handler for client specified by name

public TGo4TaskHandler* GetTaskHandler(const char * name)

Get task handler for client specified by name

public TGo4TaskManager* GetTaskManager()

public virtual Int_t LaunchClient(const char * name, const char * remotehost, const char * remotedir, const char * remotecommand, Int_t mode)

method using a shell script to create
a new linux xterm with a client executable.
May be overridden by specialised subclass methods
to call the script appropriate for the
respective client.
mode specifiers: Bit1=0 - use rsh for starting analysis client
Bit1=1 - use ssh for starting analysis client
Bit2=0 - client in xterm window
Bit2=1 - client without xterm in same shell as gui
Bit3=0 - client outside gui mainframe (not implemented)
Bit3=1 - client embedded in gui mainframe (not implemented)
specify these bits respectively, with kSecureShell, kNoXterm, kGuiEmbed

public virtual TGo4Command* NextCommand()

Delivers next command. This implementation will poll over
command queues of all existing connections. Command is labeled
with name of ordering task, so data may be returned to
command sender only.

public virtual void Quit()

Quit method used by quit command; may be overridden
in special application

public virtual Int_t RemoveAllClients()

Remove all connected client task from this server

public virtual Bool_t RemoveClient(const char * name, Bool_t clientwait, Bool_t isterminating)

Remove the client task specified by name from this server.
If clientwait=true, remove with client handshake. If isterminating=true,
do not restart workthreads after removing the client.

public Bool_t RemoveCurrentClient()

removes the currently active client from server (disconnect)

public virtual void SendStatus(TGo4Status* stat, const char * receiver)

Send status object via status channel to the master. Master name
may be specified, if more than one master is connected.
By default, object is send to all connected tasks

public virtual void SendStatusBuffer()

Send internal status buffer to the master(s).

public void SetConnect(TGo4Socket* trans, const char * host, UInt_t port, Bool_t keepserv)

public void SetCurrentTask(const char * name)

sets current client task (i.e. taskhandler) by name

public void SetDisConnect(TGo4Socket* trans)

public void Shutdown()

Fast Quit() without waiting for proper disconnection.
For analysis server shutdown.

public virtual Bool_t StartConnectorThread()

starts the thread that listens to the connector port
for a client negotiation request; used after launching an
rsh client from server

public virtual Bool_t StopConnectorThread()

stops the thread that listens to the connector port
for a client negotiation request;
used before launching an rsh client from server.
A dummy connection is performed to release socket pending in listening
state, thus runnable may wait afterwards , and no
server socket is listening on spawning the client.
Tests showed that any child process took over the listening
server socket, which is not desired here and probably a bug of the system.

public virtual Int_t TimerConnect()

this method is used by the connectortimer Notify to
connect or disconnect a transportchannel (TSocket) on demand;
the connection process itself is handled by the connector runnable
which uses services of the TaskManager class

public Int_t WaitForClose()

public Int_t WaitForConnection()

public Int_t WaitForOpen()

Association Links

to Class TGo4TaskManager

Supplier Cardinality 1

Type aggregationByValue

to Class TGo4TaskHandler

Supplier Cardinality 1

to Class TGo4Socket

link to the next TaskHandler transport instance that shall be connected
by the Application Control Timer with the client

to Class TGo4Socket

link to the next TaskHandler transport instance that shall be disconnected
by the Application Control Timer with the client

to Class TGo4TaskConnectorTimer

timer responsible for the connection/disconnection of clients;
independent of application control timer

Supplier Cardinality 1

Type aggregationByValue