 |
Belle II Software
release-05-02-19
|
11 #include <framework/pcore/zmq/utils/StreamHelper.h>
12 #include <framework/core/Environment.h>
13 #include <framework/core/RandomNumbers.h>
14 #include <framework/logging/Logger.h>
22 gSystem->Load(
"libdataobjects");
23 m_streamer = std::make_unique<DataStoreStreamer>(compressionLevel, handleMergeable);
27 B2INFO(
"Tx: Streaming objects limited : " << (
Environment::Instance().getStreamingObjects()).size() <<
" objects");
31 std::unique_ptr<EvtMessage>
StreamHelper::stream(
bool addPersistentDurability,
bool streamTransientObjects)
40 return std::unique_ptr<EvtMessage>(
m_streamer->streamDataStore(addPersistentDurability, streamTransientObjects));
static constexpr const unsigned int c_data
Where the data is stored.
std::unique_ptr< EvtMessage > stream(bool addPersistentDurability=true, bool streamTransientObjects=true)
Stream the data store into an event message.
void initialize(int compressionLevel, bool handleMergeable)
Initialize this class. Call this e.g. in the first event.
std::unique_ptr< DataStoreStreamer > m_streamer
The data store streamer to use.
Class to manage streamed object.
Abstract base class for different kinds of events.
static RandomGenerator & getEventRandomGenerator()
return reference to the event dependent random generator
void read(std::unique_ptr< ZMQNoIdMessage > message)
Read in a ZMQ message and rebuilt the data store from it.
static Environment & Instance()
Static method to get a reference to the Environment instance.
StoreObjPtr< RandomGenerator > m_randomGenerator
The random generator object in the data store that we need to transport also.