9 #include "daq/rfarm/event/RawRevSock2Rb.h"
10 #include "daq/dataflow/REvtSocket.h"
22 m_evtbuf =
new char[MAXEVTSIZE];
23 m_flow =
new RFFlowStat((
char*)shmname.c_str(),
id, m_rbuf);
24 m_buf =
new int[MAXBUFSIZE];
28 RawRevSock2Rb::~RawRevSock2Rb(
void)
37 int bufsize = m_sock->get_wordbuf(m_buf, MAXBUFSIZE);
42 m_flow->log(bufsize * 4);
47 stat = m_rbuf->insq(m_buf, bufsize);
57 return m_sock->reconnect(ntimes);