DFInterface.cc

Go to the documentation of this file.

#include "DFInterface.hh"
#include "log.hh"
 
/**
 * \author cpellegrino
 */
 
void DFInterface::operator ()()
{
  Frame frame;
 
  while (isRunning())
  {
    // wait for and get data
    m_farm.getFrame(frame);
 
    if (frame.size()) {
 
      benchmark::chrono_set(frame);
 
      #ifdef DEBUG_DAQ_HEADER
      DAQHeaderPrinter const daq_head(frame.data());
      LOG_DEBUG << "DFInterface: Got this from the queue " << daq_head;
      #endif
 
      if (!frame.getNItems())
      {
        DAQHeaderPrinter const daq_head(frame.data());
        LOG_NOTICE << "DFInterface: No data to transmit: " << daq_head;
        continue;
      }
 
      #ifdef DEBUG_FRAME_LENGHT
      static unsigned int nframes = 0;
      ++nframes;
      if (!(nframes % 10000))
      {
        LOG_DEBUG << "DFInterface: FrameLenght(): " << frame.getFrameLength();
      }
      #endif
 
      m_recipients.send(frame);
 
      benchmark::chrono_set(frame);
      benchmark::chrono_dump(frame);
    }
  }
}