 |
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>
47 class HLTDs2ZMQModule :
public Module {
53 void event()
override;
68 std::unique_ptr<ZMQConfirmedOutput>
m_output;
Helper class for data store serialization.
HLTDs2ZMQModule()
Register the module parameters.
void endRun() override
Send out a run stop message.
std::unique_ptr< ZMQConfirmedOutput > m_output
Confirmed connection to the ZMQ application.
void terminate() override
Send out a terminate message.
void event() override
On the first event, initialize the streamer and the connection. Serializes and sends out the data sto...
bool m_param_raw
Module paremeter: send out raw data with send header and trailer around the evtmessage instead of jus...
Abstract base class for different kinds of events.
std::shared_ptr< ZMQParent > m_parent
ZMQ Parent needed for the connections.
HLTStreamHelper m_streamHelper
Utility class used for serialization.
bool m_firstEvent
Are we still in the first event? Please note the special handling of the first event in the HLTEventP...
std::string m_param_output
Module parameter: the ZMQ address of the connected application (to receive the messages)