Public Member Functions
	REvtSocketRecv (std::string hostname, int port)

int	status ()

int	send (EvtMessage *msg)

EvtMessage *	recv (void)

int	send_buffer (int size, char *buf)

int	recv_buffer (char *buf)

RSocketRecv *	sock (void)

Private Attributes
RSocketRecv *	m_sock

char *	m_recbuf

Detailed Description

Definition at line 26 of file REvtSocket.h.

Constructor & Destructor Documentation

◆ REvtSocketRecv()

REvtSocketRecv	(	std::string	hostname,
		int	port
	)

Definition at line 15 of file REvtSocket.cc.

{
  m_sock = new RSocketRecv(host.c_str(), (u_short)port);
  m_recbuf = new char[MAXEVTSIZE];
}

◆ ~REvtSocketRecv()

~REvtSocketRecv ( )

Definition at line 21 of file REvtSocket.cc.

{
  delete m_sock;
  delete[] m_recbuf;
}

Member Function Documentation

◆ recv()

EvtMessage * recv ( void )

Definition at line 33 of file REvtSocket.cc.

{
  int stat = m_sock->get(m_recbuf, MAXEVTSIZE);
  if (stat <= 0) return NULL;
  EvtMessage* evt = new EvtMessage(m_recbuf);
  //  delete [] evtbuf;
  return evt;
}

◆ recv_buffer()

int recv_buffer ( char * buf )

Definition at line 47 of file REvtSocket.cc.

{
  int stat = m_sock->get(buf, MAXEVTSIZE);
  return stat;
}

◆ send()

int send ( EvtMessage * msg )

Definition at line 27 of file REvtSocket.cc.

{
  //  printf ( "REvtSocketRecv : sending = %d\n", msg->size() );
  return m_sock->put((char*)msg->buffer(), msg->size());
}

◆ send_buffer()

int send_buffer	(	int	size,
		char *	buf
	)

Definition at line 42 of file REvtSocket.cc.

{
  return m_sock->put(buf, nbytes);
}

◆ sock()

RSocketRecv * sock ( void )

Definition at line 53 of file REvtSocket.cc.

{
  return m_sock;
}

Member Data Documentation

◆ m_recbuf

char* m_recbuf

private

Definition at line 43 of file REvtSocket.h.

◆ m_sock

RSocketRecv* m_sock