ZMQHistogramToRawServer Class Reference

Non-Final histogram app: receive histogram messages from all clients and react with a confirmation message. More...

#include <ZMQHistogramServer.h>

Inheritance diagram for ZMQHistogramToRawServer:

Collaboration diagram for ZMQHistogramToRawServer:

Public Member Functions
void	initialize () final
	Initialize the two connections using the command line arguments.
void	addOptions (po::options_description &desc) final
	Add the parameters to the cmd line arguments.
void	handleExternalSignal (EMessageTypes type) final
	Merge on stop (even if not all clients have stopped) or clear the counters on start from the monitoring connection.
void	handleInput () final
	Pass the message from the input connection to the histogram storage.
void	handleTimeout () final
	Call the mergeAndSend function on timeout.
void	initFromConsole (const std::string &description, int argc, char *argv[])
	Should be called before the main() function to initialize the connections using the paremeters given on command line. More...
void	main ()
	Start the main loop polling on the output and monitoring connections and eventually also on the input if the output is ready. More...

Protected Member Functions
virtual void	handleOutput ()
	Will get called for every message on the output connection. Can be overridden in a derived class. Calls handleIncomingData by default.
virtual void	fillMonitoringJSON (std::stringstream &buffer) const
	Using the connections, fill up a buffer with the content to be monitored.
bool	terminated () const
	Check if the main loop will be exited on next occasion. Can be set via the "m_terminate" flag.
void	resetTimer ()
	Helper function to reset the start time and the remaining time.
void	pollEvent (bool pollOnInput)
	Poll until a single event is retreived.

Protected Attributes
std::shared_ptr< ZMQParent >	m_parent
	Pointer to the ZMQParent to be used as base for all connections.
std::unique_ptr< ZMQConfirmedInput >	m_input
	Pointer to the input connection. Should be set in initialize.
std::unique_ptr< ZMQHistoServerToRaw >	m_output
	Pointer to the output connection. Should be set in initialize.
std::unique_ptr< ZMQSimpleConnection >	m_monitor
	Pointer to the monitoring connection. Should be set in initialize.
bool	m_terminate
	Can be set by functions to terminate the main loop at the next possibility.
unsigned int	m_timeout
	If set to a value != 0, will call handleTimeout with this frequency (in seconds).
bool	m_monitorHasPriority
	Flag to break out of the polling loop to check for monitoring messages. Except for the finalcollector you probably do not want this.

Private Member Functions
bool	checkTimer ()
	Helper function to check, if the timeout should happen.
void	updateTimer ()
	Helper function to update the remaining time.
void	handleMonitoring ()
	Handle an incoming message on the monitoring socket by either calling handleExternalSignal() or by passing on the monitor JSONs of the connections.

Private Attributes
std::string	m_inputAddress
	Parameter: input address.
std::string	m_outputAddress
	Parameter: output address.
unsigned int	m_maximalUncompressedBufferSize = 128'000'000
	Parameter: size of the temporary internal compression buffer.
HLTMainLoop	m_mainLoop
	Internal signal handler.
std::string	m_monitoringAddress
	Storage for the monitoring address for the cmd arguments.
int	m_remainingTime
	Counter for the remaining time until a timeout happens.
std::chrono::system_clock::time_point	m_start
	Start time for the timeout.

Detailed Description

Non-Final histogram app: receive histogram messages from all clients and react with a confirmation message.

Periodically or on stop/terminate, merge them and send them out to an old implementation of the histogram server. Good for testing in combination with the legacy system. Apart from the connection-typical behavior, it reacts on termination messages by terminating. Behaves as a collector: When receiving a stop on monitoring, it merges the histograms (even if not all clients have sent a stop already). When receiving a start on monitoring, it clears the input and output stop counters and the stored histograms.

Definition at line 95 of file ZMQHistogramServer.h.

Member Function Documentation

initFromConsole()

void initFromConsole ( const std::string &  description, int  argc, char *  argv[]  )

inherited

Should be called before the main() function to initialize the connections using the paremeters given on command line.

Custom implementations should implement the addOptions function to pass the command line arguments correctly. Calls the initialize function (which should also be overridden).

Definition at line 54 of file ZMQApp.details.h.

main()

void main

inherited

Start the main loop polling on the output and monitoring connections and eventually also on the input if the output is ready.

Calls the functions handleExternalSignal, handleInput, handleOutput and handleTimeout as described in the documentation of this class.

Definition at line 61 of file ZMQApp.details.h.

---

The documentation for this class was generated from the following files:

• daq/hbasf2/apps/include/ZMQHistogramServer.h
• daq/hbasf2/apps/src/ZMQHistogramServer.cc