#include <TGo4HistogramServer.h>

Inheritance diagram for TGo4HistogramServer:

Public Member Functions
virtual	~TGo4HistogramServer ()
	TGo4HistogramServer (TGo4AnalysisClient owner, const char servername="localhost", const char *password="go4", Bool_t useobjectserver=kFALSE)
	TGo4HistogramServer ()
Int_t	ServeObjectClient ()
UInt_t	GetObjPort ()
virtual Int_t	TimerConnect ()
TGo4AnalysisClient *	GetAnalysisClient () const
TGo4Analysis *	GetAnalysis () const
Static Public Attributes
static const char *	fgcCONTHREADNAME = "HISTOSERV-"
static const char *	fgcOBJTHREADNAME = "OBJECTSERV-"
static const char *	fgcSHUTDOWNNAME = "__HServLast__"
static const char *	fgcCOMGETLIST = "__OServNamesList__"
static const UInt_t	fguTIMERPERIOD = 200
static const Int_t	fgiOPENWAITCYCLES = 100
static const UInt_t	fguOPENWAITCYCLETIME = 500
static const Int_t	fgiCLOSEWAITCYCLES = 100
static const UInt_t	fguCLOSEWAITCYCLETIME = 500
static const Int_t	fgiCONNECTWAITCYCLES = 20
static const UInt_t	fguCONNECTWAITCYCLETIME = 500
Private Member Functions
const char *	ConnectorName () const
const char *	ObjectThreadName () const
const char *	ConnectHost () const
void	SetConnect (TGo4Socket trans, const char host, UInt_t port)
void	SetDisConnect (TGo4Socket *trans)
Int_t	WaitForOpen ()
Int_t	WaitForClose ()
Int_t	WaitForConnection ()
void	DisconnectObjectClient ()
Bool_t	CheckLogin ()
Int_t	ConnectObjectClient ()
Bool_t	HandleObjectRequest ()
Bool_t	SendObject (TObject *obj)
Private Attributes
TGo4AnalysisClient *	fxAnalysisClient
TGo4Analysis *	fxAnalysis
TGo4ThreadHandler *	fxThreadHandler
TString	fxServerName
TString	fxServerPass
TString	fxConnectorName
TString	fxObjectThreadName
Int_t	fiServerPort
TGo4Socket *	fxTransport
UInt_t	fuObjectPort
TGo4Socket *	fxConnectTransport
TGo4Socket *	fxDisConnectTransport
TString	fcConnectHost
UInt_t	fuConnectPort
Bool_t	fbConnectRequest
Bool_t	fbDisConnectRequest
Bool_t	fbConnectIsOpen
Bool_t	fbConnectIsDone
Bool_t	fbConnectIsClose
TGo4ObjConnectorTimer *	fxConnectorTimer
Bool_t	fbUseObjectServer
Friends
class	TGo4HisConnectorRunnable

Detailed Description

Handles a histogram server (mbs histogram protocol) for the histograms registered in the analysis. Optionally, object server for root may be started using Go4 protocoll style. This was disabled for V3 by default 09/2005

Author:: J. Adamczewski

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

Definition at line 35 of file TGo4HistogramServer.h.

Constructor & Destructor Documentation

TGo4HistogramServer::~TGo4HistogramServer ( ) [virtual]

remove and delete the objectserver thread:

Definition at line 148 of file TGo4HistogramServer.cxx.

References TGo4Socket::Close(), ConnectorName(), f_his_close(), f_his_gethis(), fbUseObjectServer, fgcSHUTDOWNNAME, fiServerPort, fxConnectorTimer, fxServerName, fxServerPass, fxThreadHandler, fxTransport, ObjectThreadName(), TGo4ThreadHandler::RemoveThread(), TGo4ThreadHandler::Stop(), and TGo4CommandInvoker::UnRegister().

TGo4HistogramServer::TGo4HistogramServer	(	TGo4AnalysisClient *	owner,
		const char *	servername = `"localhost"`,
		const char *	password = `"go4"`,
		Bool_t	useobjectserver = `kFALSE`
	)

TGo4HistogramServer::TGo4HistogramServer ( )

Definition at line 135 of file TGo4HistogramServer.cxx.

References TGo4CommandInvoker::Instance(), and TGo4CommandInvoker::Register().

Member Function Documentation

Bool_t TGo4HistogramServer::CheckLogin ( ) [private]

Checks basename and passwd login of connected client

Definition at line 274 of file TGo4HistogramServer.cxx.

References DisconnectObjectClient(), fxServerName, fxServerPass, fxTransport, TGo4TaskHandler::Get_fgcERROR(), TGo4TaskHandler::Get_fgcOK(), TGo4Socket::RecvRaw(), and TGo4Socket::Send().

Referenced by ServeObjectClient().

const char* TGo4HistogramServer::ConnectHost ( ) const [inline, private]

Definition at line 104 of file TGo4HistogramServer.h.

References fcConnectHost.

Referenced by TimerConnect().

Int_t TGo4HistogramServer::ConnectObjectClient ( ) [private]

Starts server socket waiting for the next client

Definition at line 213 of file TGo4HistogramServer.cxx.

References TGo4Log::Debug(), fuObjectPort, fxAnalysisClient, fxServerName, fxTransport, TGo4TaskHandler::Get_fgiPORTWAITCYCLES(), TGo4TaskHandler::Get_fguPORTWAITTIME(), GetObjPort(), TGo4TaskOwner::GetTask(), TGo4Analysis::Instance(), TGo4ThreadManager::IsTerminating(), TGo4Analysis::Message(), SetConnect(), TGo4Thread::Sleep(), WaitForConnection(), and WaitForOpen().

Referenced by ServeObjectClient().

const char* TGo4HistogramServer::ConnectorName ( ) const [inline, private]

Definition at line 100 of file TGo4HistogramServer.h.

References fxConnectorName.

Referenced by TGo4HistogramServer(), and ~TGo4HistogramServer().

void TGo4HistogramServer::DisconnectObjectClient ( ) [private]

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

Definition at line 204 of file TGo4HistogramServer.cxx.

References fxTransport, SetDisConnect(), and WaitForClose().

Referenced by CheckLogin(), and ServeObjectClient().

TGo4Analysis* TGo4HistogramServer::GetAnalysis ( ) const [inline]

Definition at line 63 of file TGo4HistogramServer.h.

References fxAnalysis.

Referenced by TGo4HisConnectorRunnable::Run().

TGo4AnalysisClient* TGo4HistogramServer::GetAnalysisClient ( ) const [inline]

Definition at line 61 of file TGo4HistogramServer.h.

References fxAnalysisClient.

UInt_t TGo4HistogramServer::GetObjPort ( )

returns the portnumber for object server connection

Definition at line 570 of file TGo4HistogramServer.cxx.

References fuObjectPort, fxTransport, and TGo4Socket::GetPort().

Referenced by ConnectObjectClient().

Bool_t TGo4HistogramServer::HandleObjectRequest ( ) [private]

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

Definition at line 312 of file TGo4HistogramServer.cxx.

References fgcCOMGETLIST, TGo4ThreadManager::fguTEXTLENGTH, fxAnalysis, fxTransport, TGo4Analysis::GetNamesList(), TGo4Analysis::GetObject(), TGo4Socket::RecvRaw(), SendObject(), and TGo4Analysis::UpdateNamesList().

Referenced by ServeObjectClient().

const char* TGo4HistogramServer::ObjectThreadName ( ) const [inline, private]

Definition at line 102 of file TGo4HistogramServer.h.

References fxObjectThreadName.

Referenced by TGo4HistogramServer(), and ~TGo4HistogramServer().

Bool_t TGo4HistogramServer::SendObject ( TObject * obj ) [private]

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

Definition at line 344 of file TGo4HistogramServer.cxx.

References TGo4Log::Debug(), fxTransport, TGo4TaskHandler::Get_fgcERROR(), TGo4TaskHandler::Get_fgcOK(), TGo4Socket::RecvRaw(), TGo4Socket::Send(), TGo4Socket::SendBuffer(), and TGo4Buffer.

Referenced by HandleObjectRequest().

Int_t TGo4HistogramServer::ServeObjectClient ( )

Used by object connector runnable to serve client request

Definition at line 192 of file TGo4HistogramServer.cxx.

References CheckLogin(), ConnectObjectClient(), DisconnectObjectClient(), and HandleObjectRequest().

Referenced by TGo4ObjConnectorRunnable::Run().

void TGo4HistogramServer::SetConnect	(	TGo4Socket *	trans,
		const char *	host,
		UInt_t	port
	)			`[private]`

Definition at line 387 of file TGo4HistogramServer.cxx.

References fbConnectRequest, fcConnectHost, fuConnectPort, fxConnectTransport, and GO4TRACE.

Referenced by ConnectObjectClient().

void TGo4HistogramServer::SetDisConnect ( TGo4Socket * trans ) [private]

Definition at line 396 of file TGo4HistogramServer.cxx.

References fbDisConnectRequest, fxDisConnectTransport, and GO4TRACE.

Referenced by DisconnectObjectClient().

Int_t TGo4HistogramServer::TimerConnect ( ) [virtual]

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

Definition at line 403 of file TGo4HistogramServer.cxx.

References TGo4Socket::Close(), ConnectHost(), fbConnectIsClose, fbConnectIsDone, fbConnectIsOpen, fbConnectRequest, fbDisConnectRequest, fuConnectPort, fxConnectTransport, fxDisConnectTransport, GO4TRACE, TGo4Socket::IsOpen(), and TGo4Socket::Open().