HSIFrameProcessor.hpp

Go to the documentation of this file.

#ifndef HSILIBS_SRC_HSI_HSIFRAMEPROCESSOR_HPP_
#define HSILIBS_SRC_HSI_HSIFRAMEPROCESSOR_HPP_
 
#include "datahandlinglibs/DataHandlingIssues.hpp"
#include "datahandlinglibs/models/TaskRawDataProcessorModel.hpp"
 
#include "datahandlinglibs/FrameErrorRegistry.hpp"
#include "datahandlinglibs/ReadoutLogging.hpp"
#include "hsilibs/Types.hpp"
#include "logging/Logging.hpp"
 
#include <atomic>
#include <functional>
#include <memory>
#include <string>
 
namespace dunedaq {
namespace hsilibs {
 
class HSIFrameProcessor : public datahandlinglibs::TaskRawDataProcessorModel<hsilibs::HSI_FRAME_STRUCT>
{
 
public:
  using inherited = datahandlinglibs::TaskRawDataProcessorModel<hsilibs::HSI_FRAME_STRUCT>;
  using frameptr = hsilibs::HSI_FRAME_STRUCT*;
  using timestamp_t = std::uint64_t; // NOLINT(build/unsigned)
 
  // Constructor
  explicit HSIFrameProcessor(std::unique_ptr<datahandlinglibs::FrameErrorRegistry>& error_registry,
                             bool /*post_processing*/)
    : TaskRawDataProcessorModel<hsilibs::HSI_FRAME_STRUCT>(error_registry, false)
    , m_previous_ts(0)
  {
  }
 
  // Override config for pipeline setup
  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;
 
private:
};
 
} // namespace hsilibs
} // namespace dunedaq
 
#endif // HSILIBS_SRC_HSI_HSIFRAMEPROCESSOR_HPP_