9 #ifndef RBUF2DSMODULE_H
10 #define RBUF2DSMODULE_H
12 #include <framework/core/Module.h>
13 #include <framework/pcore/RingBuffer.h>
17 #include <framework/pcore/DataStoreStreamer.h>
19 #define RBUFSIZE 100000000
20 #define MAXEVTSIZE 400000000
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.
int m_nrecv
No. of sent events.
int m_compressionLevel
Compression Level.
std::string m_rbufname
RingBuffer ID.
Rbuf2DsModule()
Constructor / Destructor.
Class to manage a Ring Buffer placed in an IPC shared memory.
Abstract base class for different kinds of events.