 |
Belle II Software
release-05-01-25
|
12 #include <framework/core/Module.h>
14 #include <daq/hbasf2/utils/HLTStreamHelper.h>
15 #include <framework/pcore/zmq/connections/ZMQConfirmedConnection.h>
17 #include <framework/pcore/zmq/utils/ZMQParent.h>
18 #include <framework/datastore/StoreObjPtr.h>
19 #include <framework/dataobjects/EventMetaData.h>
43 class HLTDQM2ZMQModule :
public Module {
56 void event()
override;
76 std::unique_ptr<ZMQConfirmedOutput>
m_output;
87 std::chrono::system_clock::time_point
m_start;
void sendOutHistograms()
Helper function to serialize and send out the histograms.
Helper class for data store serialization.
std::unique_ptr< ZMQConfirmedOutput > m_output
Confirmed connection to the histogram server.
std::shared_ptr< ZMQParent > m_parent
ZMQ Parent needed for the connections.
void beginRun() override
Call the defineHisto function of all histogram modules registered at the RbTupleManager singleton.
void terminate() override
Stream the histograms one last time and send out a terminate message. We rely on all histogram module...
std::string m_param_output
Module parameter: histogram server address.
Abstract base class for different kinds of events.
Type-safe access to single objects in the data store.
HLTStreamHelper m_streamHelper
Streamer utility. TODO: in principle we do not need this, could be static!
void endRun() override
Stream the histograms one last time and send out a run end message. We rely on all histogram modules ...
HLTDQM2ZMQModule()
Register the module parameters.
unsigned int m_param_sendOutInterval
Module parameter: send out interval in seconds.
void event() override
On the first event, initialize the connection and the streamer.
bool m_firstEvent
Are we still in the first event?
std::chrono::system_clock::time_point m_start
Point in time when the current interval counting started.
StoreObjPtr< EventMetaData > m_eventMetaData
Reference to the event meta data in the data store for sending out the run and experiment number.
bool m_histogramsDefined
Are the histograms already defined (e.g. defineHisto is called)? TODO: should we reset this after the...