HSIEventSender.hpp

Go to the documentation of this file.

 
#ifndef HSILIBS_INCLUDE_HSILIBS_HSIEVENTSENDER_HPP_
#define HSILIBS_INCLUDE_HSILIBS_HSIEVENTSENDER_HPP_
 
#include "hsilibs/Issues.hpp"
#include "hsilibs/Types.hpp"
 
#include "appfwk/DAQModule.hpp"
#include "dfmessages/HSIEvent.hpp"
#include "utilities/WorkerThread.hpp"
#include "iomanager/IOManager.hpp"
#include <ers/Issue.hpp>
 
#include <bitset>
#include <chrono>
#include <memory>
#include <random>
#include <string>
#include <vector>
 
namespace dunedaq {
namespace hsilibs {
 
class HSIEventSender : public dunedaq::appfwk::DAQModule
{
public:
  explicit HSIEventSender(const std::string& name);
 
  HSIEventSender(const HSIEventSender&) = delete;            
  HSIEventSender& operator=(const HSIEventSender&) = delete; 
  HSIEventSender(HSIEventSender&&) = delete;                 
  HSIEventSender& operator=(HSIEventSender&&) = delete;      
 
  void init(std::shared_ptr<appfwk::ConfigurationManager> mcfg) override;
 
protected:
  // Commands
  virtual void do_configure(const nlohmann::json& obj) = 0;
  virtual void do_start(const nlohmann::json& obj) = 0;
  virtual void do_stop(const nlohmann::json& obj) = 0;
  virtual void do_scrap(const nlohmann::json& obj) = 0;
 
  // Configuration
  std::string m_hsievent_send_connection;
  std::chrono::milliseconds m_queue_timeout;
 
  using raw_sender_ct = iomanager::SenderConcept<HSI_FRAME_STRUCT>;
 
  using hsievent_sender_ct = iomanager::SenderConcept<dfmessages::HSIEvent>;
  std::shared_ptr<hsievent_sender_ct> m_hsievent_sender;
 
  // push events to HSIEvent output queue
  virtual bool ready_to_send(std::chrono::milliseconds timeout);
  virtual void send_hsi_event(dfmessages::HSIEvent& event);
  virtual void send_raw_hsi_data(const std::array<uint32_t, 7>& raw_data, raw_sender_ct* sender);
 
  std::atomic<uint64_t> m_sent_counter;           // NOLINT(build/unsigned)
  std::atomic<uint64_t> m_failed_to_send_counter; // NOLINT(build/unsigned)
  std::atomic<uint64_t> m_last_sent_timestamp;    // NOLINT(build/unsigned)
};
} // namespace hsilibs
} // namespace dunedaq
 
#endif // TIMINGLIBS_SRC_HSIEVENTSENDER_HPP_
 
// Local Variables:
// c-basic-offset: 2
// End: