Helper class for data store serialization. More...

Collaboration diagram for HLTStreamHelper:

[legend]

Public Member Functions
void	initialize ()
	Initialize this class. Call this e.g. in the first event.

std::unique_ptr< ZMQNoIdMessage >	stream (bool addPersistentDurability, bool streamTransientObjects)
	Stream the data store into an event message. Add ROI as additional message (if valid).

std::unique_ptr< ZMQNoIdMessage >	streamRaw ()
	Stream the data store into an event message and add SendHeader and SendTrailer around the message. Add ROI as additional message (if valid).

std::unique_ptr< ZMQNoIdMessage >	streamHistograms (bool compressed=true)
	Stream all objects derived from TH1 into a message. Only the last subfolder is streamed by prefixing the histogram names with "<subfolder>/".

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

void	registerStoreObjects (bool addExpressRecoObjects)
	Register all needed store objects, either only the raw data, ROIs and event meta data (for HLT) or additional objects (for express reco).

Private Member Functions
zmq::message_t	getROIMessageIfViable () const
	If the ROI payload data storobject is filled, write out the roi message (otherwise an empty message)

Private Attributes
StreamHelper	m_streamHelper
	We use the framework stream helper.

StoreObjPtr< EventMetaData >	m_eventMetaData
	Store Objects for HLT use.

StoreArray< RawSVD >	m_rawSVDs
	Store Objects for HLT use.

StoreArray< RawCDC >	m_rawCDCs
	Store Objects for HLT use.

StoreArray< RawTOP >	m_rawTOPs
	Store Objects for HLT use.

StoreArray< RawARICH >	m_rawARICHs
	Store Objects for HLT use.

StoreArray< RawECL >	m_rawECLs
	Store Objects for HLT use.

StoreArray< RawKLM >	m_rawKLMs
	Store Objects for HLT use.

StoreArray< RawTRG >	m_rawTRGs
	Store Objects for HLT use.

StoreArray< RawFTSW >	m_rawFTSWs
	Store Objects for HLT use.

StoreObjPtr< ROIpayload >	m_roiPayload
	Store Objects for HLT use.

StoreObjPtr< RandomGenerator >	m_randomGenerator
	Additional Store Objects for ExpressReco use.

StoreObjPtr< SoftwareTriggerResult >	m_softwareTriggerResult
	Additional Store Objects for ExpressReco use.

StoreObjPtr< SoftwareTrigger::SoftwareTriggerVariables >	m_softwareTriggerVariables
	Additional Store Objects for ExpressReco use.

StoreObjPtr< TRGSummary >	m_triggerSummary
	Additional Store Objects for ExpressReco use.

StoreArray< RawPXD >	m_rawPXDs
	Additional Store Objects for ExpressReco use.

StoreArray< ROIid >	m_rois
	Additional Store Objects for ExpressReco use.

std::vector< char >	m_outputBuffer
	Temporary buffer for storing the compressed result.

unsigned int	m_maximalCompressedSize = 100'000'000
	Maximal size of the compression buffer.

Detailed Description

Helper class for data store serialization.

Definition at line 42 of file HLTStreamHelper.h.

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

Public Member Functions