Helper class for data store serialization. More...

#include <StreamHelper.h>

Collaboration diagram for StreamHelper:

[legend]

Public Member Functions
void	initialize (int compressionLevel, bool handleMergeable)
	Initialize this class. Call this e.g. in the first event.

std::unique_ptr< EvtMessage >	stream (bool addPersistentDurability=true, bool streamTransientObjects=true)
	Stream the data store into an event message.

void	read (std::unique_ptr< ZMQNoIdMessage > message)
	Read in a ZMQ message and rebuilt the data store from it.

Private Attributes
std::unique_ptr< DataStoreStreamer >	m_streamer
	The data store streamer to use.

StoreObjPtr< RandomGenerator >	m_randomGenerator
	The random generator object in the data store that we need to transport also.

Detailed Description

Helper class for data store serialization.

Definition at line 23 of file StreamHelper.h.

Member Function Documentation

◆ initialize()

void initialize	(	int	compressionLevel,
		bool	handleMergeable
	)

Initialize this class. Call this e.g. in the first event.

Definition at line 18 of file StreamHelper.cc.

{
  gSystem->Load("libdataobjects");
  m_streamer = std::make_unique<DataStoreStreamer>(compressionLevel, handleMergeable);
 
  if ((Environment::Instance().getStreamingObjects()).size() > 0) {
    m_streamer->setStreamingObjects(Environment::Instance().getStreamingObjects());
    B2INFO("Tx: Streaming objects limited : " << (Environment::Instance().getStreamingObjects()).size() << " objects");
  }
}

◆ read()

void read ( std::unique_ptr< ZMQNoIdMessage > message )

Read in a ZMQ message and rebuilt the data store from it.

Definition at line 41 of file StreamHelper.cc.

{
  EvtMessage eventMessage(message->getMessagePartAsCharArray<ZMQNoIdMessage::c_data>());
  m_streamer->restoreDataStore(&eventMessage);
 
  if (m_randomGenerator.isValid()) {
    RandomNumbers::getEventRandomGenerator() = *m_randomGenerator;
  }
}

◆ stream()

std::unique_ptr< EvtMessage > stream	(	bool	addPersistentDurability = `true`,
		bool	streamTransientObjects = `true`
	)

Stream the data store into an event message.

Definition at line 29 of file StreamHelper.cc.

{
  if (m_randomGenerator.isOptional()) {
    if (not m_randomGenerator.isValid()) {
      m_randomGenerator.construct(RandomNumbers::getEventRandomGenerator());
    } else {
      *m_randomGenerator = RandomNumbers::getEventRandomGenerator();
    }
  }
  return std::unique_ptr<EvtMessage>(m_streamer->streamDataStore(addPersistentDurability, streamTransientObjects));
}

Member Data Documentation

◆ m_randomGenerator

StoreObjPtr<RandomGenerator> m_randomGenerator

private

The random generator object in the data store that we need to transport also.

Definition at line 36 of file StreamHelper.h.

◆ m_streamer

std::unique_ptr<DataStoreStreamer> m_streamer

private

The data store streamer to use.

Definition at line 34 of file StreamHelper.h.

The documentation for this class was generated from the following files:

framework/pcore/zmq/utils/include/StreamHelper.h
framework/pcore/zmq/utils/src/StreamHelper.cc

Public Member Functions

Private Attributes