Go4HistogramServer
Class TGo4HistogramServer

class TGo4HistogramServer

derived from TGo4CommandReceiver

Handles a histogram server (mbs histogram protocol) for the
histograms registered in the analysis.

Author:

J. Adamczewski

Since: 23-Sep-2002, reduced 14-Jan-2003

private Bool_t fbConnectIsClose

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

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 Timer

private Bool_t fbDisConnectRequest

True if fxConnectTransport shall be Close() by Timer

private TString fcConnectHost

hostname for timer connect

public const static const Text_t[] fgcCOMGETLIST

command string for object server nameslist request

public const static const Text_t[] fgcCONTHREADNAME

histogram server connector thread name

public const static const Text_t[] fgcOBJTHREADNAME

object server connector thread name

public const static const Text_t[] fgcSHUTDOWNNAME

This string is send as histogram name for termination connection

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, in ms

public const static const UInt_t fguCONNECTWAITCYCLETIME

Time for each connect wait cycle, in ms

public const static const UInt_t fguOPENWAITCYCLETIME

Time for each open wait cycle, in ms

public const static const UInt_t fguTIMERPERIOD

Period of connector timer, in ms

private Int_t fiServerPort

port number for server socket

private UInt_t fuConnectPort

port number for timer connect

private UInt_t fuObjectPort

port number for the object server connections

private TGo4Analysis* fxAnalysis

private TGo4AnalysisClient* fxAnalysisClient

private TString fxConnectorName

Name of connector thread

private TGo4ObjConnectorTimer* 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 Object connector Timer with the client

private TGo4Socket* fxDisConnectTransport

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

private TString fxObjectThreadName

Name of object server thread

private TString fxServerName

contains api server name

private TString fxServerPass

contains api server password

private TGo4ThreadHandler* fxThreadHandler

private TGo4Socket* fxTransport

socket for object server *

public TGo4HistogramServer(TGo4AnalysisClient* owner, const char * servername, const char * password)

public TGo4HistogramServer()

public virtual synchronized ~TGo4HistogramServer()

private Bool_t CheckLogin()

Checks basename and passwd login of connected client

private const const char * ConnectHost()

private Int_t ConnectObjectClient()

Starts server socket waiting for the next client

private const const char * ConnectorName()

private void DisconnectObjectClient()

Terminate connection to current object client, keep waiting for the next one

public const TGo4Analysis* GetAnalysis()

public const TGo4AnalysisClient* GetAnalysisClient()

public UInt_t GetObjPort()

returns the portnumber for object server connection

private Bool_t HandleObjectRequest()

Ask for which object to send and give it to the client

private const const char * ObjectThreadName()

private Bool_t SendObject(TObject* obj)

Send object to the current object client.
Protocol matches TGo4ObjectClient::ReceiveObject()

public Int_t ServeObjectClient()

Used by object connector runnable to serve client request

private void SetConnect(TGo4Socket* trans, const char * host, UInt_t port)

private void SetDisConnect(TGo4Socket* trans)

public virtual Int_t TimerConnect()

This method is used by the object connectortimer Notify to
connect or disconnect a transportchannel (TSocket) on demand;
the connection process itself is handled by the connector runnable

private Int_t WaitForClose()

private Int_t WaitForConnection()

private Int_t WaitForOpen()

Association Links

to Class TGo4AnalysisClient

to Class TGo4Analysis

to Class TGo4ThreadHandler

to Class TGo4Socket

socket for object server *

to Class TGo4Socket

link to the next TaskHandler transport instance that shall be connected
by the Object connector Timer with the client

to Class TGo4Socket

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

to Class TGo4ObjConnectorTimer

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

Supplier Cardinality 1

Type aggregationByValue