Belle II Software  release-05-02-19
Rbuf2DsModule.h
1 //+
2 // File : Rbuf2Ds.h
3 // Description : Module to restore DataStore in RingBuffer
4 //
5 // Author : Ryosuke Itoh, IPNS, KEK
6 // Date : 13 - Aug - 2010
7 //-
8 
9 #ifndef RBUF2DSMODULE_H
10 #define RBUF2DSMODULE_H
11 
12 #include <framework/core/Module.h>
13 #include <framework/pcore/RingBuffer.h>
14 
15 #include <string>
16 
17 #include <framework/pcore/DataStoreStreamer.h>
18 
19 #define RBUFSIZE 100000000
20 #define MAXEVTSIZE 400000000
21 
22 
23 namespace Belle2 {
31  class Rbuf2DsModule : public Module {
32 
33  // Public functions
34  public:
35 
37  Rbuf2DsModule();
38  virtual ~Rbuf2DsModule();
39 
41  virtual void initialize();
42 
44  virtual void beginRun();
45  virtual void event();
46  virtual void endRun();
47  virtual void terminate();
48 
49  // Data members
50  private:
51 
53  std::string m_rbufname;
54  RingBuffer* m_rbuf;
55 
58 
61 
63  int m_nrecv;
64 
65  };
66 
68 } // end namespace Belle2
69 
70 #endif // MODULEHELLO_H
Belle2::Rbuf2DsModule::initialize
virtual void initialize()
Module functions to be called from main process.
Definition: Rbuf2DsModule.cc:67
Belle2::Rbuf2DsModule::Rbuf2DsModule
Rbuf2DsModule()
Constructor / Destructor.
Definition: Rbuf2DsModule.cc:42
Belle2::Rbuf2DsModule::m_rbufname
std::string m_rbufname
RingBuffer ID.
Definition: Rbuf2DsModule.h:53
Belle2::Rbuf2DsModule::terminate
virtual void terminate()
This method is called at the end of the event processing.
Definition: Rbuf2DsModule.cc:184
Belle2::Rbuf2DsModule::m_streamer
DataStoreStreamer * m_streamer
DataStore streamer.
Definition: Rbuf2DsModule.h:57
Belle2::Module
Base class for Modules.
Definition: Module.h:74
Belle2::RingBuffer
Class to manage a Ring Buffer placed in an IPC shared memory.
Definition: RingBuffer.h:36
Belle2::Rbuf2DsModule::event
virtual void event()
This method is the core of the module.
Definition: Rbuf2DsModule.cc:122
Belle2
Abstract base class for different kinds of events.
Definition: MillepedeAlgorithm.h:19
Belle2::Rbuf2DsModule::m_compressionLevel
int m_compressionLevel
Compression Level.
Definition: Rbuf2DsModule.h:60
Belle2::Rbuf2DsModule::beginRun
virtual void beginRun()
Module functions to be called from event process.
Definition: Rbuf2DsModule.cc:106
Belle2::Rbuf2DsModule::endRun
virtual void endRun()
This method is called if the current run ends.
Definition: Rbuf2DsModule.cc:176
Belle2::Rbuf2DsModule::m_nrecv
int m_nrecv
No. of sent events.
Definition: Rbuf2DsModule.h:63
Belle2::DataStoreStreamer
Stream/restore DataStore objects to/from EvtMessage.
Definition: DataStoreStreamer.h:33
Belle2::Rbuf2DsModule
A class definition of an input module for Sequential ROOT I/O.
Definition: Rbuf2DsModule.h:31