Belle II Software  release-08-01-10
RunInfoBuffer.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 #ifndef _Belle2_RunInfoBuffer_h
9 #define _Belle2_RunInfoBuffer_h
10 
11 #include "daq/slc/system/SharedMemory.h"
12 #include "daq/slc/system/MMutex.h"
13 #include "daq/slc/system/MCond.h"
14 #include "daq/slc/readout/ronode_info.h"
15 
16 namespace Belle2 {
22  class RunInfoBuffer {
23 
24  public:
25  enum State {
26  NOTREADY = 0,
27  READY = 1,
28  RUNNING = 2,
29  PAUSING = 3,
30  PAUSED = 4,
31  RESUMING = 5
32  };
33 
34  public:
35  enum EFlag {
36  NOERRO,
37  PROCESS_DOWN = 0x01,
38  SOCKET_BIND = 0x02,
39  SOCKET_IN = 0x04,
40  SOCKET_OUT = 0x08,
41  EVENTFORMAT = 0x10,
42  CPRFIFO_EMPTY = 0x20,
43  CPRFIFO_FULL = 0x40,
44  CPRFIFO_LEF_FULL = 0x80
45  };
46 
47  public:
48  RunInfoBuffer()
49  {
50  m_info = NULL;
51  }
52  ~RunInfoBuffer() {}
53 
54  public:
55  size_t size() ;
56  bool open(const std::string& nodename,
57  int nodeid = 0, bool recreate = false);
58  bool init();
59  bool close();
60  bool unlink();
61  bool lock() ;
62  bool unlock() ;
63  bool wait() ;
64  bool wait(int time) ;
65  bool notify() ;
66  void clear();
67 
68  public:
69  const std::string getName() const { return m_nodename; }
70  const std::string getPath() const { return m_path; }
71  bool isAvailable() const { return m_info != NULL; }
72  ronode_info* get() { return m_info; }
73  unsigned int getNodeId() const { return m_info->nodeid; }
74  unsigned int getState() const { return m_info->state; }
75  unsigned int getErrorFlag() const { return m_info->eflag; }
76  unsigned int getExpNumber() const { return m_info->expno; }
77  unsigned int getRunNumber() const { return m_info->runno; }
78  unsigned int getSubNumber() const { return m_info->subno; }
79  int getInputPort() const { return m_info->io[0].port; }
80  int getInputAddress() const { return m_info->io[0].addr; }
81  unsigned int getInputCount() const { return m_info->io[0].count; }
82  unsigned long long getInputNBytes() const { return m_info->io[0].nbyte; }
83  int getOutputPort() const { return m_info->io[1].port; }
84  int getOutputAddress() const { return m_info->io[1].addr; }
85  unsigned int getOutputCount() const { return m_info->io[1].count; }
86  unsigned long long getOutputNBytes() const { return m_info->io[1].nbyte; }
87  void setNodeId(unsigned int id) { m_info->nodeid = id; }
88  void setState(State state) { m_info->state = (unsigned int)state; }
89  void setErrorFlag(EFlag eflag) { m_info->eflag = (unsigned int)eflag; }
90  void setExpNumber(unsigned int expno) { m_info->expno = expno; }
91  void setRunNumber(unsigned int runno) { m_info->runno = runno; }
92  void setSubNumber(unsigned int subno) { m_info->subno = subno; }
93  void setInputPort(int port) { m_info->io[0].port = port; }
94  void setInputAddress(int addr) { m_info->io[0].addr = addr; }
95  void setInputCount(unsigned int count) { m_info->io[0].count = count; }
96  void setInputNBytes(unsigned long long nbyte) { m_info->io[0].nbyte = nbyte; }
97  void addInputCount(unsigned int count) { m_info->io[0].count += count; }
98  void addInputNBytes(unsigned long long nbyte) { m_info->io[0].nbyte += nbyte; }
99  void setOutputPort(int port) { m_info->io[1].port = port; }
100  void setOutputAddress(int addr) { m_info->io[1].addr = addr; }
101  void setOutputCount(unsigned int count) { m_info->io[1].count = count; }
102  void setOutputNBytes(unsigned long long nbyte) { m_info->io[1].nbyte = nbyte; }
103  void addOutputCount(unsigned int count) { m_info->io[1].count += count; }
104  void addOutputNBytes(unsigned long long nbyte) { m_info->io[1].nbyte += nbyte; }
105  event_header& getEventHeader() { return m_info->header; }
106  void copyEventHeader(int* buf);
107  bool isNotReady() { return (m_info) && m_info->state == NOTREADY; }
108  bool isReady() { return (m_info) && m_info->state == READY; }
109  bool isRunning() { return (m_info) && m_info->state == RUNNING; }
110  bool isPausing() { return (m_info) && m_info->state == PAUSING; }
111  bool isPaused() { return (m_info) && m_info->state == PAUSED; }
112  bool isResuming() { return (m_info) && m_info->state == RESUMING; }
113 
114  bool waitRunning(int timeout);
115  bool waitReady(int timeout);
116  bool reportRunning();
117  bool reportError(EFlag eflag);
118  bool reportReady();
119  bool reportNotReady();
120 
121  private:
122  std::string m_nodename;
123  std::string m_path;
124  SharedMemory m_memory;
125  ronode_info* m_info;
126  MMutex m_mutex;
127  MCond m_cond;
128 
129  };
130 
132 }
133 
134 #endif
Belle2
Abstract base class for different kinds of events.
Definition: MillepedeAlgorithm.h:17
Belle2::event_header
Definition: ronode_info.h:19
Belle2::ronode_info
Definition: ronode_info.h:30