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
19
class
RawRevSock2Rb
{
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
daq
rfarm
event
include
RawRevSock2Rb.h
Generated on Fri Nov 5 2021 03:49:31 for Belle II Software by
1.8.17