 |
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/ZMQLoadBalancedConnection.h>
17 #include <framework/pcore/zmq/utils/ZMQParent.h>
32 class HLTZMQ2DsDirectModule :
public Module {
46 std::unique_ptr<ZMQLoadBalancedInput>
m_input;
Helper class for data store serialization.
std::string m_param_input
Module parameter: ZMQ address of the input ZMQ application.
void initialize() override
Receive the first event and initialize the data store with it.
HLTZMQ2DsDirectModule()
Register the module parameters.
std::shared_ptr< ZMQParent > m_parent
ZMQ Parent needed for the connections.
Abstract base class for different kinds of events.
bool m_firstEvent
Are we still in the first real event?
unsigned int m_param_bufferSize
Module parameter: how many events should be kept in flight. Has an impact on the stopping time as wel...
void event() override
If not in the first event, receive an event and store in the DS.
std::unique_ptr< ZMQLoadBalancedInput > m_input
Load balanced connection to the previous ZMQ application.
HLTStreamHelper m_streamHelper
Utility class for deserialization.