 |
Belle II Software
release-05-01-25
|
12 #include <daq/hbasf2/apps/ZMQApp.h>
13 #include <framework/pcore/zmq/connections/ZMQLoadBalancedConnection.h>
14 #include <framework/pcore/zmq/connections/ZMQRawConnection.h>
15 #include <framework/pcore/zmq/connections/ZMQConfirmedConnection.h>
17 #include <boost/program_options.hpp>
19 namespace po = boost::program_options;
35 class ZMQDistributor :
public ZMQStandardApp<ZMQRawInput, ZMQLoadBalancedOutput> {
40 void addOptions(po::options_description& desc) final;
unsigned int m_maximalBufferSize
Parameter: buffer size for storing input messages.
Output part of a confirmed connection.
EMessageTypes
Type the messages can have.
void handleTimeout() final
When a timeout is set (= we are waiting for all messages after a stop), send a stop message once we h...
Generic base class for all standalone ZMQ applications.
unsigned int m_stopWaitingTime
Parameter: how long to wait after no events come anymore.
void initialize() final
Initialize the two connections using the command line arguments.
Abstract base class for different kinds of events.
void handleExternalSignal(EMessageTypes type) final
Handle stop, start and terminate messages as described above.
bool m_expressRecoMode
Parameter: Do not wait for a ready worker if set to true, but dismiss the incoming event.
void handleInput() final
Pass the message from the input connection to the output connection (only data messages)
std::string m_outputAddress
Parameter: output address.
std::string m_inputAddress
Parameter: input address.
void addOptions(po::options_description &desc) final
Add the parameters to the cmd line arguments.