dunedaq::datahandlinglibs::RawDataHandlerBase Class Reference

#include <RawDataHandlerBase.hpp>

Public Member Functions
	RawDataHandlerBase (const std::string &name)
	RawDataHandlerBase Constructor.
virtual	~RawDataHandlerBase ()
	RawDataHandlerBase (const RawDataHandlerBase &)=delete
	RawDataHandlerBase is not copy-constructible.
RawDataHandlerBase &	operator= (const RawDataHandlerBase &)=delete
	RawDataHandlerBase is not copy-assignable.
	RawDataHandlerBase (RawDataHandlerBase &&)=delete
	RawDataHandlerBase is not move-constructible.
RawDataHandlerBase &	operator= (RawDataHandlerBase &&)=delete
	RawDataHandlerBase is not move-assignable.
void	init (std::shared_ptr< appfwk::ConfigurationManager > cfg)
virtual std::shared_ptr< dunedaq::datahandlinglibs::DataHandlingConcept >	create_readout (const appmodel::DataHandlerModule *modconf, 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 &)
void	do_record (const nlohmann::json &)
std::string	get_dlh_name ()

Private Attributes
bool	m_configured
daqdataformats::run_number_t	m_run_number
std::string	m_name
std::shared_ptr< datahandlinglibs::DataHandlingConcept >	m_readout_impl
std::atomic< bool >	m_run_marker

Detailed Description

Definition at line 34 of file RawDataHandlerBase.hpp.

Constructor & Destructor Documentation

RawDataHandlerBase() [1/3]

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

explicit

RawDataHandlerBase Constructor.

Parameters

name	Instance name for this RawDataHandlerBase instance

Definition at line 4 of file RawDataHandlerBase.hxx.

  : m_configured(false)
  , m_name(name)
  , m_readout_impl(nullptr)
  , m_run_marker{ false }
{
/*
  register_command("conf", &RawDataHandlerBase::do_conf);
  register_command("scrap", &RawDataHandlerBase::do_scrap);
  register_command("start", &RawDataHandlerBase::do_start);
  register_command("stop_trigger_sources", &RawDataHandlerBase::do_stop);
  register_command("record", &RawDataHandlerBase::do_record);
*/
}

~RawDataHandlerBase()

virtual dunedaq::datahandlinglibs::RawDataHandlerBase::~RawDataHandlerBase ( )

inlinevirtual

Definition at line 42 of file RawDataHandlerBase.hpp.

{}

RawDataHandlerBase() [2/3]

dunedaq::datahandlinglibs::RawDataHandlerBase::RawDataHandlerBase ( const RawDataHandlerBase & )

delete

RawDataHandlerBase is not copy-constructible.

RawDataHandlerBase() [3/3]

dunedaq::datahandlinglibs::RawDataHandlerBase::RawDataHandlerBase ( RawDataHandlerBase && )

delete

RawDataHandlerBase is not move-constructible.

Member Function Documentation

create_readout()

virtual std::shared_ptr< dunedaq::datahandlinglibs::DataHandlingConcept > dunedaq::datahandlinglibs::RawDataHandlerBase::create_readout ( const appmodel::DataHandlerModule * modconf, std::atomic< bool > & run_marker )

pure virtual

do_conf()

void dunedaq::datahandlinglibs::RawDataHandlerBase::do_conf

(

const nlohmann::json &

args

)

Definition at line 45 of file RawDataHandlerBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Entering do_conf() method";
  m_readout_impl->conf(args);
  m_configured = true;
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Exiting do_conf() method";
}

do_record()

void dunedaq::datahandlinglibs::RawDataHandlerBase::do_record

(

const nlohmann::json &

args

)

Definition at line 84 of file RawDataHandlerBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Entering do_issue_recording() method";
  m_readout_impl->record(args);
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Exiting do_issue_recording() method";
}

do_scrap()

void dunedaq::datahandlinglibs::RawDataHandlerBase::do_scrap

(

const nlohmann::json &

args

)

Definition at line 54 of file RawDataHandlerBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Entering do_scrap() method";
  m_readout_impl->scrap(args);
  m_configured = false;
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Exiting do_scrap() method";
}

do_start()

void dunedaq::datahandlinglibs::RawDataHandlerBase::do_start

(

const nlohmann::json &

args

)

Definition at line 62 of file RawDataHandlerBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Entering do_start() method";
  m_run_marker.store(true);
  m_readout_impl->start(args);
  rcif::cmd::StartParams start_params = args.get<rcif::cmd::StartParams>();
  m_run_number = start_params.run;
  TLOG() << get_dlh_name() << " successfully started for run number " << m_run_number;
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Exiting do_start() method";
}

do_stop()

void dunedaq::datahandlinglibs::RawDataHandlerBase::do_stop

(

const nlohmann::json &

args

)

Definition at line 74 of file RawDataHandlerBase.hxx.

{
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Entering do_stop() method";
  m_run_marker.store(false);
  m_readout_impl->stop(args);
  TLOG() << get_dlh_name() << " successfully stopped for run number " << m_run_number;
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Exiting do_stop() method";
}

get_dlh_name()

std::string dunedaq::datahandlinglibs::RawDataHandlerBase::get_dlh_name ( )

inline

Definition at line 62 of file RawDataHandlerBase.hpp.

{ return m_name; }

init()

void dunedaq::datahandlinglibs::RawDataHandlerBase::init

(

std::shared_ptr< appfwk::ConfigurationManager >

cfg

)

Definition at line 21 of file RawDataHandlerBase.hxx.

{
  
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Entering init() method";
  const appmodel::DataHandlerModule* modconf = cfg->get_dal<appmodel::DataHandlerModule>(get_dlh_name());
  if(modconf == nullptr) {
    throw dunedaq::datahandlinglibs::FailedReadoutInitialization(ERS_HERE, get_dlh_name(), "not a DataHandlerModule");
  }
  m_readout_impl = create_readout(modconf, m_run_marker);
  if (m_readout_impl == nullptr) {
    TLOG() << get_dlh_name() << "Initialize readout implementation FAILED! "
           << "Failed to find specialization for given queue setup!";
    throw dunedaq::datahandlinglibs::FailedReadoutInitialization(ERS_HERE, get_dlh_name(), ""); // 4 json ident
  }
  TLOG_DEBUG(dunedaq::datahandlinglibs::logging::TLVL_ENTER_EXIT_METHODS) << get_dlh_name() << ": Exiting init() method";
}

operator=() [1/2]

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

delete

RawDataHandlerBase is not copy-assignable.

operator=() [2/2]

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

delete

RawDataHandlerBase is not move-assignable.

Member Data Documentation

m_configured

bool dunedaq::datahandlinglibs::RawDataHandlerBase::m_configured

private

Definition at line 67 of file RawDataHandlerBase.hpp.

m_name

std::string dunedaq::datahandlinglibs::RawDataHandlerBase::m_name

private

Definition at line 71 of file RawDataHandlerBase.hpp.

m_readout_impl

std::shared_ptr<datahandlinglibs::DataHandlingConcept> dunedaq::datahandlinglibs::RawDataHandlerBase::m_readout_impl

private

Definition at line 74 of file RawDataHandlerBase.hpp.

m_run_marker

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

private

Definition at line 77 of file RawDataHandlerBase.hpp.

m_run_number

daqdataformats::run_number_t dunedaq::datahandlinglibs::RawDataHandlerBase::m_run_number

private

Definition at line 68 of file RawDataHandlerBase.hpp.

---

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

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