Belle II Software development
StorageDeserializer.h
1/**************************************************************************
2 * basf2 (Belle II Analysis Software Framework) *
3 * Author: The Belle II Collaboration *
4 * *
5 * See git log for contributors and copyright holders. *
6 * This file is licensed under LGPL-3.0, see LICENSE.md. *
7 **************************************************************************/
8
9#ifndef STORAGEDESERIALIZER_H
10#define STORAGEDESERIALIZER_H
11
12#include <framework/core/Module.h>
13#include <framework/datastore/StoreArray.h>
14
15#include <rawdata/dataobjects/RawCOPPER.h>
16
17#include <daq/slc/readout/RunInfoBuffer.h>
18
19#include <daq/storage/SharedEventBuffer.h>
20#include "daq/storage/modules/DataStorePackage.h"
21
22#include <string>
23#include <vector>
24
25namespace Belle2 {
33
34 /*
35 private:
36 static StorageDeserializerModule* g_module;
37
38 public:
39 static StorageDeserializerModule* get() { return g_module; }
40 static DataStorePackage& getPackage() { return *(g_module->m_package); }
41 static RunInfoBuffer& getInfo() { return g_module->m_info; }
42 static EvtMessage* streamDataStore();
43 */
44
45 // Public functions
46 public:
50
52 void initialize() override;
53
55 void beginRun() override;
56 void event() override;
57 void endRun() override;
58 void terminate() override;
59
60 private:
61 DataStorePackage* m_package;
62 std::string m_ibuf_name;
63 int m_ibuf_size;
64 SharedEventBuffer m_ibuf;
65 RunInfoBuffer m_info;
66 int m_compressionLevel;
67 int m_nodeid;
68 std::string m_nodename;
69 int m_shmflag;
70 unsigned long long m_count;
71 int m_expno;
72 int m_runno;
73 unsigned int m_evtno;
74 MsgHandler* m_handler;
77 int m_eb2;
78 std::vector<std::string> m_saveObjs;
79
80 StoreArray<RawCOPPER> rawcprarray;
81 StoreArray<RawPXD> rawpxdarray;
82
83 };
84
86} // end namespace Belle2
87
88#endif // MODULEHELLO_H
Stream/restore DataStore objects to/from EvtMessage.
Base class for Modules.
Definition: Module.h:72
A class to encode/decode an EvtMessage.
Definition: MsgHandler.h:103
A class definition of an input module for Sequential ROOT I/O.
DataStoreStreamer * m_streamer
DataStoreStreamer.
void initialize() override
Module functions to be called from main process.
void event() override
This method is the core of the module.
StorageDeserializerModule()
Constructor / Destructor.
void endRun() override
This method is called if the current run ends.
void terminate() override
This method is called at the end of the event processing.
void beginRun() override
Module functions to be called from event process.
Accessor to arrays stored in the data store.
Definition: StoreArray.h:113
Abstract base class for different kinds of events.