Helper class for data store serialization. More...

#include <StorageStreamHelper.h>

Collaboration diagram for StorageStreamHelper:

[legend]

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

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 Attributes
StreamHelper	m_streamHelper
	We use the framework stream helper.

DataStoreStreamer *	m_streamer

BinData	m_data
	Decoding input.

BinData	m_data_hlt

BinData	m_data_pxd

int *	m_buf

int	m_eb2 = 1

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.

StoreArray< OnlineEventT0 >	m_onlineEventT0
	StoreArray of OnlineEventT0.

StoreObjPtr< EventT0 >	m_eventT0
	StoreArray of EventT0.

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 48 of file StorageStreamHelper.h.

Member Function Documentation

◆ initialize()

void initialize ( )

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

Definition at line 30 of file StorageStreamHelper.cc.

{
  //m_streamHelper.initialize(0, true);
 
  m_buf = new int [10000000];
  m_data.setBuffer(m_buf);
  m_data_hlt.setBuffer(NULL);
  m_data_pxd.setBuffer(NULL);
}

◆ read()

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

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

Definition at line 69 of file StorageStreamHelper.cc.

{
  if (message->isMessage(EMessageTypes::c_eventMessage)) {
    B2DEBUG(10, "EMessageTypes::c_eventMessage: begin");
    m_streamHelper.read(std::move(message));
    B2DEBUG(10, "EMessageTypes::c_eventMessage: end");
  } else if (message->isMessage(EMessageTypes::c_rawDataMessage)) {
    B2DEBUG(10, "EMessageTypes::c_rawDataMessage");
    int* eventBuffer = message->getMessagePart<1>().data<int>();
 
    m_data.setBuffer(eventBuffer);
 
    int nboard = m_data.getNBoard();
    /*
    if (m_eb2 == 0 && nboard == 1) {
      m_data_hlt.setBuffer(m_data.getBuffer());
    } else if (m_eb2 > 0 || nboard > 1) {
      m_data_hlt.setBuffer(m_data.getBody());
    }
    */
 
    m_data_hlt.setBuffer(m_data.getBody());
 
    EvtMessage* msg = new EvtMessage((char*)m_data_hlt.getBody());
    if (msg->type() == MSG_TERMINATE) {
      B2INFO("Got Termination message");
      delete msg;
      return;
    }
    m_streamer->restoreDataStore(msg);
    delete msg;
 
    if (nboard > 1) {
      unsigned int offset = m_data_hlt.getWordSize() + m_data.getHeaderWordSize();
      for (int i = 0; i < nboard - 1; i++) {
        m_data_pxd.setBuffer(m_data.getBuffer() + offset);
        offset += m_data_pxd.getWordSize();
        if (m_data_pxd.getBody()[0] != ONSENBinData::MAGIC) {
          B2FATAL("Bad ONSEN magic for PXD = " << m_data_pxd.getTrailerMagic());
          return;
        } else if (m_data_pxd.getTrailerMagic() != BinData::TRAILER_MAGIC) {
          B2FATAL("Bad tarailer magic for PXD = " << m_data_pxd.getTrailerMagic());
          return;
        }
        if (m_data_pxd.getBuffer() != NULL) {
          m_rawPXDs.appendNew((int*)m_data_pxd.getBody(), m_data_pxd.getBodyByteSize());
        }
      }
    } else {
      m_data_pxd.setBuffer(NULL);
    }
 
    // m_eventMetaData.create();
    m_eventMetaData->setExperiment(m_data_hlt.getExpNumber());
    m_eventMetaData->setRun(m_data_hlt.getRunNumber());
    m_eventMetaData->setSubrun(m_data_hlt.getSubNumber());
    m_eventMetaData->setEvent(m_data_hlt.getEventNumber());
  }
}

◆ registerStoreObjects()

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).

Definition at line 40 of file StorageStreamHelper.cc.

{
  m_eventMetaData.registerInDataStore();
  m_rawSVDs.registerInDataStore();
  m_rawCDCs.registerInDataStore();
  m_rawTOPs.registerInDataStore();
  m_rawARICHs.registerInDataStore();
  m_rawECLs.registerInDataStore();
  m_rawKLMs.registerInDataStore();
  m_rawTRGs.registerInDataStore();
  m_rawFTSWs.registerInDataStore();
 
  //m_eventT0.registerInDataStore();
  m_onlineEventT0.registerInDataStore();
  //m_eventT0.isRequired();
 
  if (addExpressRecoObjects) {
    m_randomGenerator.registerInDataStore(DataStore::c_DontWriteOut);
    m_softwareTriggerResult.registerInDataStore();
    m_softwareTriggerVariables.registerInDataStore();
    m_triggerSummary.registerInDataStore();
    m_rawPXDs.registerInDataStore();
    m_roiPayload.registerInDataStore();
    m_rois.registerInDataStore("ROIs");
  }
 
  m_streamer = new DataStoreStreamer();
}

Member Data Documentation

◆ m_buf

int* m_buf

private

Definition at line 79 of file StorageStreamHelper.h.

◆ m_data

BinData m_data

private

Decoding input.

Definition at line 76 of file StorageStreamHelper.h.

◆ m_data_hlt

BinData m_data_hlt

private

Definition at line 77 of file StorageStreamHelper.h.

◆ m_data_pxd

BinData m_data_pxd

private

Definition at line 78 of file StorageStreamHelper.h.

◆ m_eb2

int m_eb2 = 1

private

Definition at line 80 of file StorageStreamHelper.h.

◆ m_eventMetaData

StoreObjPtr<EventMetaData> m_eventMetaData

private

Store Objects for HLT use.

Definition at line 83 of file StorageStreamHelper.h.

◆ m_eventT0

StoreObjPtr<EventT0> m_eventT0

private

StoreArray of EventT0.

Definition at line 107 of file StorageStreamHelper.h.

◆ m_maximalCompressedSize

unsigned int m_maximalCompressedSize = 100'000'000

private

Maximal size of the compression buffer.

Definition at line 125 of file StorageStreamHelper.h.

◆ m_onlineEventT0

StoreArray<OnlineEventT0> m_onlineEventT0

private

StoreArray of OnlineEventT0.

Definition at line 104 of file StorageStreamHelper.h.

◆ m_outputBuffer

std::vector<char> m_outputBuffer

private

Temporary buffer for storing the compressed result.

Definition at line 123 of file StorageStreamHelper.h.

◆ m_randomGenerator

StoreObjPtr<RandomGenerator> m_randomGenerator

private

Additional Store Objects for ExpressReco use.

Definition at line 110 of file StorageStreamHelper.h.

◆ m_rawARICHs

StoreArray<RawARICH> m_rawARICHs

private

Store Objects for HLT use.

Definition at line 91 of file StorageStreamHelper.h.

◆ m_rawCDCs

StoreArray<RawCDC> m_rawCDCs

private

Store Objects for HLT use.

Definition at line 87 of file StorageStreamHelper.h.

◆ m_rawECLs

StoreArray<RawECL> m_rawECLs

private

Store Objects for HLT use.

Definition at line 93 of file StorageStreamHelper.h.

◆ m_rawFTSWs

StoreArray<RawFTSW> m_rawFTSWs

private

Store Objects for HLT use.

Definition at line 99 of file StorageStreamHelper.h.

◆ m_rawKLMs

StoreArray<RawKLM> m_rawKLMs

private

Store Objects for HLT use.

Definition at line 95 of file StorageStreamHelper.h.

◆ m_rawPXDs

StoreArray<RawPXD> m_rawPXDs

private

Additional Store Objects for ExpressReco use.

Definition at line 118 of file StorageStreamHelper.h.

◆ m_rawSVDs

StoreArray<RawSVD> m_rawSVDs

private

Store Objects for HLT use.

Definition at line 85 of file StorageStreamHelper.h.

◆ m_rawTOPs

StoreArray<RawTOP> m_rawTOPs

private

Store Objects for HLT use.

Definition at line 89 of file StorageStreamHelper.h.

◆ m_rawTRGs

StoreArray<RawTRG> m_rawTRGs

private

Store Objects for HLT use.

Definition at line 97 of file StorageStreamHelper.h.

◆ m_roiPayload

StoreObjPtr<ROIpayload> m_roiPayload

private

Store Objects for HLT use.

Definition at line 101 of file StorageStreamHelper.h.

◆ m_rois

StoreArray<ROIid> m_rois

private

Additional Store Objects for ExpressReco use.

Definition at line 120 of file StorageStreamHelper.h.

◆ m_softwareTriggerResult

StoreObjPtr<SoftwareTriggerResult> m_softwareTriggerResult

private

Additional Store Objects for ExpressReco use.

Definition at line 112 of file StorageStreamHelper.h.

◆ m_softwareTriggerVariables

StoreObjPtr<SoftwareTrigger::SoftwareTriggerVariables> m_softwareTriggerVariables

private

Additional Store Objects for ExpressReco use.

Definition at line 114 of file StorageStreamHelper.h.

◆ m_streamer

DataStoreStreamer* m_streamer

private

Definition at line 73 of file StorageStreamHelper.h.

◆ m_streamHelper

StreamHelper m_streamHelper

private

We use the framework stream helper.

Definition at line 72 of file StorageStreamHelper.h.

◆ m_triggerSummary

StoreObjPtr<TRGSummary> m_triggerSummary

private

Additional Store Objects for ExpressReco use.

Definition at line 116 of file StorageStreamHelper.h.

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

daq/hbasf2/utils/include/StorageStreamHelper.h
daq/hbasf2/utils/src/StorageStreamHelper.cc

Public Member Functions

Private Attributes

Detailed Description

Member Function Documentation

◆ initialize()

◆ read()

◆ registerStoreObjects()

Member Data Documentation

◆ m_buf

◆ m_data

◆ m_data_hlt

◆ m_data_pxd

◆ m_eb2

◆ m_eventMetaData

◆ m_eventT0

◆ m_maximalCompressedSize

◆ m_onlineEventT0

◆ m_outputBuffer

◆ m_randomGenerator

◆ m_rawARICHs

◆ m_rawCDCs

◆ m_rawECLs

◆ m_rawFTSWs

◆ m_rawKLMs

◆ m_rawPXDs

◆ m_rawSVDs

◆ m_rawTOPs

◆ m_rawTRGs

◆ m_roiPayload

◆ m_rois

◆ m_softwareTriggerResult

◆ m_softwareTriggerVariables

◆ m_streamer

◆ m_streamHelper

◆ m_triggerSummary