9#ifndef DS2SAMPLEMODULE_H
10#define DS2SAMPLEMODULE_H
12#include <framework/core/Module.h>
13#include <framework/pcore/RingBuffer.h>
15#include <framework/pcore/DataStoreStreamer.h>
19#define RBUFSIZE 100000000
43 void event()
override;
Stream/restore DataStore objects to/from EvtMessage.
A class definition of an input module for Sequential ROOT I/O.
DataStoreStreamer * m_streamer
DataStore streamer.
void initialize() override
Module functions to be called from main process.
void event() override
This method is the core of the module.
void endRun() override
This method is called if the current run ends.
void terminate() override
This method is called at the end of the event processing.
Ds2SampleModule()
Constructor / Destructor.
void beginRun() override
Module functions to be called from event process.
int m_nsent
No. of sent events.
std::vector< std::string > m_saveObjs
List of objects to be saved.
int m_compressionLevel
Compression parameter.
std::string m_rbufname
RingBuffer ID.
Class to manage a Ring Buffer placed in an IPC shared memory.
Abstract base class for different kinds of events.