HSIFrameProcessor.cpp

Go to the documentation of this file.

#include "HSIFrameProcessor.hpp"
#include "hsilibs/Types.hpp"
 
#include <atomic>
#include <functional>
#include <memory>
#include <string>
 
using dunedaq::datahandlinglibs::logging::TLVL_FRAME_RECEIVED;
 
namespace dunedaq {
namespace hsilibs {
 
void
HSIFrameProcessor::conf(const appmodel::DataHandlerModule* conf)
{
  inherited::add_preprocess_task(std::bind(&HSIFrameProcessor::timestamp_check, this, std::placeholders::_1));
  // m_tasklist.push_back( std::bind(&HSIFrameProcessor::frame_error_check, this, std::placeholders::_1) );
  inherited::conf(conf);
}
 
void
HSIFrameProcessor::timestamp_check(frameptr fp)
{
  // Acquire timestamp
  timestamp_t current_ts = fp->get_timestamp();
  uint64_t k_clock_frequency = 62500000; // NOLINT(build/unsigned)
  TLOG_DEBUG(TLVL_FRAME_RECEIVED) << "Received HSI frame timestamp value of " << current_ts << " ticks (..."
                                  << std::fixed << std::setprecision(8)
                                  << (static_cast<double>(current_ts % (k_clock_frequency * 1000)) /
                                      static_cast<double>(k_clock_frequency))
                                  << " sec)"; // NOLINT
 
  if (current_ts < m_previous_ts) {
    TLOG() << "*** Data Integrity ERROR *** Current HSIFrame timestamp " << current_ts
           << " is before previous timestamp " << m_previous_ts;
  }
 
  if (current_ts == 0) {
    TLOG() << "*** Data Integrity ERROR *** Current HSIFrame timestamp " << current_ts << " is 0";
  }
 
  m_previous_ts = current_ts;
  m_last_processed_daq_ts = current_ts;
}

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