EventSampler Class Reference

Public Member Functions
	EventSampler (std::vector< std::string > nodes, int port, std::string rbufname, int interval=5000)
int	server ()

Private Attributes
std::vector< EvtSocketSend * >	m_socklist
RingBuffer *	m_rbuf
int	m_interval

Detailed Description

Definition at line 25 of file EventSampler.h.

Constructor & Destructor Documentation

EventSampler()

EventSampler	(	std::vector< std::string >	nodes,
		int	port,
		std::string	rbufname,
		int	interval = 5000 )

Definition at line 18 of file EventSampler.cc.

                                                                                        : m_interval(interval)
{
  // Attach to output RingBuffer
  m_rbuf = new RingBuffer(rbufname.c_str());
 
  // Open EvtSocket
  for (vector<string>::iterator it = nodes.begin(); it != nodes.end(); ++it) {
    string& nodename = *it;
    printf("EventSampler : connecting to %s (port %d)\n", nodename.c_str(), port);
    EvtSocketSend* sock = new EvtSocketSend(nodename.c_str(), port);
    if (sock == NULL) {
      printf("EventSampler : error to connect to %s\n",
             nodename.c_str());
    } else {
      m_socklist.push_back(sock);
    }
    fflush(stdout);
  }
  printf("EventSampler : init : socklist = %lu\n", m_socklist.size());
  fflush(stdout);
}

~EventSampler()

~EventSampler

(

)

Definition at line 40 of file EventSampler.cc.

{
  for (vector<EvtSocketSend*>::iterator it = m_socklist.begin();
       it != m_socklist.end(); ++it) {
    EvtSocketSend* sock = *it;
    delete sock;
    m_socklist.erase(it);
  }
  delete m_rbuf;
}

Member Function Documentation

server()

int server

(

)

Definition at line 51 of file EventSampler.cc.

{
  //  printf ( "EventSampler : server started\n" );
  fflush(stdout);
  int nsample = 0;
  for (;;) {
    for (vector<EvtSocketSend*>::iterator it = m_socklist.begin();
         it != m_socklist.end(); ++it) {
      // Receive an event from connected socket
      EvtSocketSend* sock = *it;
      //      printf ( "EventSampler : receiving event from sock %s\n",
      //         (sock->sock())->node() );
      EvtMessage* msg = sock->recv();
      //      printf ( "Event Sampler : got event : %d\n", msg->size() );
      //      fflush ( stdout );
      if (msg == NULL) {
        printf("EventSampler : Error to receive data\n");
        return -1;
      }
      // Put the message in ring buffer. If full, just skip the event.
      m_rbuf->insq((int*)msg->buffer(), msg->paddedSize());
      delete msg;
      nsample++;
      if (nsample % 1000 == 0)
        printf("EventSampler : %d events sampled and queued\n", nsample);
      usleep(m_interval);
    }
  }
}

Member Data Documentation

m_interval

int m_interval

private

Definition at line 35 of file EventSampler.h.

m_rbuf

RingBuffer* m_rbuf

private

Definition at line 33 of file EventSampler.h.

m_socklist

std::vector<EvtSocketSend*> m_socklist

private

Definition at line 32 of file EventSampler.h.

---

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

• daq/expreco/include/EventSampler.h
• daq/expreco/src/EventSampler.cc