dunedaq::datahandlinglibs::FakeCardReaderBase Class Reference

#include <FakeCardReaderBase.hpp>

Public Member Functions
	FakeCardReaderBase (const std::string &name)
	FakeCardReaderBase Constructor.
virtual	~FakeCardReaderBase ()
	FakeCardReaderBase (const FakeCardReaderBase &)=delete
	FakeCardReaderBase is not copy-constructible.
FakeCardReaderBase &	operator= (const FakeCardReaderBase &)=delete
	FakeCardReaderBase is not copy-assignable.
	FakeCardReaderBase (FakeCardReaderBase &&)=delete
	FakeCardReaderBase is not move-constructible.
FakeCardReaderBase &	operator= (FakeCardReaderBase &&)=delete
	FakeCardReaderBase is not move-assignable.
void	init (std::shared_ptr< appfwk::ConfigurationManager > cfg)
virtual std::shared_ptr< datahandlinglibs::SourceEmulatorConcept >	create_source_emulator (std::string qi, std::atomic< bool > &run_marker)=0
void	do_conf (const nlohmann::json &)
void	do_scrap (const nlohmann::json &)
void	do_start (const nlohmann::json &)
void	do_stop (const nlohmann::json &)
std::string	get_fcr_name ()

Private Attributes
bool	m_configured
std::string	m_name
std::shared_ptr< appfwk::ConfigurationManager >	m_cfg
std::map< std::string, std::shared_ptr< datahandlinglibs::SourceEmulatorConcept > >	m_source_emus
std::unique_ptr< datahandlinglibs::FileSourceBuffer >	m_source_buffer
std::atomic< bool >	m_run_marker

Detailed Description

Definition at line 46 of file FakeCardReaderBase.hpp.

Constructor & Destructor Documentation

FakeCardReaderBase() [1/3]

dunedaq::datahandlinglibs::FakeCardReaderBase::FakeCardReaderBase ( const std::string & name )

explicit

FakeCardReaderBase Constructor.

Parameters

name	Instance name for this FakeCardReaderBase instance

Definition at line 4 of file FakeCardReaderBase.hxx.

  : m_configured(false)
  , m_name(name)
  , m_run_marker{ false }
{
}

~FakeCardReaderBase()

virtual dunedaq::datahandlinglibs::FakeCardReaderBase::~FakeCardReaderBase ( )

inlinevirtual

Definition at line 54 of file FakeCardReaderBase.hpp.

{}

FakeCardReaderBase() [2/3]

dunedaq::datahandlinglibs::FakeCardReaderBase::FakeCardReaderBase ( const FakeCardReaderBase & )

delete

FakeCardReaderBase is not copy-constructible.

FakeCardReaderBase() [3/3]

dunedaq::datahandlinglibs::FakeCardReaderBase::FakeCardReaderBase ( FakeCardReaderBase && )

delete

FakeCardReaderBase is not move-constructible.

Member Function Documentation

create_source_emulator()

virtual std::shared_ptr< datahandlinglibs::SourceEmulatorConcept > dunedaq::datahandlinglibs::FakeCardReaderBase::create_source_emulator ( std::string qi, std::atomic< bool > & run_marker )

pure virtual

do_conf()

void dunedaq::datahandlinglibs::FakeCardReaderBase::do_conf

(

const nlohmann::json &

)

Definition at line 43 of file FakeCardReaderBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Entering do_conf() method";
 
  if (m_configured) {
    TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_WORK_STEPS) << "This module is already configured!";
  } else {
      auto cfg = m_cfg->get_dal<appmodel::DataReaderModule>(get_fcr_name());
 
    std::map<uint32_t, const confmodel::DetectorStream*> streams;
    for (const auto & det_connections : cfg->get_connections()) {
            
      for (const auto& stream : det_connections->get_streams()) {
        streams[stream->get_source_id()] = stream;
      }
    }
 
    for (const auto& qi : cfg->get_outputs()) {
      auto q_with_id = qi->cast<confmodel::QueueWithSourceId>();
      if (q_with_id == nullptr) {
        throw datahandlinglibs::FailedFakeCardInitialization(ERS_HERE, get_fcr_name(), "Queue is not of type QueueWithSourceId");
      }  
      if (m_source_emus.find(q_with_id->UID()) == m_source_emus.end()) {
       TLOG() << "Cannot find queue: " <<  q_with_id->UID() << std::endl;
        throw datahandlinglibs::GenericConfigurationError(ERS_HERE, "Cannot find queue: " + q_with_id->UID());
      }
      if (m_source_emus[q_with_id->UID()]->is_configured()) {
        TLOG() << "Emulator for queue name " << q_with_id->UID() << " was already configured";
        throw datahandlinglibs::GenericConfigurationError(ERS_HERE, "Emulator configured twice: " + q_with_id->UID());
      }
      m_source_emus[q_with_id->UID()]->conf(streams[q_with_id->get_source_id()], cfg->get_configuration()->get_emulation_conf());
    }
    for (auto& [name, emu] : m_source_emus) {
      if (!emu->is_configured()) {
        throw datahandlinglibs::GenericConfigurationError(ERS_HERE, "Not all links were configured");
      }
    }
 
    // Mark configured
    m_configured = true;
  }
 
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Exiting do_conf() method";
}

do_scrap()

void dunedaq::datahandlinglibs::FakeCardReaderBase::do_scrap

(

const nlohmann::json &

args

)

Definition at line 89 of file FakeCardReaderBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Entering do_scrap() method";
 
  for (auto& [name, emu] : m_source_emus) {
    emu->scrap(args);
  }
 
  m_configured = false;
 
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Exiting do_scrap() method";
}

do_start()

void dunedaq::datahandlinglibs::FakeCardReaderBase::do_start

(

const nlohmann::json &

args

)

Definition at line 102 of file FakeCardReaderBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Entering do_start() method";
 
  m_run_marker.store(true);
 
  for (auto& [name, emu] : m_source_emus) {
    emu->start(args);
  }
 
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Exiting do_start() method";
}

do_stop()

void dunedaq::datahandlinglibs::FakeCardReaderBase::do_stop

(

const nlohmann::json &

args

)

Definition at line 116 of file FakeCardReaderBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Entering do_stop() method";
 
  m_run_marker = false;
 
  for (auto& [name, emu] : m_source_emus) {
    emu->stop(args);
  }
 
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Exiting do_stop() method";
}

get_fcr_name()

std::string dunedaq::datahandlinglibs::FakeCardReaderBase::get_fcr_name ( )

inline

Definition at line 73 of file FakeCardReaderBase.hpp.

{ return m_name; }

init()

void dunedaq::datahandlinglibs::FakeCardReaderBase::init

(

std::shared_ptr< appfwk::ConfigurationManager >

cfg

)

Definition at line 12 of file FakeCardReaderBase.hxx.

{
  m_cfg = cfg;
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Entering init() method";
  //auto ini = args.get<appfwk::app::ModInit>();
  auto ini = cfg->get_dal<appmodel::DataReaderModule>(m_name);
  if (ini != nullptr && ini->get_configuration()->get_emulation_mode()) {
 
    for (auto qi : ini->get_outputs()) {
      
      try {
        if (m_source_emus.find(qi->UID()) != m_source_emus.end()) {
          TLOG() << get_fcr_name() << "Same queue instance used twice";
          throw datahandlinglibs::FailedFakeCardInitialization(ERS_HERE, get_fcr_name(), "");
        }
        m_source_emus[qi->UID()] = create_source_emulator(qi->UID(), m_run_marker);
        if (m_source_emus[qi->UID()].get() == nullptr) {
          TLOG() << get_fcr_name() << "Source emulator could not be created";
          throw datahandlinglibs::FailedFakeCardInitialization(ERS_HERE, get_fcr_name(), "");
        }
        // m_source_emus[qi->UID()]->init(cfg);
        m_source_emus[qi->UID()]->set_sender(qi->UID());
      } catch (const ers::Issue& excpt) {
        throw datahandlinglibs::ResourceQueueError(ERS_HERE, qi->UID(), get_fcr_name(), excpt);
      }
    }
  }
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_fcr_name() << ": Exiting init() method";
}

operator=() [1/2]

FakeCardReaderBase & dunedaq::datahandlinglibs::FakeCardReaderBase::operator= ( const FakeCardReaderBase & )

delete

FakeCardReaderBase is not copy-assignable.

operator=() [2/2]

FakeCardReaderBase & dunedaq::datahandlinglibs::FakeCardReaderBase::operator= ( FakeCardReaderBase && )

delete

FakeCardReaderBase is not move-assignable.

Member Data Documentation

m_cfg

std::shared_ptr<appfwk::ConfigurationManager> dunedaq::datahandlinglibs::FakeCardReaderBase::m_cfg

private

Definition at line 79 of file FakeCardReaderBase.hpp.

m_configured

bool dunedaq::datahandlinglibs::FakeCardReaderBase::m_configured

private

Definition at line 77 of file FakeCardReaderBase.hpp.

m_name

std::string dunedaq::datahandlinglibs::FakeCardReaderBase::m_name

private

Definition at line 78 of file FakeCardReaderBase.hpp.

m_run_marker

std::atomic<bool> dunedaq::datahandlinglibs::FakeCardReaderBase::m_run_marker

private

Definition at line 87 of file FakeCardReaderBase.hpp.

m_source_buffer

std::unique_ptr<datahandlinglibs::FileSourceBuffer> dunedaq::datahandlinglibs::FakeCardReaderBase::m_source_buffer

private

Definition at line 84 of file FakeCardReaderBase.hpp.

m_source_emus

std::map<std::string, std::shared_ptr<datahandlinglibs::SourceEmulatorConcept> > dunedaq::datahandlinglibs::FakeCardReaderBase::m_source_emus

private

Definition at line 81 of file FakeCardReaderBase.hpp.

---

The documentation for this class was generated from the following files:

• /github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/FakeCardReaderBase.hpp
• /github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/detail/FakeCardReaderBase.hxx