Belle II Software  release-05-01-25
RevSock2Rb.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/REvtSocket.h"
14 #include "daq/rfarm/manager/RFFlowStat.h"
15 
16 #define RBUFSIZE 100000000
17 
18 namespace Belle2 {
24  class RevSock2Rb {
25  public:
27  RevSock2Rb(std::string rbuf, std::string src, int port, std::string shmname, int id);
28  ~RevSock2Rb(void);
29 
31  int ReceiveEvent(void);
32 
34  int Reconnect(int ntry);
35 
36  private:
37  RingBuffer* m_rbuf;
38  REvtSocketRecv* m_sock;
39  RFFlowStat* m_flow;
40  char* m_evtbuf;
41 
42  };
43 
45 }
Belle2::REvtSocketRecv
Definition: REvtSocket.h:26
Belle2::RFFlowStat
Definition: RFFlowStat.h:28
Belle2::RingBuffer
Class to manage a Ring Buffer placed in an IPC shared memory.
Definition: RingBuffer.h:36
Belle2::RevSock2Rb
Definition: RevSock2Rb.h:24
Belle2
Abstract base class for different kinds of events.
Definition: MillepedeAlgorithm.h:19
Belle2::RevSock2Rb::ReceiveEvent
int ReceiveEvent(void)
Event function.
Definition: RevSock2Rb.cc:32
Belle2::RevSock2Rb::Reconnect
int Reconnect(int ntry)
Reconnect.
Definition: RevSock2Rb.cc:59
Belle2::RevSock2Rb::RevSock2Rb
RevSock2Rb(std::string rbuf, std::string src, int port, std::string shmname, int id)
Constuctor and Destructor.
Definition: RevSock2Rb.cc:16