Sock2Rb Class Reference

Public Member Functions
	Sock2Rb (std::string rbuf, int port)
	Constuctor and Destructor.
int	ReceiveEvent (void)
	Event function.

Private Attributes
RingBuffer *	m_rbuf
EvtSocketRecv *	m_sock
char *	m_evtbuf

Detailed Description

Definition at line 23 of file Sock2Rb.h.

Constructor & Destructor Documentation

Sock2Rb()

Sock2Rb	(	std::string	rbuf,
		int	port )

Constuctor and Destructor.

Definition at line 16 of file Sock2Rb.cc.

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

~Sock2Rb()

~Sock2Rb

(

void

)

Definition at line 25 of file Sock2Rb.cc.

{
  delete m_sock;
  delete m_rbuf;
}

Member Function Documentation

ReceiveEvent()

int ReceiveEvent

(

void

)

Event function.

Definition at line 31 of file Sock2Rb.cc.

{
  // Get a record from socket
  EvtMessage* msg = m_sock->recv();
  if (msg == NULL) {
    return 0;
  }
  //  B2INFO ( "Rx: got an event from Socket, size=" << msg->size()  );
  if (msg->type() == MSG_TERMINATE) {
    return 0;
    // Flag End Of File !!!!!
    //    return msg->type(); // EOF
  }
 
  // Put the message in ring buffer
  int stat = 0;
  for (;;) {
    stat = m_rbuf->insq((int*)msg->buffer(), msg->paddedSize());
    if (stat >= 0) break;
    //    usleep(100);
    usleep(20);
  }
  delete msg;
  return stat;
}

Member Data Documentation

m_evtbuf

char* m_evtbuf

private

Definition at line 35 of file Sock2Rb.h.

m_rbuf

RingBuffer* m_rbuf

private

Definition at line 33 of file Sock2Rb.h.

m_sock

EvtSocketRecv* m_sock

private

Definition at line 34 of file Sock2Rb.h.

---

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

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