Rb2Sock Class Reference

Public Member Functions
	Rb2Sock (std::string rbuf, std::string dest, int port)
	Constuctor and Destructor.
int	SendEvent (void)
	Event function.

Private Attributes
RingBuffer *	m_rbuf
EvtSocketSend *	m_sock
char *	m_evtbuf

Detailed Description

Definition at line 23 of file Rb2Sock.h.

Constructor & Destructor Documentation

Rb2Sock()

Rb2Sock	(	std::string	rbuf,
		std::string	dest,
		int	port )

Constuctor and Destructor.

Definition at line 16 of file Rb2Sock.cc.

{
  //  m_rbuf = new RingBuffer(rbuf.c_str(), RBUFSIZE);
  m_rbuf = new RingBuffer(rbuf.c_str());
  m_sock = new EvtSocketSend(dest, port);
  m_evtbuf = new char[MAXEVTSIZE];
 
}

~Rb2Sock()

~Rb2Sock

(

void

)

Definition at line 25 of file Rb2Sock.cc.

{
  delete m_sock;
  delete m_rbuf;
}

Member Function Documentation

SendEvent()

int SendEvent

(

void

)

Event function.

Definition at line 31 of file Rb2Sock.cc.

{
  // Get a record from ringbuf
  int size;
  while ((size = m_rbuf->remq((int*)m_evtbuf)) == 0) {
    //    printf ( "Rx : evtbuf is not available yet....\n" );
    //    usleep(100);
    usleep(20);
  }
 
  EvtMessage* msg = new EvtMessage(m_evtbuf);    // Ptr copy, no overhead
 
  if (msg->type() == MSG_TERMINATE) {
    printf("EoF found. Exitting.....\n");
    m_sock->send(msg);
    delete msg;
    return -1;
  } else {
    int is = m_sock->send(msg);
    delete msg;
    return is;
    //    return msg->size();
  }
}

Member Data Documentation

m_evtbuf

char* m_evtbuf

private

Definition at line 35 of file Rb2Sock.h.

m_rbuf

RingBuffer* m_rbuf

private

Definition at line 33 of file Rb2Sock.h.

m_sock

EvtSocketSend* m_sock

private

Definition at line 34 of file Rb2Sock.h.

---

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

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