DAPHNEEthStreamFrameProcessor.cpp

Go to the documentation of this file.

#include "fddetdataformats/DAPHNEEthStreamFrame.hpp"
#include "fdreadoutlibs/daphneeth/DAPHNEEthStreamFrameProcessor.hpp"
 
#include <atomic>
#include <functional>
#include <memory>
#include <string>
 
using dunedaq::datahandlinglibs::logging::TLVL_BOOKKEEPING;
using dunedaq::datahandlinglibs::logging::TLVL_FRAME_RECEIVED;
 
namespace dunedaq {
namespace fdreadoutlibs {
 
void 
DAPHNEEthStreamFrameProcessor::conf(const appmodel::DataHandlerModule* conf)
{
  datahandlinglibs::TaskRawDataProcessorModel<types::DAPHNEEthStreamTypeAdapter>::add_preprocess_task(
    std::bind(&DAPHNEEthStreamFrameProcessor::timestamp_check, this, std::placeholders::_1));
  // m_tasklist.push_back( std::bind(&DAPHNEStreamFrameProcessor::frame_error_check, this, std::placeholders::_1) );
  TaskRawDataProcessorModel<types::DAPHNEEthStreamTypeAdapter>::conf(conf);
}

void 
DAPHNEEthStreamFrameProcessor::timestamp_check(frameptr fp)
{
/* Let Source Emulator deal with this
  // If EMU data, emulate perfectly incrementing timestamp
  if (inherited::m_emulator_mode) { // emulate perfectly incrementing timestamp
    uint64_t ts_next = m_previous_ts + 64; // NOLINT(build/unsigned)
    auto df = reinterpret_cast<daphneframeptr>(((uint8_t*)fp));  // NOLINT
    for (unsigned int i = 0; i < fp->get_num_frames(); ++i) { // NOLINT(build/unsigned)
      //auto wfh = const_cast<dunedaq::fddetdataformats::WIB2Header*>(wf->get_wib_header());
      df->set_timestamp(ts_next);
      ts_next += 64;
      df++;
    }
  }
*/
  // Acquire timestamp
  m_current_ts = fp->get_timestamp();
  uint64_t k_clock_frequency = 62500000; // NOLINT(build/unsigned)
  uint16_t tick_difference = types::DAPHNEEthStreamTypeAdapter::expected_tick_difference;
  uint16_t frame_tick_difference = tick_difference * fp->get_num_frames();
  TLOG_DEBUG(TLVL_FRAME_RECEIVED) << "Received DAPHNEEthStream frame timestamp value of " << m_current_ts << " ticks (..." << std::fixed << std::setprecision(8) << (static_cast<double>(m_current_ts % (k_clock_frequency*1000)) / static_cast<double>(k_clock_frequency)) << " sec)"; // NOLINT
 
  // Check timestamp
  // RS warning : not fixed rate!
  if (m_current_ts - m_previous_ts != frame_tick_difference) {
    ++m_ts_error_ctr;
  }
 
  if (m_ts_error_ctr > 1000) {
    if (!m_problem_reported) {
      TLOG() << "*** Data Integrity ERROR *** Timestamp continuity is completely broken! "
             << "Something is wrong with the FE source or with the configuration!";
      m_problem_reported = true;
    }
  }
 
  m_previous_ts = m_current_ts;
  m_last_processed_daq_ts = m_current_ts;
}

void 
DAPHNEEthStreamFrameProcessor::frame_error_check(frameptr /*fp*/)
{
  // check error fields
}
 
} // namespace fdreadoutlibs
} // namespace dunedaq