Belle II Software  release-05-02-19
RxSocketModule.h
1 //+
2 // File : rxmodule.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 RXMODULE_H
10 #define RXMODULE_H
11 
12 #include <framework/core/Module.h>
13 #include <daq/dataflow/EvtSocket.h>
14 
15 #include <framework/pcore/DataStoreStreamer.h>
16 
17 namespace Belle2 {
25  class RxSocketModule : public Module {
26 
27  // Public functions
28  public:
29 
32  virtual ~RxSocketModule();
33 
35  virtual void initialize();
36 
38  virtual void beginRun();
39  virtual void event();
40  virtual void endRun();
41  virtual void terminate();
42 
43  // Data members
44  private:
45 
47  int m_port;
48 
51 
54 
57 
59  int m_nrecv;
60 
61  };
62 
64 } // end namespace Belle2
65 
66 #endif // MODULEHELLO_H
Belle2::RxSocketModule
A class definition of an input module for Sequential ROOT I/O.
Definition: RxSocketModule.h:25
Belle2::RxSocketModule::beginRun
virtual void beginRun()
Module functions to be called from event process.
Definition: RxSocketModule.cc:75
Belle2::RxSocketModule::terminate
virtual void terminate()
This method is called at the end of the event processing.
Definition: RxSocketModule.cc:119
Belle2::RxSocketModule::m_compressionLevel
int m_compressionLevel
Compression Level.
Definition: RxSocketModule.h:56
Belle2::RxSocketModule::RxSocketModule
RxSocketModule()
Constructor / Destructor.
Definition: RxSocketModule.cc:29
Belle2::Module
Base class for Modules.
Definition: Module.h:74
Belle2::RxSocketModule::initialize
virtual void initialize()
Module functions to be called from main process.
Definition: RxSocketModule.cc:48
Belle2
Abstract base class for different kinds of events.
Definition: MillepedeAlgorithm.h:19
Belle2::RxSocketModule::endRun
virtual void endRun()
This method is called if the current run ends.
Definition: RxSocketModule.cc:111
Belle2::RxSocketModule::m_port
int m_port
Receiver Port.
Definition: RxSocketModule.h:47
Belle2::RxSocketModule::m_streamer
DataStoreStreamer * m_streamer
DataStoreStreamer.
Definition: RxSocketModule.h:53
Belle2::RxSocketModule::m_nrecv
int m_nrecv
No. of sent events.
Definition: RxSocketModule.h:59
Belle2::RxSocketModule::m_recv
EvtSocketRecv * m_recv
Reciever Socket.
Definition: RxSocketModule.h:50
Belle2::DataStoreStreamer
Stream/restore DataStore objects to/from EvtMessage.
Definition: DataStoreStreamer.h:33
Belle2::EvtSocketRecv
Definition: EvtSocket.h:47
Belle2::RxSocketModule::event
virtual void event()
This method is the core of the module.
Definition: RxSocketModule.cc:81