TDEFrameProcessor.hpp

Go to the documentation of this file.

/*
 * @file TDEFrameProcessor.hpp TDE specific Task based raw processor
 *
 * This is part of the DUNE DAQ , copyright 2020.
 * Licensing/copyright details are in the COPYING file that you should have
 * received with this code.
 */
#ifndef FDREADOUTLIBS_INCLUDE_FDREADOUTLIBS_TDE_TDEFRAMEPROCESSOR_HPP_
#define FDREADOUTLIBS_INCLUDE_FDREADOUTLIBS_TDE_TDEFRAMEPROCESSOR_HPP_
 
#include "datahandlinglibs/DataHandlingIssues.hpp"
#include "datahandlinglibs/models/TaskRawDataProcessorModel.hpp"
 
#include "fddetdataformats/TDE16Frame.hpp"
 
#include "fdreadoutlibs/TDEFrameTypeAdapter.hpp"
 
#include "logging/Logging.hpp"
#include "datahandlinglibs/FrameErrorRegistry.hpp"
#include "datahandlinglibs/ReadoutLogging.hpp"
 
#include <atomic>
#include <functional>
#include <memory>
#include <string>
 
using dunedaq::datahandlinglibs::logging::TLVL_BOOKKEEPING;
 
namespace dunedaq {
namespace fdreadoutlibs {
 
class TDEFrameProcessor : public datahandlinglibs::TaskRawDataProcessorModel<types::TDEFrameTypeAdapter
>
{
 
public:
  using inherited = datahandlinglibs::TaskRawDataProcessorModel<types::TDEFrameTypeAdapter>;
  using frameptr = types::TDEFrameTypeAdapter*;
  using tdeframeptr = dunedaq::fddetdataformats::TDE16Frame*;
  using timestamp_t = std::uint64_t; // NOLINT(build/unsigned)
 
  explicit TDEFrameProcessor(std::unique_ptr<datahandlinglibs::FrameErrorRegistry>& error_registry, bool post_processing_enabled)
    : TaskRawDataProcessorModel<types::TDEFrameTypeAdapter
>(error_registry, post_processing_enabled)
  {}
 
  // Override configuration to register pipeline
  void conf(const appmodel::DataHandlerModule* conf) override;
 
protected:
  void timestamp_check(frameptr fp);
 
  void frame_error_check(frameptr /*fp*/);
 
  // Internals
  timestamp_t m_previous_ts[64] = {0};
  timestamp_t m_current_ts = 0;
  bool m_first_ts_missmatch = true;
  bool m_problem_reported = false;
  std::atomic<int> m_ts_error_ctr{ 0 };
  uint64_t m_clock_frequency; // NOLINT(build/unsigned)
 
private:
};
 
} // namespace fdreadoutlibs
} // namespace dunedaq
 
#endif // FDREADOUTLIBS_INCLUDE_FDREADOUTLIBS_TDE_TDEFRAMEPROCESSOR_HPP_