11#include <framework/core/Module.h>
12#include <framework/pcore/MsgHandler.h>
13#include <framework/pcore/SeqFile.h>
14#include <framework/pcore/DataStoreStreamer.h>
43 virtual void event()
override;
44 virtual void endRun()
override;
Stream/restore DataStore objects to/from EvtMessage.
A class to encode/decode an EvtMessage.
A class to manage I/O for a chain of blocked files.
Output module for sequential ROOT I/O.
int m_nevt
Total nr. of events in the file.
DataStoreStreamer * m_streamer
DataStoreStreamer.
virtual void initialize() override
Module functions to be called from main process.
virtual void event() override
This method is the core of the module.
struct timeval m_tend
time at end of current run.
virtual void endRun() override
This method is called if the current run ends.
virtual void terminate() override
This method is called at the end of the event processing.
bool m_fileNameIsPattern
If true the output filename will be interpreted as a boost::format pattern.
int m_streamerinfo_size
The size of the StreamerInfo.
SeqFile * m_file
Blocked file handler.
MsgHandler * m_msghandler
Messaage handler.
virtual void beginRun() override
Module functions to be called from event process.
std::vector< std::string > m_saveObjs
List of objects to be saved.
int m_compressionLevel
Compression level.
SeqRootOutputModule()
Constructor / Destructor.
double m_size
total transferred data, in kB.
void getStreamerInfos()
! Write StreamerInfos to a file
char * m_streamerinfo
StreamerInfo to be written.
std::string m_outputFileName
File name.
double m_size2
sum of squares of data transferred in each event, in kB^2.
Abstract base class for different kinds of events.