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
Stream/restore DataStore objects to/from EvtMessage.
A class definition of an input module for Sequential ROOT I/O.
virtual void event()
This method is the core of the module.
DataStoreStreamer * m_streamer
DataStore streamer.
virtual void initialize()
Module functions to be called from main process.
virtual void beginRun()
Module functions to be called from event process.
virtual void terminate()
This method is called at the end of the event processing.
virtual void endRun()
This method is called if the current run ends.
Ds2SampleModule()
Constructor / Destructor.
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.