#include <OnlMon/blob/main/onlmonserver/OnlMonServer.h>

Inheritance diagram for OnlMonServer:

Collaboration diagram for OnlMonServer:

Public Member Functions
	~OnlMonServer () override

	OnlMonServer (const OnlMonServer &)=delete

OnlMonServer &	operator= (const OnlMonServer &)=delete

void	registerHisto (const std::string &monitorname, const std::string &hname, TH1 *h1d, const int replace=0)

void	registerHisto (const OnlMon monitor, TH1 h1d)

void	registerCommonHisto (TH1 *h1d)

TH1 *	getHisto (const std::string &subsys, const std::string &hname) const

TH1 *	getCommonHisto (const std::string &hname) const

TH1 *	getHisto (const unsigned int ihisto) const

const std::string	getHistoName (const unsigned int ihisto) const

unsigned int	nHistos () const

int	RunNumber () const

void	RunNumber (const int irun)

int	EventNumber () const

void	EventNumber (const int iev)

int	PortNumber () const

void	PortNumber (const int i)

void	Print (const std::string &what="ALL", std::ostream &os=std::cout) const

void	PrintFile (const std::string &fname) const

void	InitAll ()

void	registerMonitor (OnlMon *Monitor)

OnlMon *	getMonitor (const std::string &name)

void	dumpHistos (const std::string &filename)

int	process_event (Event *)

int	Reset ()

int	BeginRun (const int runno)

int	EndRun (const int runno)

int	WriteHistoFile ()

uint64_t	CurrentTicks () const

void	CurrentTicks (const uint64_t ival)

uint64_t	BorTicks () const

void	BorTicks (const uint64_t ival)

int	BadEvents () const

void	AddBadEvent ()

void	BadEvents (const int ibad)

int	WriteLogFile (const std::string &name, const std::string &msg) const

int	IsPacketActive (const unsigned int ipkt)

int	SetSubsystemStatus (OnlMon *Monitor, const int status)

int	SetSubsystemRunStatus (OnlMon *Monitor, const int status)

int	LookAtMe (OnlMon *Monitor, const int level, const std::string &message)

std::string	GetRunType () const

int	send_message (const OnlMon *Monitor, const int msgsource, const int severity, const std::string &err_message, const int msgtype) const

void	SetThreadId (const pthread_t &id)

void	clearactivepackets ()

int	isStandaloneRun () const

int	isCosmicRun () const

int	run_empty (const int nevents)

std::map< std::string, std::map< std::string, TH1 * > >::const_iterator	monibegin ()

std::map< std::string, std::map< std::string, TH1 * > >::const_iterator	moniend ()

std::vector< OnlMon * > ::const_iterator	monitor_vec_begin ()

std::vector< OnlMon * > ::const_iterator	monitor_vec_end ()

Public Member Functions inherited from OnlMonBase
	OnlMonBase (const std::string &name="NONE")

virtual	~OnlMonBase ()

const std::string	Name () const

void	Name (const std::string &name)

virtual void	Verbosity (const int i)

virtual int	Verbosity () const

Static Public Member Functions
static OnlMonServer *	instance ()

Private Member Functions
	OnlMonServer (const std::string &name="OnlMonServer")

int	send_message (const int severity, const std::string &err_message, const int msgtype) const

int	CacheRunDB (const int runno)

void	registerHisto (const std::string &hname, TH1 *h1d, const int replace=0)

Private Attributes
int	runnumber = -1

int	eventnumber = 0

int	portnumber = OnlMonDefs::MONIPORT

int	badevents = 0

uint64_t	currentticks = 0

uint64_t	borticks = 0

int	activepacketsinit = 0

unsigned int	scaledtrigmask = 0xFFFFFFFF

int	scaledtrigmask_used = 0

int	standalone = 0

int	cosmicrun = 0

std::string	TriggerConfig = "UNKNOWN"

std::string	RunType = "UNKNOWN"

TH1 *	serverrunning = nullptr

OnlMonStatusDB *	statusDB = nullptr

OnlMonStatusDB *	RunStatusDB = nullptr

std::map< const std::string, TH1 * >	CommonHistoMap

std::vector< OnlMon * >	MonitorList

std::set< unsigned int >	activepackets

std::map< std::string, MessageSystem * >	MsgSystem

std::map< std::string, std::map< std::string, TH1 * > >	MonitorHistoSet

pthread_mutex_t	mutex

pthread_t	serverthreadid = 0

Static Private Attributes
static OnlMonServer *	__instance = nullptr

Additional Inherited Members
Protected Attributes inherited from OnlMonBase
std::string	ThisName

int	verbosity = 0

Detailed Description

Definition at line 23 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 23 of file OnlMonServer.h

Constructor & Destructor Documentation

OnlMonServer::~OnlMonServer ( )

override

Definition at line 64 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 64 of file OnlMonServer.cc

References CommonHistoMap, MonitorHistoSet, MonitorList, MsgSystem, mutex, RunStatusDB, serverrunning, serverthreadid, statusDB, and OnlMonBase::Verbosity().

Here is the call graph for this function:

OnlMonServer::OnlMonServer ( const OnlMonServer & )

explicitdelete

Referenced by instance().

Here is the caller graph for this function:

OnlMonServer::OnlMonServer ( const std::string & name = "OnlMonServer" )

private

Definition at line 51 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 51 of file OnlMonServer.cc

References InitAll(), MsgSystem, mutex, RunStatusDB, statusDB, and OnlMonBase::ThisName.

Here is the call graph for this function:

Member Function Documentation

void OnlMonServer::AddBadEvent ( )

inline

Definition at line 68 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 68 of file OnlMonServer.h

References badevents.

Referenced by process_event().

Here is the caller graph for this function:

int OnlMonServer::BadEvents ( ) const

inline

Definition at line 67 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 67 of file OnlMonServer.h

References badevents.

Referenced by process_event().

Here is the caller graph for this function:

void OnlMonServer::BadEvents ( const int ibad )

inline

Definition at line 69 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 69 of file OnlMonServer.h

References badevents.

int OnlMonServer::BeginRun ( const int runno )

Definition at line 443 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 443 of file OnlMonServer.cc

References activepacketsinit, CacheRunDB(), i, MonitorList, and printf().

Referenced by process_event().

Here is the call graph for this function:

Here is the caller graph for this function:

uint64_t OnlMonServer::BorTicks ( ) const

inline

Definition at line 64 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 64 of file OnlMonServer.h

References borticks.

Referenced by process_event().

Here is the caller graph for this function:

void OnlMonServer::BorTicks ( const uint64_t ival )

inline

Definition at line 65 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 65 of file OnlMonServer.h

References borticks.

int OnlMonServer::CacheRunDB ( const int runno )

private

Definition at line 642 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 642 of file OnlMonServer.cc

References borticks, runCondor_beamspot::cmd, con, cosmicrun, odbc::Connection::createStatement(), Acts::UnitConstants::e, odbc::Statement::executeQuery(), odbc::DriverManager::getConnection(), odbc::ResultSet::getInt(), odbc::SQLException::getMessage(), odbc::ResultSet::getString(), odbc::ResultSet::next(), printf(), RunType, standalone, TriggerConfig, and OnlMonBase::verbosity.

Referenced by BeginRun().

Here is the call graph for this function:

Here is the caller graph for this function:

void OnlMonServer::clearactivepackets ( )

inline

Definition at line 91 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 91 of file OnlMonServer.h

References activepackets.

uint64_t OnlMonServer::CurrentTicks ( ) const

inline

Definition at line 62 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 62 of file OnlMonServer.h

References currentticks.

Referenced by OnlMonDB::DBcommit(), MyMon::process_event(), process_event(), and WriteLogFile().

Here is the caller graph for this function:

void OnlMonServer::CurrentTicks ( const uint64_t ival )

inline

Definition at line 63 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 63 of file OnlMonServer.h

References currentticks.

void OnlMonServer::dumpHistos ( const std::string & filename )

Definition at line 130 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 130 of file OnlMonServer.cc

References MonitorHistoSet.

int OnlMonServer::EndRun ( const int runno )

Definition at line 463 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 463 of file OnlMonServer.cc

References i, and MonitorList.

Referenced by process_event(), and start_server().

Here is the caller graph for this function:

int OnlMonServer::EventNumber ( ) const

inline

Definition at line 44 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 44 of file OnlMonServer.h

References eventnumber.

Referenced by process_event().

Here is the caller graph for this function:

void OnlMonServer::EventNumber ( const int iev )

inline

Definition at line 45 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 45 of file OnlMonServer.h

References eventnumber.

TH1 * OnlMonServer::getCommonHisto ( const std::string & hname ) const

Definition at line 366 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 366 of file OnlMonServer.cc

References CommonHistoMap, TauVsDIS_MachineLearning_Differentiation::msg, MSG_SEV_ERROR, Print(), and send_message().

Referenced by OnlMon::InitCommon().

Here is the call graph for this function:

Here is the caller graph for this function:

TH1 * OnlMonServer::getHisto	(	const std::string &	subsys,
		const std::string &	hname
	)		const

Definition at line 342 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 342 of file OnlMonServer.cc

References MonitorHistoSet, TauVsDIS_MachineLearning_Differentiation::msg, MSG_SEV_ERROR, Print(), send_message(), and OnlMonBase::Verbosity().

Referenced by handleconnection().

Here is the call graph for this function:

Here is the caller graph for this function:

TH1 * OnlMonServer::getHisto ( const unsigned int ihisto ) const

Definition at line 284 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 284 of file OnlMonServer.cc

References CommonHistoMap, i, TauVsDIS_MachineLearning_Differentiation::msg, MSG_SEV_ERROR, MSG_SEV_INFORMATIONAL, send_message(), size, and OnlMonBase::Verbosity().

Here is the call graph for this function:

const std::string OnlMonServer::getHistoName ( const unsigned int ihisto ) const

Definition at line 314 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 314 of file OnlMonServer.cc

References CommonHistoMap, i, TauVsDIS_MachineLearning_Differentiation::msg, MSG_SEV_ERROR, MSG_SEV_INFORMATIONAL, send_message(), size, and OnlMonBase::verbosity.

Here is the call graph for this function:

OnlMon * OnlMonServer::getMonitor ( const std::string & name )

Definition at line 249 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 249 of file OnlMonServer.cc

References MonitorList.

std::string OnlMonServer::GetRunType ( ) const

inline

Definition at line 79 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 79 of file OnlMonServer.h

References RunType.

Referenced by SetSubsystemRunStatus(), and SetSubsystemStatus().

Here is the caller graph for this function:

void OnlMonServer::InitAll ( )

Definition at line 117 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 117 of file OnlMonServer.cc

References TauVsDIS_MachineLearning_Differentiation::msg, MSG_SEV_FATAL, send_message(), and serverrunning.

Referenced by OnlMonServer().

Here is the call graph for this function:

Here is the caller graph for this function:

OnlMonServer * OnlMonServer::instance ( )

static

Definition at line 41 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 41 of file OnlMonServer.cc

References __instance, and OnlMonServer().

Referenced by CleanUpServer(), OnlMonDB::DBcommit(), handleconnection(), LL1Mon::Init(), DaqMon::Init(), MyMon::Init(), PktSizeMon::Init(), BbcMon::Init(), SepdMon::Init(), HcalMon::Init(), ZdcMon::Init(), CemcMon::Init(), TpcMon::Init(), TpotMon::Init(), InttMon::Init(), MvtxMon::Init(), pinit(), MyMon::process_event(), PktSizeMon::process_event(), BbcMon::process_event(), MvtxMon::process_event(), process_event(), PktSizeMon::putmapinhisto(), PktSizeMon::Reset(), run_bbc_server(), run_cemc_server(), run_cemc_server_SEB00(), run_cemc_server_SEB01(), run_daq_server(), run_example_server0(), run_example_server1(), run_hcal_server(), run_intt_server(), run_ll1_server(), run_mvtx_server(), run_pktsize_server(), run_sepd_server(), run_tpc_server(), run_tpot_server(), run_zdc_server(), MessageSystem::send_message(), server(), OnlMon::SetStatus(), start_server(), and PktSizeMon::UpdateDB().

Here is the call graph for this function:

Here is the caller graph for this function:

int OnlMonServer::isCosmicRun ( ) const

inline

Definition at line 94 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 94 of file OnlMonServer.h

References cosmicrun.

int OnlMonServer::IsPacketActive ( const unsigned int ipkt )

int OnlMonServer::isStandaloneRun ( ) const

inline

Definition at line 93 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 93 of file OnlMonServer.h

References standalone.

int OnlMonServer::LookAtMe	(	OnlMon *	Monitor,
		const int	level,
		const std::string &	message
	)

Definition at line 763 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 763 of file OnlMonServer.cc

References OnlMonBase::Name().

Here is the call graph for this function:

std::map<std::string, std::map<std::string, TH1 *> >::const_iterator OnlMonServer::monibegin ( )

inline

Definition at line 97 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 97 of file OnlMonServer.h

References MonitorHistoSet.

Referenced by handleconnection().

Here is the caller graph for this function:

std::map<std::string, std::map<std::string, TH1 *> >::const_iterator OnlMonServer::moniend ( )

inline

Definition at line 98 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 98 of file OnlMonServer.h

References MonitorHistoSet.

Referenced by handleconnection().

Here is the caller graph for this function:

std::vector<OnlMon *>::const_iterator OnlMonServer::monitor_vec_begin ( )

inline

Definition at line 99 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 99 of file OnlMonServer.h

References MonitorList.

Referenced by handleconnection().

Here is the caller graph for this function:

std::vector<OnlMon *>::const_iterator OnlMonServer::monitor_vec_end ( )

inline

Definition at line 100 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 100 of file OnlMonServer.h

References MonitorList.

Referenced by handleconnection().

Here is the caller graph for this function:

unsigned int OnlMonServer::nHistos ( ) const

inline

Definition at line 41 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 41 of file OnlMonServer.h

References CommonHistoMap.

Referenced by handleconnection().

Here is the caller graph for this function:

OnlMonServer& OnlMonServer::operator= ( const OnlMonServer & )

delete

int OnlMonServer::PortNumber ( ) const

inline

Definition at line 46 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 46 of file OnlMonServer.h

References portnumber.

Referenced by Print(), and server().

Here is the caller graph for this function:

void OnlMonServer::PortNumber ( const int i )

inline

Definition at line 47 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 47 of file OnlMonServer.h

References i, and portnumber.

void OnlMonServer::Print	(	const std::string &	what = `"ALL"`,
		std::ostream &	os = `std::cout`
	)		const

Definition at line 474 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 474 of file OnlMonServer.cc

References activepackets, CommonHistoMap, MonitorHistoSet, MonitorList, and PortNumber().

Referenced by getCommonHisto(), getHisto(), and PrintFile().

Here is the call graph for this function:

Here is the caller graph for this function:

void OnlMonServer::PrintFile ( const std::string & fname ) const

Definition at line 532 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 532 of file OnlMonServer.cc

References fout, and Print().

Here is the call graph for this function:

int OnlMonServer::process_event ( Event * evt )

Definition at line 396 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 396 of file OnlMonServer.cc

References i, and MonitorList.

Referenced by process_event(), and run_empty().

Here is the caller graph for this function:

void OnlMonServer::registerCommonHisto ( TH1 * h1d )

Definition at line 147 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 147 of file OnlMonServer.cc

References CommonHistoMap, and h1d.

Referenced by pinit().

Here is the caller graph for this function:

void OnlMonServer::registerHisto	(	const std::string &	monitorname,
		const std::string &	hname,
		TH1 *	h1d,
		const int	replace = `0`
	)

Definition at line 159 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 159 of file OnlMonServer.cc

References h1d, and MonitorHistoSet.

Referenced by DaqMon::Init(), LL1Mon::Init(), MyMon::Init(), PktSizeMon::Init(), BbcMon::Init(), SepdMon::Init(), ZdcMon::Init(), CemcMon::Init(), HcalMon::Init(), TpcMon::Init(), InttMon::Init(), MvtxMon::Init(), OnlMon::InitCommon(), PktSizeMon::putmapinhisto(), registerHisto(), and PktSizeMon::Reset().

Here is the caller graph for this function:

void OnlMonServer::registerHisto	(	const OnlMon *	monitor,
		TH1 *	h1d
	)

Definition at line 153 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 153 of file OnlMonServer.cc

References h1d, OnlMonBase::Name(), and registerHisto().

Here is the call graph for this function:

void OnlMonServer::registerHisto	(	const std::string &	hname,
		TH1 *	h1d,
		const int	replace = `0`
	)

private

Definition at line 196 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 196 of file OnlMonServer.cc

References CommonHistoMap, h1d, TauVsDIS_MachineLearning_Differentiation::msg, MSG_SEV_INFORMATIONAL, MSG_SEV_WARNING, send_message(), and OnlMonBase::verbosity.

Here is the call graph for this function:

void OnlMonServer::registerMonitor ( OnlMon * Monitor )

Definition at line 262 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 262 of file OnlMonServer.cc

References OnlMon::Init(), OnlMon::InitCommon(), MonitorList, TauVsDIS_MachineLearning_Differentiation::msg, MSG_SEV_SEVEREERROR, MsgSystem, OnlMonBase::Name(), and send_message().

Referenced by run_bbc_server(), run_cemc_server(), run_cemc_server_SEB00(), run_cemc_server_SEB01(), run_daq_server(), run_example_server0(), run_example_server1(), run_hcal_server(), run_intt_server(), run_ll1_server(), run_mvtx_server(), run_pktsize_server(), run_sepd_server(), run_tpc_server(), and run_zdc_server().

Here is the call graph for this function:

Here is the caller graph for this function:

int OnlMonServer::Reset ( )

Definition at line 413 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 413 of file OnlMonServer.cc

References CommonHistoMap, eventnumber, i, MonitorHistoSet, MonitorList, and MsgSystem.

Referenced by process_event().

Here is the caller graph for this function:

int OnlMonServer::run_empty ( const int nevents )

Definition at line 382 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 382 of file OnlMonServer.cc

References i, nevents(), and process_event().

Here is the call graph for this function:

int OnlMonServer::RunNumber ( ) const

inline

Definition at line 42 of file OnlMonServer.h.

View newest version in sPHENIX GitHub at line 42 of file OnlMonServer.h

References runnumber.

Referenced by OnlMonDB::DBcommit(), process_event(), send_message(), start_server(), WriteHistoFile(), and WriteLogFile().

Here is the caller graph for this function:

void OnlMonServer::RunNumber ( const int irun )

Definition at line 539 of file OnlMonServer.cc.

View newest version in sPHENIX GitHub at line 539 of file OnlMonServer.cc

References runnumber.

int OnlMonServer::send_message	(	const OnlMon *	Monitor,
		const int	msgsource,
		const int	severity,
		const std::string &	err_message,
		const int	msgtype
	)		const