Belle II Software  release-05-01-25
RawRevSock2Rb.h
1 //+
2 // File : Sock2Rb.h
3 // Description : Receive an event from EvtSocket and place it in Rbuf.
4 //
5 // Author : Ryosuke Itoh, IPNS, KEK
6 // Date : 10 - Dec - 2002, Orignal for RFARM
7 // 26 - Apr - 2012, for Belle II RFARM
8 //-
9 
10 #include <string>
11 
12 #include "framework/pcore/RingBuffer.h"
13 #include "daq/dataflow/RSocketLib.h"
14 #include "daq/rfarm/manager/RFFlowStat.h"
15 
16 #define MAXBUFSIZE 20000000
17 #define RBUFSIZE 100000000
18 
20 public:
22  RawRevSock2Rb(std::string rbuf, std::string src, int port, std::string shmname, int id);
23  ~RawRevSock2Rb(void);
24 
26  int ReceiveEvent(void);
27 
29  int Reconnect(int ntry);
30 
31 private:
32  Belle2::RingBuffer* m_rbuf;
33  Belle2::RSocketRecv* m_sock;
34  Belle2::RFFlowStat* m_flow;
35  char* m_evtbuf;
36  int* m_buf;
37 
38 };
39 
Belle2::RSocketRecv
Definition: RSocketLib.h:58
RawRevSock2Rb::ReceiveEvent
int ReceiveEvent(void)
Event function.
Definition: RawRevSock2Rb.cc:34
Belle2::RFFlowStat
Definition: RFFlowStat.h:28
RawRevSock2Rb
Definition: RawRevSock2Rb.h:19
Belle2::RingBuffer
Class to manage a Ring Buffer placed in an IPC shared memory.
Definition: RingBuffer.h:36
RawRevSock2Rb::Reconnect
int Reconnect(int ntry)
Reconnect.
Definition: RawRevSock2Rb.cc:55
RawRevSock2Rb::RawRevSock2Rb
RawRevSock2Rb(std::string rbuf, std::string src, int port, std::string shmname, int id)
Constuctor and Destructor.
Definition: RawRevSock2Rb.cc:17