GSI Object Oriented Online Offline (Go4)  GO4-6.3.0
Public Member Functions | Static Public Attributes | Private Member Functions | Private Attributes | Friends | List of all members
TGo4HistogramServer Class Reference

#include <TGo4HistogramServer.h>

+ Inheritance diagram for TGo4HistogramServer:

Public Member Functions

 TGo4HistogramServer ()
 
 TGo4HistogramServer (TGo4AnalysisClient *owner, const char *servername="localhost", const char *password="go4", Bool_t useobjectserver=kFALSE)
 
virtual ~TGo4HistogramServer ()
 
Int_t ServeObjectClient ()
 
UInt_t GetObjPort ()
 
virtual Int_t TimerConnect ()
 
TGo4AnalysisClient * GetAnalysisClient () const
 
TGo4Analysis * GetAnalysis () const
 
- Public Member Functions inherited from TGo4CommandReceiver
 TGo4CommandReceiver ()
 
virtual ~TGo4CommandReceiver ()
 

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 {nullptr}
 
TGo4Analysis * fxAnalysis {nullptr}
 
TGo4ThreadHandler * fxThreadHandler {nullptr}
 
TString fxServerName
 
TString fxServerPass
 
TString fxConnectorName
 
TString fxObjectThreadName
 
Int_t fiServerPort {0}
 
TGo4Socket * fxTransport {nullptr}
 
UInt_t fuObjectPort {0}
 
TGo4Socket * fxConnectTransport {nullptr}
 
TGo4Socket * fxDisConnectTransport {nullptr}
 
TString fcConnectHost
 
UInt_t fuConnectPort {0}
 
Bool_t fbConnectRequest {kFALSE}
 
Bool_t fbDisConnectRequest {kFALSE}
 
Bool_t fbConnectIsOpen {kFALSE}
 
Bool_t fbConnectIsDone {kFALSE}
 
Bool_t fbConnectIsClose {kFALSE}
 
TGo4ObjConnectorTimer * fxConnectorTimer {nullptr}
 
Bool_t fbUseObjectServer {kFALSE}
 

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 protocol 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() [1/2]

TGo4HistogramServer::TGo4HistogramServer ( )

Definition at line 113 of file TGo4HistogramServer.cxx.

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

◆ TGo4HistogramServer() [2/2]

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

Definition at line 55 of file TGo4HistogramServer.cxx.

References COMM__SUCCESS, ConnectorName(), f_his_server(), fbUseObjectServer, fgcCONTHREADNAME, fgcOBJTHREADNAME, fguTIMERPERIOD, fiServerPort, fxAnalysis, fxAnalysisClient, fxConnectorName, fxConnectorTimer, fxObjectThreadName, fxServerName, fxServerPass, fxThreadHandler, fxTransport, TGo4AnalysisClient::GetAnalysis(), TGo4TaskOwner::GetName(), TGo4Slave::GetThreadHandler(), TGo4CommandInvoker::Instance(), TGo4Analysis::Instance(), TGo4Analysis::Message(), TGo4ThreadHandler::NewThread(), ObjectThreadName(), TGo4CommandInvoker::Register(), TGo4ThreadHandler::Start(), and TGo4HisConnectorRunnable.

◆ ~TGo4HistogramServer()

TGo4HistogramServer::~TGo4HistogramServer ( )
virtual

remove and delete the objectserver thread:

Definition at line 123 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().

Member Function Documentation

◆ CheckLogin()

Bool_t TGo4HistogramServer::CheckLogin ( )
private

Checks basename and passwd login of connected client

Definition at line 230 of file TGo4HistogramServer.cxx.

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

Referenced by ConnectHost(), and ServeObjectClient().

◆ ConnectHost()

const char* TGo4HistogramServer::ConnectHost ( ) const
inlineprivate

Definition at line 104 of file TGo4HistogramServer.h.

References CheckLogin(), ConnectObjectClient(), DisconnectObjectClient(), fcConnectHost, HandleObjectRequest(), SendObject(), SetConnect(), SetDisConnect(), WaitForClose(), WaitForConnection(), and WaitForOpen().

Referenced by TimerConnect().

◆ ConnectObjectClient()

Int_t TGo4HistogramServer::ConnectObjectClient ( )
private

Starts server socket waiting for the next client

Definition at line 181 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 ConnectHost(), and ServeObjectClient().

◆ ConnectorName()

const char* TGo4HistogramServer::ConnectorName ( ) const
inlineprivate

Definition at line 100 of file TGo4HistogramServer.h.

References fxConnectorName.

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

◆ DisconnectObjectClient()

void TGo4HistogramServer::DisconnectObjectClient ( )
private

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

Definition at line 172 of file TGo4HistogramServer.cxx.

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

Referenced by CheckLogin(), ConnectHost(), and ServeObjectClient().

◆ GetAnalysis()

TGo4Analysis* TGo4HistogramServer::GetAnalysis ( ) const
inline

Definition at line 63 of file TGo4HistogramServer.h.

References fxAnalysis.

Referenced by TGo4HisConnectorRunnable::Run().

◆ GetAnalysisClient()

TGo4AnalysisClient* TGo4HistogramServer::GetAnalysisClient ( ) const
inline

Definition at line 61 of file TGo4HistogramServer.h.

References fxAnalysisClient.

◆ GetObjPort()

UInt_t TGo4HistogramServer::GetObjPort ( )

returns the portnumber for object server connection

Definition at line 455 of file TGo4HistogramServer.cxx.

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

Referenced by ConnectObjectClient().

◆ HandleObjectRequest()

Bool_t TGo4HistogramServer::HandleObjectRequest ( )
private

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

Definition at line 260 of file TGo4HistogramServer.cxx.

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

Referenced by ConnectHost(), and ServeObjectClient().

◆ ObjectThreadName()

const char* TGo4HistogramServer::ObjectThreadName ( ) const
inlineprivate

Definition at line 102 of file TGo4HistogramServer.h.

References fxObjectThreadName.

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

◆ SendObject()

Bool_t TGo4HistogramServer::SendObject ( TObject *  obj)
private

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

Definition at line 284 of file TGo4HistogramServer.cxx.

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

Referenced by ConnectHost(), and HandleObjectRequest().

◆ ServeObjectClient()

Int_t TGo4HistogramServer::ServeObjectClient ( )

Used by object connector runnable to serve client request

Definition at line 159 of file TGo4HistogramServer.cxx.

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

Referenced by TGo4ObjConnectorRunnable::Run().

◆ SetConnect()

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

Definition at line 316 of file TGo4HistogramServer.cxx.

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

Referenced by ConnectHost(), and ConnectObjectClient().

◆ SetDisConnect()

void TGo4HistogramServer::SetDisConnect ( TGo4Socket *  trans)
private

Definition at line 325 of file TGo4HistogramServer.cxx.

References fbDisConnectRequest, fxDisConnectTransport, and GO4TRACE.

Referenced by ConnectHost(), and DisconnectObjectClient().

◆ TimerConnect()

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 332 of file TGo4HistogramServer.cxx.

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

Referenced by TGo4ObjConnectorTimer::Notify().

◆ WaitForClose()

Int_t TGo4HistogramServer::WaitForClose ( )
private

Definition at line 418 of file TGo4HistogramServer.cxx.

References fbConnectIsClose, fgiCLOSEWAITCYCLES, fguCLOSEWAITCYCLETIME, GO4TRACE, and TGo4Thread::Sleep().

Referenced by ConnectHost(), and DisconnectObjectClient().

◆ WaitForConnection()

Int_t TGo4HistogramServer::WaitForConnection ( )
private

Definition at line 436 of file TGo4HistogramServer.cxx.

References fbConnectIsDone, fguCONNECTWAITCYCLETIME, fxAnalysisClient, TGo4TaskOwner::GetTask(), GO4TRACE, TGo4ThreadManager::IsTerminating(), and TGo4Thread::Sleep().

Referenced by ConnectHost(), and ConnectObjectClient().

◆ WaitForOpen()

Int_t TGo4HistogramServer::WaitForOpen ( )
private

Definition at line 396 of file TGo4HistogramServer.cxx.

References fbConnectIsOpen, fgiOPENWAITCYCLES, fguOPENWAITCYCLETIME, fxAnalysisClient, TGo4TaskOwner::GetTask(), GO4TRACE, TGo4ThreadManager::IsTerminating(), and TGo4Thread::Sleep().

Referenced by ConnectHost(), and ConnectObjectClient().

Friends And Related Function Documentation

◆ TGo4HisConnectorRunnable

friend class TGo4HisConnectorRunnable
friend

Definition at line 37 of file TGo4HistogramServer.h.

Referenced by TGo4HistogramServer().

Member Data Documentation

◆ fbConnectIsClose

Bool_t TGo4HistogramServer::fbConnectIsClose {kFALSE}
private

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

Definition at line 186 of file TGo4HistogramServer.h.

Referenced by TimerConnect(), and WaitForClose().

◆ fbConnectIsDone

Bool_t TGo4HistogramServer::fbConnectIsDone {kFALSE}
private

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

Definition at line 182 of file TGo4HistogramServer.h.

Referenced by TimerConnect(), and WaitForConnection().

◆ fbConnectIsOpen

Bool_t TGo4HistogramServer::fbConnectIsOpen {kFALSE}
private

True if fxConnectTransport waits in server Open() call

Definition at line 178 of file TGo4HistogramServer.h.

Referenced by TimerConnect(), and WaitForOpen().

◆ fbConnectRequest

Bool_t TGo4HistogramServer::fbConnectRequest {kFALSE}
private

True if fxConnectTransport shall be Open() by Timer

Definition at line 172 of file TGo4HistogramServer.h.

Referenced by SetConnect(), and TimerConnect().

◆ fbDisConnectRequest

Bool_t TGo4HistogramServer::fbDisConnectRequest {kFALSE}
private

True if fxConnectTransport shall be Close() by Timer

Definition at line 175 of file TGo4HistogramServer.h.

Referenced by SetDisConnect(), and TimerConnect().

◆ fbUseObjectServer

Bool_t TGo4HistogramServer::fbUseObjectServer {kFALSE}
private

Switches Go4 objectserver option on/off

Definition at line 195 of file TGo4HistogramServer.h.

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

◆ fcConnectHost

TString TGo4HistogramServer::fcConnectHost
private

hostname for timer connect

Definition at line 166 of file TGo4HistogramServer.h.

Referenced by ConnectHost(), and SetConnect().

◆ fgcCOMGETLIST

const char * TGo4HistogramServer::fgcCOMGETLIST = "__OServNamesList__"
static

command string for object server nameslist request

Definition at line 75 of file TGo4HistogramServer.h.

Referenced by HandleObjectRequest(), and TGo4ObjClient::RequestNamesList().

◆ fgcCONTHREADNAME

const char * TGo4HistogramServer::fgcCONTHREADNAME = "HISTOSERV-"
static

histogram server connector thread name

Definition at line 66 of file TGo4HistogramServer.h.

Referenced by TGo4HistogramServer().

◆ fgcOBJTHREADNAME

const char * TGo4HistogramServer::fgcOBJTHREADNAME = "OBJECTSERV-"
static

object server connector thread name

Definition at line 69 of file TGo4HistogramServer.h.

Referenced by TGo4HistogramServer().

◆ fgcSHUTDOWNNAME

const char * TGo4HistogramServer::fgcSHUTDOWNNAME = "__HServLast__"
static

This string is send as histogram name for termination connection

Definition at line 72 of file TGo4HistogramServer.h.

Referenced by TGo4HisConnectorRunnable::Run(), and ~TGo4HistogramServer().

◆ fgiCLOSEWAITCYCLES

const Int_t TGo4HistogramServer::fgiCLOSEWAITCYCLES = 100
static

Maximum cycles to wait until transport is closed

Definition at line 87 of file TGo4HistogramServer.h.

Referenced by WaitForClose().

◆ fgiCONNECTWAITCYCLES

const Int_t TGo4HistogramServer::fgiCONNECTWAITCYCLES = 20
static

Maximum cycles to wait until transport is connected

Definition at line 93 of file TGo4HistogramServer.h.

◆ fgiOPENWAITCYCLES

const Int_t TGo4HistogramServer::fgiOPENWAITCYCLES = 100
static

Maximum cycles to wait until transport is open

Definition at line 81 of file TGo4HistogramServer.h.

Referenced by WaitForOpen().

◆ fguCLOSEWAITCYCLETIME

const UInt_t TGo4HistogramServer::fguCLOSEWAITCYCLETIME = 500
static

Time for each close wait cycle, in ms

Definition at line 90 of file TGo4HistogramServer.h.

Referenced by WaitForClose().

◆ fguCONNECTWAITCYCLETIME

const UInt_t TGo4HistogramServer::fguCONNECTWAITCYCLETIME = 500
static

Time for each connect wait cycle, in ms

Definition at line 96 of file TGo4HistogramServer.h.

Referenced by WaitForConnection().

◆ fguOPENWAITCYCLETIME

const UInt_t TGo4HistogramServer::fguOPENWAITCYCLETIME = 500
static

Time for each open wait cycle, in ms

Definition at line 84 of file TGo4HistogramServer.h.

Referenced by WaitForOpen().

◆ fguTIMERPERIOD

const UInt_t TGo4HistogramServer::fguTIMERPERIOD = 200
static

Period of connector timer, in ms

Definition at line 78 of file TGo4HistogramServer.h.

Referenced by TGo4HistogramServer().

◆ fiServerPort

Int_t TGo4HistogramServer::fiServerPort {0}
private

port number for server socket

Definition at line 149 of file TGo4HistogramServer.h.

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

◆ fuConnectPort

UInt_t TGo4HistogramServer::fuConnectPort {0}
private

port number for timer connect

Definition at line 169 of file TGo4HistogramServer.h.

Referenced by SetConnect(), and TimerConnect().

◆ fuObjectPort

UInt_t TGo4HistogramServer::fuObjectPort {0}
private

port number for the object server connections

Definition at line 155 of file TGo4HistogramServer.h.

Referenced by ConnectObjectClient(), and GetObjPort().

◆ fxAnalysis

TGo4Analysis* TGo4HistogramServer::fxAnalysis {nullptr}
private

Definition at line 133 of file TGo4HistogramServer.h.

Referenced by GetAnalysis(), HandleObjectRequest(), and TGo4HistogramServer().

◆ fxAnalysisClient

TGo4AnalysisClient* TGo4HistogramServer::fxAnalysisClient {nullptr}
private

Definition at line 132 of file TGo4HistogramServer.h.

Referenced by ConnectObjectClient(), GetAnalysisClient(), TGo4HistogramServer(), WaitForConnection(), and WaitForOpen().

◆ fxConnectorName

TString TGo4HistogramServer::fxConnectorName
private

Name of connector thread

Definition at line 143 of file TGo4HistogramServer.h.

Referenced by ConnectorName(), and TGo4HistogramServer().

◆ fxConnectorTimer

TGo4ObjConnectorTimer* TGo4HistogramServer::fxConnectorTimer {nullptr}
private

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

Definition at line 192 of file TGo4HistogramServer.h.

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

◆ fxConnectTransport

TGo4Socket* TGo4HistogramServer::fxConnectTransport {nullptr}
private

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

Definition at line 159 of file TGo4HistogramServer.h.

Referenced by SetConnect(), and TimerConnect().

◆ fxDisConnectTransport

TGo4Socket* TGo4HistogramServer::fxDisConnectTransport {nullptr}
private

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

Definition at line 163 of file TGo4HistogramServer.h.

Referenced by SetDisConnect(), and TimerConnect().

◆ fxObjectThreadName

TString TGo4HistogramServer::fxObjectThreadName
private

Name of object server thread

Definition at line 146 of file TGo4HistogramServer.h.

Referenced by ObjectThreadName(), and TGo4HistogramServer().

◆ fxServerName

TString TGo4HistogramServer::fxServerName
private

contains api server name

Definition at line 137 of file TGo4HistogramServer.h.

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

◆ fxServerPass

TString TGo4HistogramServer::fxServerPass
private

contains api server password

Definition at line 140 of file TGo4HistogramServer.h.

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

◆ fxThreadHandler

TGo4ThreadHandler* TGo4HistogramServer::fxThreadHandler {nullptr}
private

Definition at line 134 of file TGo4HistogramServer.h.

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

◆ fxTransport

TGo4Socket* TGo4HistogramServer::fxTransport {nullptr}
private

socket for object server

Definition at line 152 of file TGo4HistogramServer.h.

Referenced by CheckLogin(), ConnectObjectClient(), DisconnectObjectClient(), GetObjPort(), HandleObjectRequest(), SendObject(), TGo4HistogramServer(), and ~TGo4HistogramServer().

The documentation for this class was generated from the following files:
Generated on Wed Jan 10 2024 15:05:23 for GSI Object Oriented Online Offline (Go4) by   doxygen 1.8.13