ElinkConcept.hpp

Go to the documentation of this file.

#ifndef FLXLIBS_SRC_ELINKCONCEPT_HPP_
#define FLXLIBS_SRC_ELINKCONCEPT_HPP_
 
#include "DefaultParserImpl.hpp"
 
#include "appfwk/DAQModule.hpp"
#include "packetformat/detail/block_parser.hpp"
 
#include "appmodel/DataMoveCallbackConf.hpp"
 
#include <memory>
#include <sstream>
#include <string>
 
namespace dunedaq {
namespace flxlibs {
 
class ElinkConcept : public opmonlib::MonitorableObject 
{
public:
  ElinkConcept()
    : m_parser_impl()
    , m_card_id(0)
    , m_logical_unit(0)
    , m_link_id(0)
    , m_link_tag(0)
    , m_elink_str("")
    , m_elink_source_tid("")
  {
    m_parser = std::make_unique<felix::packetformat::BlockParser<DefaultParserImpl>>(m_parser_impl);
  }
  virtual ~ElinkConcept() {}
 
  ElinkConcept(const ElinkConcept&) = delete;            
  ElinkConcept& operator=(const ElinkConcept&) = delete; 
  ElinkConcept(ElinkConcept&&) = delete;                 
  ElinkConcept& operator=(ElinkConcept&&) = delete;      
 
  virtual void init(const size_t block_queue_capacity) = 0;
  virtual void acquire_callback() = 0;
  
  virtual void conf(size_t block_size, bool is_32b_trailers) = 0;
  virtual void start() = 0;
  virtual void stop() = 0;
 
  virtual bool queue_in_block_address(uint64_t block_addr) = 0; // NOLINT
 
  DefaultParserImpl& get_parser() { return std::ref(m_parser_impl); }
 
  void set_sink_config(const appmodel::DataMoveCallbackConf* sink_conf) 
  { 
    m_sink_conf = sink_conf; 
  }
  
  void set_ids(int card, int slr, int id, int tag)
  {
    m_card_id = card;
    m_logical_unit = slr;
    m_link_id = id;
    m_link_tag = tag;
 
    std::ostringstream lidstrs;
    lidstrs << "Elink["
            << "cid:" << std::to_string(m_card_id) << "|"
            << "slr:" << std::to_string(m_logical_unit) << "|"
            << "lid:" << std::to_string(m_link_id) << "|"
            << "tag:" << std::to_string(m_link_tag) << "]";
    m_elink_str = lidstrs.str();
 
    std::ostringstream tidstrs;
    tidstrs << "ept-" << std::to_string(m_card_id) << "-" << std::to_string(m_logical_unit);
    m_elink_source_tid = tidstrs.str();
 
  }
 
  const appmodel::DataMoveCallbackConf* m_sink_conf;
 
  protected:
  // Block Parser
  DefaultParserImpl m_parser_impl;
  std::unique_ptr<felix::packetformat::BlockParser<DefaultParserImpl>> m_parser;
 
  int m_card_id;
  int m_logical_unit;
  int m_link_id;
  int m_link_tag;
  std::string m_elink_str;
  std::string m_elink_source_tid;
  std::chrono::time_point<std::chrono::high_resolution_clock> m_t0;
 
private:
};
 
} // namespace flxlibs
} // namespace dunedaq
 
#endif // FLXLIBS_SRC_ELINKCONCEPT_HPP_