RawRevRb2Sock Class Reference

Public Member Functions
	RawRevRb2Sock (std::string rbuf, int port, std::string shmname, int id)
	Constuctor and Destructor.
int	SendEvent (void)
	Event function.
int	Reconnect (void)
	Reconnect.

Private Attributes
RingBuffer *	m_rbuf
RSocketSend *	m_sock
RFFlowStat *	m_flow
int *	m_evtbuf

Detailed Description

Definition at line 35 of file RawRevRb2Sock.h.

Constructor & Destructor Documentation

RawRevRb2Sock()

RawRevRb2Sock	(	std::string	rbuf,
		int	port,
		std::string	shmname,
		int	id )

Constuctor and Destructor.

Definition at line 14 of file RawRevRb2Sock.cc.

{
  //  m_rbuf = new RingBuffer((char*)rbuf.c_str(), RBUFSIZE);
  m_rbuf = new RingBuffer((char*)rbuf.c_str());
  m_sock = new RSocketSend(port);
  m_evtbuf = new int[MAXEVTSIZE];
  m_flow = new RFFlowStat((char*)shmname.c_str(), id, m_rbuf);
 
  m_sock->accept();
}

~RawRevRb2Sock()

~RawRevRb2Sock

(

void

)

Definition at line 25 of file RawRevRb2Sock.cc.

{
  delete m_sock;
  delete m_rbuf;
}

Member Function Documentation

Reconnect()

int Reconnect

(

void

)

Reconnect.

Definition at line 47 of file RawRevRb2Sock.cc.

{
  int port = m_sock->port();
  delete m_sock;
  m_sock = new RSocketSend((u_short)port);
  m_sock->accept();
  return 0; //TODO is it correct?
}

SendEvent()

int SendEvent

(

void

)

Event function.

Definition at line 31 of file RawRevRb2Sock.cc.

{
  // Get a record from ringbuf
  int size;
  while ((size = m_rbuf->remq(m_evtbuf)) == 0) {
    //    printf ( "Rx : evtbuf is not available yet....\n" );
    //    usleep(100);
    usleep(20);
  }
  m_flow->log(size * 4);
 
  int is = m_sock->put_wordbuf(m_evtbuf, size);
  //  if (is < 0) perror("put_wordbuf");
  return is;
}

Member Data Documentation

m_evtbuf

int* m_evtbuf

private

Definition at line 51 of file RawRevRb2Sock.h.

m_flow

RFFlowStat* m_flow

private

Definition at line 50 of file RawRevRb2Sock.h.

m_rbuf

RingBuffer* m_rbuf

private

Definition at line 48 of file RawRevRb2Sock.h.

m_sock

RSocketSend* m_sock

private

Definition at line 49 of file RawRevRb2Sock.h.

---

The documentation for this class was generated from the following files:

• daq/rfarm/event/include/RawRevRb2Sock.h
• daq/rfarm/event/src/RawRevRb2Sock.cc