TPProcessor.hpp

Go to the documentation of this file.

 
#ifndef TRIGGER_SRC_TRIGGER_TPPROCESSOR_HPP_
#define TRIGGER_SRC_TRIGGER_TPPROCESSOR_HPP_
 
#include "iomanager/IOManager.hpp"
#include "iomanager/Sender.hpp"
#include "logging/Logging.hpp"
 
#include "datahandlinglibs/models/TaskRawDataProcessorModel.hpp"
 
//#include "triggger/Issues.hpp"
#include "trigger/TriggerPrimitiveTypeAdapter.hpp"
#include "trigger/Latency.hpp"
#include "trigger/opmon/tpprocessor_info.pb.h"
#include "trigger/opmon/latency_info.pb.h"
 
#include "triggeralgs/TriggerActivity.hpp"
#include "triggeralgs/Types.hpp"
#include "triggeralgs/TriggerActivityMaker.hpp"
 
#include "appmodel/DataHandlerModule.hpp"
 
namespace dunedaq {
namespace trigger {
 
class TPProcessor : public datahandlinglibs::TaskRawDataProcessorModel<TriggerPrimitiveTypeAdapter>
{
 
public:
  using inherited = datahandlinglibs::TaskRawDataProcessorModel<TriggerPrimitiveTypeAdapter>;
  using tpptr = TriggerPrimitiveTypeAdapter*;
  using consttpptr = const TriggerPrimitiveTypeAdapter*;
 
 
  explicit TPProcessor(std::unique_ptr<datahandlinglibs::FrameErrorRegistry>& error_registry, bool post_processing_enabled);
 
  ~TPProcessor();
 
  void start(const nlohmann::json& args) override;
 
  void stop(const nlohmann::json& args) override;
 
  void conf(const appmodel::DataHandlerModule* conf) override;
 
  void scrap(const nlohmann::json& args) override;
 
  void generate_opmon_data() override;
 
protected:
  // Internals
  dunedaq::daqdataformats::timestamp_t m_previous_ts = 0;
  dunedaq::daqdataformats::timestamp_t m_current_ts = 0;
 
  void find_ta(const TriggerPrimitiveTypeAdapter* tp,  std::shared_ptr<triggeralgs::TriggerActivityMaker> tam);
 
  private:
 
  std::vector<std::shared_ptr<triggeralgs::TriggerActivityMaker>> m_tams;
 
  std::shared_ptr<iomanager::SenderConcept<triggeralgs::TriggerActivity>> m_ta_sink;
 
  daqdataformats::SourceID m_sourceid;
 
  using metric_counter_type = uint64_t;
  std::atomic<metric_counter_type> m_tp_received_count{ 0 };  // NOLINT(build/unsigned)
  std::atomic<metric_counter_type> m_ta_made_count{ 0 };
  std::atomic<metric_counter_type> m_ta_sent_count{ 0 };
  std::atomic<metric_counter_type> m_ta_failed_sent_count{ 0 };
  void print_opmon_stats();
 
  // Create an instance of the Latency class
  std::atomic<bool> m_running_flag{ false };
  std::atomic<bool> m_latency_monitoring{ false };
  dunedaq::trigger::Latency m_latency_instance;
  std::atomic<metric_counter_type> m_latency_in{ 0 };
  std::atomic<metric_counter_type> m_latency_out{ 0 };
 
};
 
} // namespace trigger
} // namespace dunedaq
 
#endif // TRIGGER_SRC_TRIGGER_TPPROCESSOR_HPP_