dunedaq::snbmodules::FileReaderBase Class Reference

#include <FileReaderBase.hpp>

Public Member Functions
	FileReaderBase (const std::string &name)
	FileReaderBase Constructor.
virtual	~FileReaderBase ()
	FileReaderBase (const FileReaderBase &)=delete
	FileReaderBase is not copy-constructible.
FileReaderBase &	operator= (const FileReaderBase &)=delete
	FileReaderBase is not copy-assignable.
	FileReaderBase (FileReaderBase &&)=delete
	FileReaderBase is not move-constructible.
FileReaderBase &	operator= (FileReaderBase &&)=delete
	FileReaderBase is not move-assignable.
void	init (std::shared_ptr< appfwk::ConfigurationManager > cfg)
virtual std::shared_ptr< snbmodules::FileSourceConcept >	create_source_emulator (const appmodel::DataMoveCallbackConf *cb_conf, std::atomic< bool > &run_marker)=0
void	do_conf (const appfwk::DAQModule::CommandData_t &)
void	do_scrap (const appfwk::DAQModule::CommandData_t &)
void	do_start (const appfwk::DAQModule::CommandData_t &)
void	do_stop (const appfwk::DAQModule::CommandData_t &)
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< snbmodules::FileSourceConcept > >	m_source_emus
std::atomic< bool >	m_run_marker

Detailed Description

Definition at line 46 of file FileReaderBase.hpp.

Constructor & Destructor Documentation

FileReaderBase() [1/3]

dunedaq::snbmodules::FileReaderBase::FileReaderBase ( const std::string & name )

explicit

FileReaderBase Constructor.

Parameters

name	Instance name for this FileReaderBase instance

Definition at line 9 of file FileReaderBase.hxx.

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

~FileReaderBase()

virtual dunedaq::snbmodules::FileReaderBase::~FileReaderBase ( )

inlinevirtual

Definition at line 54 of file FileReaderBase.hpp.

{}

FileReaderBase() [2/3]

dunedaq::snbmodules::FileReaderBase::FileReaderBase ( const FileReaderBase & )

delete

FileReaderBase is not copy-constructible.

FileReaderBase() [3/3]

dunedaq::snbmodules::FileReaderBase::FileReaderBase ( FileReaderBase && )

delete

FileReaderBase is not move-constructible.

Member Function Documentation

create_source_emulator()

virtual std::shared_ptr< snbmodules::FileSourceConcept > dunedaq::snbmodules::FileReaderBase::create_source_emulator ( const appmodel::DataMoveCallbackConf * cb_conf, std::atomic< bool > & run_marker )

pure virtual

do_conf()

void dunedaq::snbmodules::FileReaderBase::do_conf

(

const appfwk::DAQModule::CommandData_t &

)

Definition at line 49 of file FileReaderBase.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->streams()) {
        streams[stream->get_source_id()] = stream;
      }
    }
 
    for (const auto& cb : cfg->get_raw_data_callbacks()) {
      if (m_source_emus.find(cb->UID()) == m_source_emus.end()) {
        TLOG() << "Cannot find queue: " << cb->UID() << std::endl;
        throw datahandlinglibs::GenericConfigurationError(ERS_HERE, "Cannot find queue: " + cb->UID());
      }
      if (m_source_emus[cb->UID()]->is_configured()) {
        TLOG() << "Emulator for queue name " << cb->UID() << " was already configured";
        throw datahandlinglibs::GenericConfigurationError(ERS_HERE, "Emulator configured twice: " + cb->UID());
      }
      m_source_emus[cb->UID()]->set_sender(cb);
      m_source_emus[cb->UID()]->conf(streams[cb->get_source_id()],
                                            cfg->get_configuration()->get_snb_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::snbmodules::FileReaderBase::do_scrap

(

const appfwk::DAQModule::CommandData_t &

args

)

Definition at line 95 of file FileReaderBase.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::snbmodules::FileReaderBase::do_start

(

const appfwk::DAQModule::CommandData_t &

args

)

Definition at line 110 of file FileReaderBase.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::snbmodules::FileReaderBase::do_stop

(

const appfwk::DAQModule::CommandData_t &

args

)

Definition at line 126 of file FileReaderBase.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::snbmodules::FileReaderBase::get_fcr_name ( )

inline

Definition at line 73 of file FileReaderBase.hpp.

{ return m_name; }

init()

void dunedaq::snbmodules::FileReaderBase::init

(

std::shared_ptr< appfwk::ConfigurationManager >

cfg

)

Definition at line 17 of file FileReaderBase.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 cb : ini->get_raw_data_callbacks()) {
 
      try {
        if (m_source_emus.find(cb->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[cb->UID()] = create_source_emulator(cb, m_run_marker);
        if (m_source_emus[cb->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);
      } catch (const ers::Issue& excpt) {
        throw datahandlinglibs::ResourceQueueError(ERS_HERE, cb->UID(), get_fcr_name(), excpt);
      }
    }
  }
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS)
    << get_fcr_name() << ": Exiting init() method";
}

operator=() [1/2]

FileReaderBase & dunedaq::snbmodules::FileReaderBase::operator= ( const FileReaderBase & )

delete

FileReaderBase is not copy-assignable.

operator=() [2/2]

FileReaderBase & dunedaq::snbmodules::FileReaderBase::operator= ( FileReaderBase && )

delete

FileReaderBase is not move-assignable.

Member Data Documentation

m_cfg

std::shared_ptr<appfwk::ConfigurationManager> dunedaq::snbmodules::FileReaderBase::m_cfg

private

Definition at line 79 of file FileReaderBase.hpp.

m_configured

bool dunedaq::snbmodules::FileReaderBase::m_configured

private

Definition at line 77 of file FileReaderBase.hpp.

m_name

std::string dunedaq::snbmodules::FileReaderBase::m_name

private

Definition at line 78 of file FileReaderBase.hpp.

m_run_marker

std::atomic<bool> dunedaq::snbmodules::FileReaderBase::m_run_marker

private

Definition at line 84 of file FileReaderBase.hpp.

m_source_emus

std::map<std::string, std::shared_ptr<snbmodules::FileSourceConcept> > dunedaq::snbmodules::FileReaderBase::m_source_emus

private

Definition at line 81 of file FileReaderBase.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/snbmodules/include/snbmodules/readout/FileReaderBase.hpp
• /github/workspace/dunedaq/sourcecode/snbmodules/include/snbmodules/readout/detail/FileReaderBase.hxx