#include <NP02ReadoutApplication.hpp>

Inheritance diagram for dunedaq::appmodel::NP02ReadoutApplication:

Collaboration diagram for dunedaq::appmodel::NP02ReadoutApplication:

Public Member Functions
virtual void	print (unsigned int offset, bool print_header, std::ostream &s) const
	Print details of the NP02ReadoutApplication object.

virtual std::vector< const dunedaq::conffwk::DalObject * >	get (const std::string &name, bool upcast_unregistered=true) const
	Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject pointers.

void	generate_modules (std::shared_ptr< appmodel::ConfigurationHelper >) const override

virtual void	print (unsigned int offset, bool print_header, std::ostream &s) const
	Print details of the NP02ReadoutApplication object.

virtual std::vector< const dunedaq::conffwk::DalObject * >	get (const std::string &name, bool upcast_unregistered=true) const
	Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject pointers.

void	generate_modules (std::shared_ptr< appmodel::ConfigurationHelper >) const override

Public Member Functions inherited from dunedaq::appmodel::ReadoutApplication
const std::string &	get_application_name () const
	Get "application_name" attribute value.

void	set_application_name (const std::string &value)
	Set "application_name" attribute value.

bool	get_tp_generation_enabled () const
	Get "tp_generation_enabled" attribute value.

void	set_tp_generation_enabled (bool value)
	Set "tp_generation_enabled" attribute value.

bool	get_ta_generation_enabled () const
	Get "ta_generation_enabled" attribute value.

void	set_ta_generation_enabled (bool value)
	Set "ta_generation_enabled" attribute value.

const std::vector< const dunedaq::appmodel::SourceIDConf * > &	get_tp_source_ids () const
	Get "tp_source_ids" relationship value.

void	set_tp_source_ids (const std::vector< const dunedaq::appmodel::SourceIDConf * > &value)
	Set "tp_source_ids" relationship value.

const dunedaq::appmodel::RoHwConfig *	get_uses () const
	Get "uses" relationship value. Configuration of the host hardware resources used by this application.

void	set_uses (const dunedaq::appmodel::RoHwConfig *value)
	Set "uses" relationship value. Configuration of the host hardware resources used by this application.

const dunedaq::appmodel::DataHandlerConf *	get_link_handler () const
	Get "link_handler" relationship value.

void	set_link_handler (const dunedaq::appmodel::DataHandlerConf *value)
	Set "link_handler" relationship value.

const dunedaq::appmodel::DataHandlerConf *	get_tp_handler () const
	Get "tp_handler" relationship value.

void	set_tp_handler (const dunedaq::appmodel::DataHandlerConf *value)
	Set "tp_handler" relationship value.

const dunedaq::appmodel::DataReaderConf *	get_data_reader () const
	Get "data_reader" relationship value.

void	set_data_reader (const dunedaq::appmodel::DataReaderConf *value)
	Set "data_reader" relationship value.

const dunedaq::appmodel::DataRecorderConf *	get_data_recorder () const
	Get "data_recorder" relationship value.

void	set_data_recorder (const dunedaq::appmodel::DataRecorderConf *value)
	Set "data_recorder" relationship value.

const dunedaq::appmodel::FragmentAggregatorConf *	get_fragment_aggregator () const
	Get "fragment_aggregator" relationship value.

void	set_fragment_aggregator (const dunedaq::appmodel::FragmentAggregatorConf *value)
	Set "fragment_aggregator" relationship value.

const std::vector< const dunedaq::confmodel::DetectorToDaqConnection * > &	get_detector_connections () const
	Get "detector_connections" relationship value. The list of detector channels to be read out by this readout application.

void	set_detector_connections (const std::vector< const dunedaq::confmodel::DetectorToDaqConnection * > &value)
	Set "detector_connections" relationship value. The list of detector channels to be read out by this readout application.

const dunedaq::appmodel::DataMoveCallbackDescriptor *	get_callback_desc () const
	Get "callback_desc" relationship value.

void	set_callback_desc (const dunedaq::appmodel::DataMoveCallbackDescriptor *value)
	Set "callback_desc" relationship value.

void	generate_modules (std::shared_ptr< appmodel::ConfigurationHelper >) const override

virtual std::vector< const Resource * >	contained_resources () const override

const std::string &	get_application_name () const
	Get "application_name" attribute value.

void	set_application_name (const std::string &value)
	Set "application_name" attribute value.

bool	get_tp_generation_enabled () const
	Get "tp_generation_enabled" attribute value.

void	set_tp_generation_enabled (bool value)
	Set "tp_generation_enabled" attribute value.

bool	get_ta_generation_enabled () const
	Get "ta_generation_enabled" attribute value.

void	set_ta_generation_enabled (bool value)
	Set "ta_generation_enabled" attribute value.

const std::vector< const dunedaq::appmodel::SourceIDConf * > &	get_tp_source_ids () const
	Get "tp_source_ids" relationship value.

void	set_tp_source_ids (const std::vector< const dunedaq::appmodel::SourceIDConf * > &value)
	Set "tp_source_ids" relationship value.

const dunedaq::appmodel::RoHwConfig *	get_uses () const
	Get "uses" relationship value. Configuration of the host hardware resources used by this application.

void	set_uses (const dunedaq::appmodel::RoHwConfig *value)
	Set "uses" relationship value. Configuration of the host hardware resources used by this application.

const dunedaq::appmodel::DataHandlerConf *	get_link_handler () const
	Get "link_handler" relationship value.

void	set_link_handler (const dunedaq::appmodel::DataHandlerConf *value)
	Set "link_handler" relationship value.

const dunedaq::appmodel::DataHandlerConf *	get_tp_handler () const
	Get "tp_handler" relationship value.

void	set_tp_handler (const dunedaq::appmodel::DataHandlerConf *value)
	Set "tp_handler" relationship value.

const dunedaq::appmodel::DataReaderConf *	get_data_reader () const
	Get "data_reader" relationship value.

void	set_data_reader (const dunedaq::appmodel::DataReaderConf *value)
	Set "data_reader" relationship value.

const dunedaq::appmodel::DataRecorderConf *	get_data_recorder () const
	Get "data_recorder" relationship value.

void	set_data_recorder (const dunedaq::appmodel::DataRecorderConf *value)
	Set "data_recorder" relationship value.

const dunedaq::appmodel::FragmentAggregatorConf *	get_fragment_aggregator () const
	Get "fragment_aggregator" relationship value.

void	set_fragment_aggregator (const dunedaq::appmodel::FragmentAggregatorConf *value)
	Set "fragment_aggregator" relationship value.

const std::vector< const dunedaq::confmodel::DetectorToDaqConnection * > &	get_detector_connections () const
	Get "detector_connections" relationship value. The list of detector channels to be read out by this readout application.

void	set_detector_connections (const std::vector< const dunedaq::confmodel::DetectorToDaqConnection * > &value)
	Set "detector_connections" relationship value. The list of detector channels to be read out by this readout application.

const dunedaq::appmodel::DataMoveCallbackDescriptor *	get_callback_desc () const
	Get "callback_desc" relationship value.

void	set_callback_desc (const dunedaq::appmodel::DataMoveCallbackDescriptor *value)
	Set "callback_desc" relationship value.

void	generate_modules (std::shared_ptr< appmodel::ConfigurationHelper >) const override

virtual std::vector< const Resource * >	contained_resources () const override

Public Member Functions inherited from dunedaq::appmodel::SmartDaqApplication
const dunedaq::appmodel::SourceIDConf *	get_source_id () const
	Get "source_id" relationship value.

void	set_source_id (const dunedaq::appmodel::SourceIDConf *value)
	Set "source_id" relationship value.

const std::vector< const dunedaq::appmodel::QueueConnectionRule * > &	get_queue_rules () const
	Get "queue_rules" relationship value.

void	set_queue_rules (const std::vector< const dunedaq::appmodel::QueueConnectionRule * > &value)
	Set "queue_rules" relationship value.

const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > &	get_network_rules () const
	Get "network_rules" relationship value.

void	set_network_rules (const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > &value)
	Set "network_rules" relationship value.

const dunedaq::appmodel::SourceIDConf *	get_source_id () const
	Get "source_id" relationship value.

void	set_source_id (const dunedaq::appmodel::SourceIDConf *value)
	Set "source_id" relationship value.

const std::vector< const dunedaq::appmodel::QueueConnectionRule * > &	get_queue_rules () const
	Get "queue_rules" relationship value.

void	set_queue_rules (const std::vector< const dunedaq::appmodel::QueueConnectionRule * > &value)
	Set "queue_rules" relationship value.

const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > &	get_network_rules () const
	Get "network_rules" relationship value.

void	set_network_rules (const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > &value)
	Set "network_rules" relationship value.

Public Member Functions inherited from dunedaq::confmodel::DaqApplication
const std::string &	get_application_name () const
	Get "application_name" attribute value. Name of the application binary to run.

void	set_application_name (const std::string &value)
	Set "application_name" attribute value. Name of the application binary to run.

const std::vector< const dunedaq::confmodel::DaqModule * > &	get_modules () const
	Get "modules" relationship value.

void	set_modules (const std::vector< const dunedaq::confmodel::DaqModule * > &value)
	Set "modules" relationship value.

const std::vector< const dunedaq::confmodel::ActionPlan * > &	get_action_plans () const
	Get "action_plans" relationship value.

void	set_action_plans (const std::vector< const dunedaq::confmodel::ActionPlan * > &value)
	Set "action_plans" relationship value.

std::set< const dunedaq::confmodel::HostComponent * >	get_used_hostresources () const

const std::vector< std::string >	construct_commandline_parameters (const conffwk::Configuration &confdb, const dunedaq::confmodel::Session *session) const

const std::string &	get_application_name () const
	Get "application_name" attribute value. Name of the application binary to run.

void	set_application_name (const std::string &value)
	Set "application_name" attribute value. Name of the application binary to run.

const std::vector< const dunedaq::confmodel::DaqModule * > &	get_modules () const
	Get "modules" relationship value.

void	set_modules (const std::vector< const dunedaq::confmodel::DaqModule * > &value)
	Set "modules" relationship value.

const std::vector< const dunedaq::confmodel::ActionPlan * > &	get_action_plans () const
	Get "action_plans" relationship value.

void	set_action_plans (const std::vector< const dunedaq::confmodel::ActionPlan * > &value)
	Set "action_plans" relationship value.

std::set< const dunedaq::confmodel::HostComponent * >	get_used_hostresources () const

const std::vector< std::string >	construct_commandline_parameters (const conffwk::Configuration &confdb, const dunedaq::confmodel::Session *session) const

Public Member Functions inherited from dunedaq::confmodel::Application
const std::string &	get_application_name () const
	Get "application_name" attribute value. Name of the application binary to run.

void	set_application_name (const std::string &value)
	Set "application_name" attribute value. Name of the application binary to run.

const std::vector< std::string > &	get_commandline_parameters () const
	Get "commandline_parameters" attribute value. command line parameters to add when starting the application.

void	set_commandline_parameters (const std::vector< std::string > &value)
	Set "commandline_parameters" attribute value. command line parameters to add when starting the application.

const std::string &	get_log_path () const
	Get "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.

void	set_log_path (const std::string &value)
	Set "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.

const std::vector< const dunedaq::confmodel::VariableBase * > &	get_application_environment () const
	Get "application_environment" relationship value. Define process environment for this application.

void	set_application_environment (const std::vector< const dunedaq::confmodel::VariableBase * > &value)
	Set "application_environment" relationship value. Define process environment for this application.

const dunedaq::confmodel::VirtualHost *	get_runs_on () const
	Get "runs_on" relationship value. VirtualHost to run this application on.

void	set_runs_on (const dunedaq::confmodel::VirtualHost *value)
	Set "runs_on" relationship value. VirtualHost to run this application on.

const std::vector< const dunedaq::confmodel::Service * > &	get_exposes_service () const
	Get "exposes_service" relationship value. Services exposed i.e. provided by this application.

void	set_exposes_service (const std::vector< const dunedaq::confmodel::Service * > &value)
	Set "exposes_service" relationship value. Services exposed i.e. provided by this application.

const dunedaq::confmodel::OpMonConf *	get_opmon_conf () const
	Get "opmon_conf" relationship value. description of the monitoring behaviour in the application.

void	set_opmon_conf (const dunedaq::confmodel::OpMonConf *value)
	Set "opmon_conf" relationship value. description of the monitoring behaviour in the application.

const std::vector< std::string >	parse_commandline_parameters () const

const std::string &	get_application_name () const
	Get "application_name" attribute value. Name of the application binary to run.

void	set_application_name (const std::string &value)
	Set "application_name" attribute value. Name of the application binary to run.

const std::vector< std::string > &	get_commandline_parameters () const
	Get "commandline_parameters" attribute value. command line parameters to add when starting the application.

void	set_commandline_parameters (const std::vector< std::string > &value)
	Set "commandline_parameters" attribute value. command line parameters to add when starting the application.

const std::string &	get_log_path () const
	Get "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.

void	set_log_path (const std::string &value)
	Set "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.

const std::vector< const dunedaq::confmodel::VariableBase * > &	get_application_environment () const
	Get "application_environment" relationship value. Define process environment for this application.

void	set_application_environment (const std::vector< const dunedaq::confmodel::VariableBase * > &value)
	Set "application_environment" relationship value. Define process environment for this application.

const dunedaq::confmodel::VirtualHost *	get_runs_on () const
	Get "runs_on" relationship value. VirtualHost to run this application on.

void	set_runs_on (const dunedaq::confmodel::VirtualHost *value)
	Set "runs_on" relationship value. VirtualHost to run this application on.

const std::vector< const dunedaq::confmodel::Service * > &	get_exposes_service () const
	Get "exposes_service" relationship value. Services exposed i.e. provided by this application.

void	set_exposes_service (const std::vector< const dunedaq::confmodel::Service * > &value)
	Set "exposes_service" relationship value. Services exposed i.e. provided by this application.

const dunedaq::confmodel::OpMonConf *	get_opmon_conf () const
	Get "opmon_conf" relationship value. description of the monitoring behaviour in the application.

void	set_opmon_conf (const dunedaq::confmodel::OpMonConf *value)
	Set "opmon_conf" relationship value. description of the monitoring behaviour in the application.

const std::vector< std::string >	parse_commandline_parameters () const

Public Member Functions inherited from dunedaq::conffwk::DalObject
const std::string &	UID () const noexcept

const std::string &	class_name () const noexcept

bool	castable (const std::string &target) const noexcept

bool	castable (const std::string *target) const noexcept

template<class TARGET >
const TARGET *	cast () const noexcept
	Casts object to different class.

std::string	full_name () const noexcept

const ConfigObject &	config_object () const

DalRegistry &	registry () const noexcept

Configuration &	configuration () const noexcept

void	unread ()

void	set (const ConfigObject &o) noexcept

void	move (const std::string &at)

void	rename (const std::string &new_id)

void	p_hdr (std::ostream &s, unsigned int indent, const std::string &cl, const char *nm=nullptr) const
	print object headers

std::ostream &	print_object (std::ostream &s) const
	print object details

void	throw_init_ex (dunedaq::conffwk::Exception &ex)
	throw object initialisation exception (i.e.

Public Member Functions inherited from dunedaq::confmodel::ResourceSetDisableAND
bool	compute_disabled_state (const std::set< std::string > &disabled) const final

bool	compute_disabled_state (const std::set< std::string > &disabled) const final

Public Member Functions inherited from dunedaq::confmodel::ResourceSet
Public Member Functions inherited from dunedaq::confmodel::Resource
void	parents (const dunedaq::confmodel::Session &session, std::list< std::vector< const dunedaq::confmodel::Resource * > > &parents) const

bool	is_disabled (const dunedaq::confmodel::ResourceTree &session) const

void	parents (const dunedaq::confmodel::Session &session, std::list< std::vector< const dunedaq::confmodel::Resource * > > &parents) const

bool	is_disabled (const dunedaq::confmodel::ResourceTree &session) const

Static Public Attributes
static const std::string &	s_class_name

Static Public Attributes inherited from dunedaq::appmodel::ReadoutApplication
static const std::string &	s_class_name

static const std::string	s_application_name = "application_name"

static const std::string	s_tp_generation_enabled = "tp_generation_enabled"

static const std::string	s_ta_generation_enabled = "ta_generation_enabled"

static const std::string	s_tp_source_ids = "tp_source_ids"

static const std::string	s_uses = "uses"

static const std::string	s_link_handler = "link_handler"

static const std::string	s_tp_handler = "tp_handler"

static const std::string	s_data_reader = "data_reader"

static const std::string	s_data_recorder = "data_recorder"

static const std::string	s_fragment_aggregator = "fragment_aggregator"

static const std::string	s_detector_connections = "detector_connections"

static const std::string	s_callback_desc = "callback_desc"

Static Public Attributes inherited from dunedaq::appmodel::SmartDaqApplication
static const std::string &	s_class_name

static const std::string	s_source_id = "source_id"

static const std::string	s_queue_rules = "queue_rules"

static const std::string	s_network_rules = "network_rules"

Static Public Attributes inherited from dunedaq::confmodel::DaqApplication
static const std::string &	s_class_name

static const std::string	s_application_name = "application_name"

static const std::string	s_modules = "modules"

static const std::string	s_action_plans = "action_plans"

Static Public Attributes inherited from dunedaq::confmodel::Application
static const std::string &	s_class_name

static const std::string	s_application_name = "application_name"

static const std::string	s_commandline_parameters = "commandline_parameters"

static const std::string	s_log_path = "log_path"

static const std::string	s_application_environment = "application_environment"

static const std::string	s_runs_on = "runs_on"

static const std::string	s_exposes_service = "exposes_service"

static const std::string	s_opmon_conf = "opmon_conf"

Static Public Attributes inherited from dunedaq::confmodel::ResourceSetDisableAND
static const std::string &	s_class_name

Static Public Attributes inherited from dunedaq::confmodel::ResourceSet
static const std::string &	s_class_name

Static Public Attributes inherited from dunedaq::confmodel::Resource
static const std::string &	s_class_name

Protected Member Functions
	NP02ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~NP02ReadoutApplication () noexcept

virtual void	init (bool init_children)

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

	NP02ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~NP02ReadoutApplication () noexcept

virtual void	init (bool init_children)

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

Protected Member Functions inherited from dunedaq::appmodel::ReadoutApplication
	ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~ReadoutApplication () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

	ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~ReadoutApplication () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

Protected Member Functions inherited from dunedaq::appmodel::SmartDaqApplication
	SmartDaqApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~SmartDaqApplication () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

	SmartDaqApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~SmartDaqApplication () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

Protected Member Functions inherited from dunedaq::confmodel::DaqApplication
	DaqApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~DaqApplication () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

	DaqApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~DaqApplication () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

Protected Member Functions inherited from dunedaq::confmodel::Application
	Application (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~Application () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

	Application (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~Application () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

Protected Member Functions inherited from dunedaq::conffwk::DalObject
	DalObject (DalRegistry &db, const ConfigObject &o) noexcept

virtual	~DalObject ()

void	clear () noexcept

void	check () const

bool	is_deleted () const

void	increment_created () noexcept

void	increment_read () noexcept

void	check_init () const
	Check and initialize object if necessary.

template<typename T >
void	_set_object (const std::string &name, const T *value)
	Helper method for generated set single-value relationship methods.

template<typename T >
void	_set_objects (const std::string &name, const std::vector< const T * > &value)
	Helper method for generated set multi-value relationship methods.

bool	get_rel_objects (const std::string &name, bool upcast_unregistered, std::vector< const DalObject * > &objs) const
	Read relationship values as DAL objects using DAL factory.

bool	get_algo_objects (const std::string &name, std::vector< const DalObject * > &objs) const
	Run algorithm and return result as DAL objects using DAL factory.

Protected Member Functions inherited from dunedaq::confmodel::ResourceSetDisableAND
	ResourceSetDisableAND (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~ResourceSetDisableAND () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

	ResourceSetDisableAND (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~ResourceSetDisableAND () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

Protected Member Functions inherited from dunedaq::confmodel::ResourceSet
	ResourceSet (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~ResourceSet () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

	ResourceSet (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~ResourceSet () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

Protected Member Functions inherited from dunedaq::confmodel::Resource
	Resource (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~Resource () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

	Resource (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept

virtual	~Resource () noexcept

bool	get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const

Friends
class	conffwk::Configuration

class	conffwk::DalObject

class	conffwk::DalFactory

class	conffwk::DalRegistry

Additional Inherited Members
Static Public Member Functions inherited from dunedaq::appmodel::ReadoutApplication
static const std::string &	__get_application_name_str () noexcept

static const std::string &	__get_tp_generation_enabled_str () noexcept

static const std::string &	__get_ta_generation_enabled_str () noexcept

static const std::string &	__get_tp_source_ids_str () noexcept

static const std::string &	__get_uses_str () noexcept

static const std::string &	__get_link_handler_str () noexcept

static const std::string &	__get_tp_handler_str () noexcept

static const std::string &	__get_data_reader_str () noexcept

static const std::string &	__get_data_recorder_str () noexcept

static const std::string &	__get_fragment_aggregator_str () noexcept

static const std::string &	__get_detector_connections_str () noexcept

static const std::string &	__get_callback_desc_str () noexcept

static const std::string &	__get_application_name_str () noexcept

static const std::string &	__get_tp_generation_enabled_str () noexcept

static const std::string &	__get_ta_generation_enabled_str () noexcept

static const std::string &	__get_tp_source_ids_str () noexcept

static const std::string &	__get_uses_str () noexcept

static const std::string &	__get_link_handler_str () noexcept

static const std::string &	__get_tp_handler_str () noexcept

static const std::string &	__get_data_reader_str () noexcept

static const std::string &	__get_data_recorder_str () noexcept

static const std::string &	__get_fragment_aggregator_str () noexcept

static const std::string &	__get_detector_connections_str () noexcept

static const std::string &	__get_callback_desc_str () noexcept

Static Public Member Functions inherited from dunedaq::appmodel::SmartDaqApplication
static const std::string &	__get_source_id_str () noexcept

static const std::string &	__get_queue_rules_str () noexcept

static const std::string &	__get_network_rules_str () noexcept

static const std::string &	__get_source_id_str () noexcept

static const std::string &	__get_queue_rules_str () noexcept

static const std::string &	__get_network_rules_str () noexcept

Static Public Member Functions inherited from dunedaq::confmodel::DaqApplication
static const std::string &	__get_application_name_str () noexcept

static const std::string &	__get_modules_str () noexcept

static const std::string &	__get_action_plans_str () noexcept

static const std::string &	__get_application_name_str () noexcept

static const std::string &	__get_modules_str () noexcept

static const std::string &	__get_action_plans_str () noexcept

Static Public Member Functions inherited from dunedaq::confmodel::Application
static const std::string &	__get_application_name_str () noexcept

static const std::string &	__get_commandline_parameters_str () noexcept

static const std::string &	__get_log_path_str () noexcept

static const std::string &	__get_application_environment_str () noexcept

static const std::string &	__get_runs_on_str () noexcept

static const std::string &	__get_exposes_service_str () noexcept

static const std::string &	__get_opmon_conf_str () noexcept

static const std::string &	__get_application_name_str () noexcept

static const std::string &	__get_commandline_parameters_str () noexcept

static const std::string &	__get_log_path_str () noexcept

static const std::string &	__get_application_environment_str () noexcept

static const std::string &	__get_runs_on_str () noexcept

static const std::string &	__get_exposes_service_str () noexcept

static const std::string &	__get_opmon_conf_str () noexcept

Static Public Member Functions inherited from dunedaq::conffwk::DalObject
static void	p_null (std::ostream &s)
	print "(null)"

static void	p_rm (std::ostream &s)
	print "(deleted object)"

static void	p_error (std::ostream &s, dunedaq::conffwk::Exception &ex)
	print error text

static void	throw_get_ex (const std::string &what, const std::string &class_name, const DalObject *obj)
	throw exception in generated get method (i.e.

static bool	is_null (const DalObject *ref) noexcept
	check a pointer on DAL object is null

Protected Attributes inherited from dunedaq::conffwk::DalObject
std::mutex	m_mutex
	Used to protect changes of DAL object.

bool	p_was_read
	is true, if the object was read

DalRegistry &	p_registry
	Configuration object.

ConfigObject	p_obj
	Config object used by given template object.

std::string	p_UID
	Is used for template objects (see dqm_conffwk)

Detailed Description

Definition at line 23 of file NP02ReadoutApplication.hpp.

Constructor & Destructor Documentation

◆ NP02ReadoutApplication() [1/2]

dunedaq::appmodel::NP02ReadoutApplication::NP02ReadoutApplication	(	conffwk::DalRegistry &	db,
		const conffwk::ConfigObject &	obj )

protectednoexcept

Definition at line 26 of file NP02ReadoutApplication.cpp.

                                                                                                                :
      dunedaq::conffwk::DalObject(db, o),
      ReadoutApplication(db, o)
 
    {
      ;
    }

◆ ~NP02ReadoutApplication() [1/2]

dunedaq::appmodel::NP02ReadoutApplication::~NP02ReadoutApplication ( )

protectedvirtualnoexcept

Definition at line 62 of file NP02ReadoutApplication.cpp.

63 {

64 }

◆ NP02ReadoutApplication() [2/2]

dunedaq::appmodel::NP02ReadoutApplication::NP02ReadoutApplication	(	conffwk::DalRegistry &	db,
		const conffwk::ConfigObject &	obj )

protectednoexcept

◆ ~NP02ReadoutApplication() [2/2]

virtual dunedaq::appmodel::NP02ReadoutApplication::~NP02ReadoutApplication ( )

protectedvirtualnoexcept

Member Function Documentation

◆ generate_modules() [1/2]

void dunedaq::appmodel::NP02ReadoutApplication::generate_modules ( std::shared_ptr< appmodel::ConfigurationHelper > helper ) const

overridevirtual

Generate daq module dal objects for streams of thie ReadoutApplication on the fly

Implements dunedaq::appmodel::SmartDaqApplication.

Definition at line 73 of file NP02ReadoutApplication.cpp.

{
 
  TLOG_DEBUG(6) << "Generating modules for application " << this->UID();
 
  ConfigObjectFactory obj_fac(this);
 
  //
  // Extract basic configuration objects
  //
 
  // Data reader
  auto reader_conf = get_data_reader();
  if (reader_conf == 0) {
    throw(BadConf(ERS_HERE, "No DataReaderModule configuration given"));
  }
  std::string reader_class = reader_conf->get_template_for();
 
  // Link handler
  auto dlh_conf = get_link_handler();
  // What is template for?
  auto dlh_class = dlh_conf->get_template_for();
 
  auto tph_conf = get_tp_handler();
  if (tph_conf==nullptr && get_tp_generation_enabled()) {
    throw(BadConf(ERS_HERE, "TP generation is enabled but there is no TP data handler configuration"));
  }
 
  std::string tph_class = "";
  if (tph_conf != nullptr && get_tp_generation_enabled()) {
    tph_class = tph_conf->get_template_for();
  }
 
  //
  // Process the queue rules looking for inputs to our DL/TP handler modules
  //
  const QueueDescriptor* dlh_reqinput_qdesc = nullptr;
  const QueueDescriptor* tp_input_qdesc = nullptr;
  // const QueueDescriptor* tpReqInputQDesc = nullptr;
  const QueueDescriptor* fa_output_qdesc = nullptr;
 
  for (auto rule : get_queue_rules()) {
    auto destination_class = rule->get_destination_class();
    auto data_type = rule->get_descriptor()->get_data_type();
    // Why datahander here?
    if (destination_class == "DataHandlerModule" || destination_class == dlh_class || destination_class == tph_class) {
      if (data_type == "DataRequest") {
        dlh_reqinput_qdesc = rule->get_descriptor();
      } else if ((data_type == "TriggerPrimitive" || data_type == "TriggerPrimitiveVector") && get_tp_generation_enabled()) {
        tp_input_qdesc = rule->get_descriptor();
      }
    } else if (destination_class == "FragmentAggregatorModule") {
      fa_output_qdesc = rule->get_descriptor();
    }
  }
 
  //
  // Process the network rules looking for the Fragment Aggregator and TP handler data reuest inputs
  //
  const NetworkConnectionDescriptor* fa_net_desc = nullptr;
  const NetworkConnectionDescriptor* tp_net_desc = nullptr;
  const NetworkConnectionDescriptor* ta_net_desc = nullptr;
  const NetworkConnectionDescriptor* ts_net_desc = nullptr;
  for (auto rule : get_network_rules()) {
    auto endpoint_class = rule->get_endpoint_class();
    auto data_type = rule->get_descriptor()->get_data_type();
 
    if (endpoint_class == "FragmentAggregatorModule") {
      fa_net_desc = rule->get_descriptor();
    } else if (data_type == "TPSet") {
      tp_net_desc = rule->get_descriptor();
    } else if (data_type == "TriggerActivity") {
      ta_net_desc = rule->get_descriptor();
    } else if (data_type == "TimeSync") {
      ts_net_desc = rule->get_descriptor();
    }
  }
 
  // Create here the Queue on which all data fragments are forwarded to the fragment aggregator
  // and a container for the queues of data request to TP handler and DLH
  if (fa_output_qdesc == nullptr) {
    throw(BadConf(ERS_HERE, "No fragment output queue descriptor given"));
  }
  std::vector<const confmodel::Connection*> req_queues;
  conffwk::ConfigObject frag_queue_obj = obj_fac.create_queue_obj(fa_output_qdesc);
 
  //
  // Get the callback descriptor
  //
  const DataMoveCallbackDescriptor* raw_data_callback_desc = get_callback_desc();
 
  if (raw_data_callback_desc == nullptr) {
    throw(BadConf(ERS_HERE, "No Raw Data Callback descriptor given"));
  }
 
  //
  // Scan Detector 2 DAQ connections to extract sender, receiver and stream information
  //
 
  std::vector<const confmodel::DaqModule*> modules;
 
  // Loop over the detector to daq connections and generate one data reader per connection
  // and the cooresponding datalink handlers
 
  // Collect all streams
  std::vector<std::pair<int16_t, const confmodel::DetectorStream*>> all_enabled_det_streams;
  std::map<uint32_t, const appmodel::DataMoveCallbackConf*> callback_confs_by_sid;
 
  std::vector<const conffwk::ConfigObject*> d2d_conn_objs;
  uint16_t conn_idx = 0;
 
 
  std::set<int16_t> numas;
  for (auto d2d_conn : get_detector_connections()) {
    uint16_t receiver_numa = 0;
 
    // Are we sure?
    if (helper->is_disabled(d2d_conn)) {
      TLOG_DEBUG(7) << "Ignoring disabled DetectorToDaqConnection " << d2d_conn->UID();
      continue;
    }
 
    d2d_conn_objs.push_back(&d2d_conn->config_object());
 
    TLOG_DEBUG(6) << "Processing DetectorToDaqConnection " << d2d_conn->UID();
    // get the readout groups and the interfaces and streams therein; 1 reaout group corresponds to 1 data reader module
 
    if (d2d_conn->senders().empty()) {
      throw(BadConf(ERS_HERE, "DetectorToDaqConnection does not contain sebders or receivers"));
    }
    if (d2d_conn->receiver() == nullptr) {
      throw(BadConf(ERS_HERE, "DetectorToDaqConnection does not contain a receiver"));
    }
 
    // Loop over detector 2 daq connections to find senders and receivers
    auto det_senders = d2d_conn->senders();
    auto det_receiver = d2d_conn->receiver();
 
 
    // Here I want to resolve the type of connection (network, felix, or?)
    // Rules of engagement: if the receiver interface is network or felix, the receivers should be castable to the counterpart
    if (reader_class == "DPDKReaderModule" || reader_class == "SocketReaderModule") {
      if ((reader_class == "DPDKReaderModule" && !det_receiver->cast<appmodel::DPDKReceiver>()) ||
          (reader_class == "SocketReaderModule" && !det_receiver->cast<appmodel::SocketReceiver>())) {
        throw(BadConf(ERS_HERE, fmt::format("{} requires NWDetDataReceiver, found {} of class {}", reader_class, det_receiver->UID(), det_receiver->class_name())));
      }
 
      if (reader_class == "DPDKReaderModule") {
        auto dpdk_reciever = det_receiver->cast<appmodel::DPDKReceiver>();
        receiver_numa = (int16_t)dpdk_reciever->get_uses()->get_numa_id();
      }
 
      bool all_nw_senders = true;
      for (auto s : det_senders) {
        all_nw_senders &= (s->cast<appmodel::NWDetDataSender>() != nullptr);
      }
 
      // Ensure that all senders are compatible with receiver
      if (!all_nw_senders) {
        throw(BadConf(ERS_HERE, "Non-network DetDataSener found with NWreceiver"));
      }
    }
 
    std::vector<const confmodel::DetectorStream*> enabled_det_streams;
    // Loop over senders
    for (auto stream : d2d_conn->streams()) {
 
      // Are we sure?
      if (helper->is_disabled(stream)) {
        TLOG_DEBUG(7) << "Ignoring disabled DetectorStream " << stream->UID();
        continue;
      }
 
      // loop over streams
      all_enabled_det_streams.push_back(std::make_pair(receiver_numa, stream));
      enabled_det_streams.push_back(stream);
      numas.insert(receiver_numa);
    }
 
  }
 
  //-----------------------------------------------------------------
  //
  // Create DataReaderModule object
  //
 
  //
  // Instantiate DataReaderModule of type DPDKReaderModule
  //
 
   // Create the Data reader object
 
    std::string reader_uid(fmt::format("datareader-{}-{}", this->UID(), std::to_string(conn_idx++)));
    TLOG_DEBUG(6) << fmt::format("creating OKS configuration object for Data reader class {} with id {}", reader_class, reader_uid);
    auto reader_obj = obj_fac.create(reader_class, reader_uid);
 
    // Populate configuration and interfaces (leave output queues for later)
    reader_obj.set_obj("configuration", &reader_conf->config_object());
    reader_obj.set_objs("connections", d2d_conn_objs);
 
    // Create the raw data callbacks
    std::vector<const conffwk::ConfigObject*> raw_data_callback_objs;
 
    // Create data queues
    for (auto& [numa, ds] : all_enabled_det_streams) {
      conffwk::ConfigObject callback_obj = obj_fac.create_callback_sid_obj(raw_data_callback_desc, ds->get_source_id());
      const auto* callback_conf = obj_fac.get_dal<DataMoveCallbackConf>(callback_obj.UID());
      raw_data_callback_objs.push_back(&callback_conf->config_object());
      callback_confs_by_sid[ds->get_source_id()] = callback_conf;
    }
 
    reader_obj.set_objs("raw_data_callbacks", raw_data_callback_objs);
 
    modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(reader_obj.UID()));
 
 
 
 
  //-----------------------------------------------------------------
  //
  // Prepare the tp handlers and related queues
  //
  std::vector<std::pair<uint32_t, const confmodel::Connection*>> tp_queues;
 
  if (get_tp_generation_enabled()) {
 
    // Create TP handler object
    auto tph_conf_obj = tph_conf->config_object();
    auto tpsrc_ids = get_tp_source_ids();
 
    if ((tpsrc_ids.size() % 3) > 0) {
      throw(BadConf(ERS_HERE, fmt::format("number of TP source IDs must be a multiple of 3, current amount: {}", tpsrc_ids.size())));
    }
 
    for (auto sid : tpsrc_ids) {
      conffwk::ConfigObject tp_queue_obj;
      conffwk::ConfigObject tpreq_queue_obj;
      std::string tp_uid("tphandler-" + std::to_string(sid->get_sid()));
      auto tph_obj = obj_fac.create(tph_class, tp_uid);
      tph_obj.set_by_val<uint32_t>("source_id", sid->get_sid());
      tph_obj.set_by_val<uint32_t>("detector_id", 1); // 1 == kDAQ
      tph_obj.set_by_val<bool>("post_processing_enabled", get_ta_generation_enabled());
      tph_obj.set_obj("module_configuration", &tph_conf_obj);
 
      // Create the TPs aggregator queue (from RawData Handlers to TP handlers)
      tp_queue_obj = obj_fac.create_queue_sid_obj(tp_input_qdesc, sid->get_sid());
      tp_queue_obj.set_by_val<uint32_t>("recv_timeout_ms", 50);
      tp_queue_obj.set_by_val<uint32_t>("send_timeout_ms", 1);
 
      tp_queues.push_back(std::make_pair(sid->get_sid(), obj_fac.get_dal<confmodel::Connection>(tp_queue_obj.UID())));
      // Create tp data requests queue from Fragment Aggregator
      tpreq_queue_obj = obj_fac.create_queue_sid_obj(dlh_reqinput_qdesc, sid->get_sid());
      req_queues.push_back(obj_fac.get_dal<confmodel::Connection>(tpreq_queue_obj.UID()));
 
      // Create the tp(set) publishing service
      conffwk::ConfigObject tp_net_obj = obj_fac.create_net_obj(tp_net_desc, tp_uid);
 
      // Create the ta(set) publishing service
      conffwk::ConfigObject ta_net_obj = obj_fac.create_net_obj(ta_net_desc, tp_uid);
 
      // Register queues with tp handler
      tph_obj.set_objs("inputs", { &tp_queue_obj, &tpreq_queue_obj });
      tph_obj.set_objs("outputs", { &tp_net_obj, &ta_net_obj, &frag_queue_obj });
      modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(tph_obj.UID()));
    }
  }
 
  // Add output queueus of tps
  std::vector<std::pair<uint32_t, const conffwk::ConfigObject*>> tp_queue_objs;
  for (auto q : tp_queues) {
    tp_queue_objs.push_back(std::make_pair(q.first, &q.second->config_object()));
  }
 
  //-----------------------------------------------------------------
  //
  // Create datalink handlers
  //
  // Recover the emulation flag
 
  auto lb_conf = dlh_conf->get_latency_buffer();
 
  std::map<int16_t, conffwk::ConfigObject> numa_dhlconf_map;
  for ( int16_t numa : numas ) {
    auto lb_confobj_numa = obj_fac.create(lb_conf->class_name(), fmt::format("{}-numa{}",lb_conf->UID(), numa));
    lb_confobj_numa.set_by_val<uint32_t>("size", lb_conf->get_size());
    lb_confobj_numa.set_by_val<bool>("numa_aware", lb_conf->get_numa_aware());
    lb_confobj_numa.set_by_val<int16_t>("numa_node", numa);
    lb_confobj_numa.set_by_val<bool>("intrinsic_allocator", lb_conf->get_intrinsic_allocator());
    lb_confobj_numa.set_by_val<uint32_t>("alignment_size", lb_conf->get_alignment_size());
    lb_confobj_numa.set_by_val<bool>("preallocation", lb_conf->get_preallocation());
 
    auto dhl_confobj_numa = obj_fac.create(dlh_conf->class_name(), fmt::format("{}-numa{}",dlh_conf->UID(), numa));
    dhl_confobj_numa.set_by_val<std::string>("template_for", dlh_conf->get_template_for());
    dhl_confobj_numa.set_by_val<std::string>("input_data_type", dlh_conf->get_input_data_type());
    dhl_confobj_numa.set_by_val<bool>("generate_timesync", dlh_conf->get_generate_timesync());
    dhl_confobj_numa.set_by_val<uint64_t>("post_processing_delay_ticks", dlh_conf->get_post_processing_delay_ticks());
    dhl_confobj_numa.set_by_val<std::string>("input_data_type", dlh_conf->get_input_data_type());
    dhl_confobj_numa.set_obj("request_handler", &dlh_conf->get_request_handler()->config_object());
    dhl_confobj_numa.set_obj("latency_buffer", &lb_confobj_numa);
    dhl_confobj_numa.set_obj("data_processor", &dlh_conf->get_data_processor()->config_object());
 
 
    numa_dhlconf_map[numa] = dhl_confobj_numa;
 
  }
 
  auto emulation_mode = reader_conf->get_emulation_mode();
  for (auto& [numa, ds] : all_enabled_det_streams) {
    uint32_t sid = ds->get_source_id();
    TLOG_DEBUG(6) << fmt::format("Processing stream {}, id {}, det id {}", ds->UID(), ds->get_source_id(), ds->get_geo_id()->get_detector_id());
    std::string uid(fmt::format("DLH-{}", sid));
    TLOG_DEBUG(6) << fmt::format("creating OKS configuration object for Data Link Handler class {}, if {}", dlh_class, sid);
    auto dlh_obj = obj_fac.create(dlh_class, uid);
    dlh_obj.set_by_val<uint32_t>("source_id", sid);
    dlh_obj.set_by_val<uint32_t>("detector_id", ds->get_geo_id()->get_detector_id());
    dlh_obj.set_by_val<bool>("post_processing_enabled", get_tp_generation_enabled());
    dlh_obj.set_by_val<bool>("emulation_mode", emulation_mode);
    dlh_obj.set_obj("geo_id", &ds->get_geo_id()->config_object());
    dlh_obj.set_obj("module_configuration", &numa_dhlconf_map[numa]);
    dlh_obj.set_obj("raw_data_callback", &callback_confs_by_sid[sid]->config_object());
 
    std::vector<const conffwk::ConfigObject*> dlh_ins, dlh_outs;
 
    // Create request queue
    conffwk::ConfigObject req_queue_obj = obj_fac.create_queue_sid_obj(dlh_reqinput_qdesc, ds);
 
 
    // Add the requessts queue dal pointer to the outputs of the FragmentAggregatorModule
    req_queues.push_back(obj_fac.get_dal<confmodel::Connection>(req_queue_obj.UID()));
    dlh_ins.push_back(&req_queue_obj);
    dlh_outs.push_back(&frag_queue_obj);
 
 
    // Time Sync network connection
    if (dlh_conf->get_generate_timesync()) {
      // Add timestamp endpoint
      conffwk::ConfigObject ts_net_obj = obj_fac.create_net_obj(ts_net_desc, std::to_string(sid));
      dlh_outs.push_back(&ts_net_obj);
    }
 
    // here, we want to select which tp queues to add to the output, to separate mutiple detector elements
    for (auto tpq : tp_queue_objs) {
        if ((sid / 100) == (tpq.first / 10)) {
        dlh_outs.push_back(tpq.second);
      }
    }
    dlh_obj.set_objs("inputs", dlh_ins);
    dlh_obj.set_objs("outputs", dlh_outs);
 
    modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(dlh_obj.UID()));
  }
 
 
  // Finally create Fragment Aggregator
  auto aggregator_conf = get_fragment_aggregator();
  if (aggregator_conf == 0) {
    throw(BadConf(ERS_HERE, "No FragmentAggregatorModule configuration given"));
  }
  std::string faUid("fragmentaggregator-" + UID());
  // conffwk::ConfigObject frag_aggr;
  TLOG_DEBUG(7) << "creating OKS configuration object for Fragment Aggregator class ";
  auto frag_aggr = obj_fac.create("FragmentAggregatorModule", faUid);
  conffwk::ConfigObject fa_net_obj = obj_fac.create_net_obj(fa_net_desc);
 
  // Process special Network rules!
  // Looking for Fragment rules from DFAppplications in current Session
  std::vector<conffwk::ConfigObject> fragOutObjs;
  for (auto [uid, descriptor]:
         helper->get_netdescriptors("Fragment", "DFApplication")) {
    std::string dreqNetUid(descriptor->get_uid_base() + uid);
    auto frag_conn = obj_fac.create("NetworkConnection", dreqNetUid);
 
    frag_conn.set_by_val<std::string>("data_type", descriptor->get_data_type());
    frag_conn.set_by_val<std::string>("connection_type", descriptor->get_connection_type());
    // Override capacity, set to 2x expected number of Fragments
    frag_conn.set_by_val<int>("capacity", all_enabled_det_streams.size() * 2);
 
    auto serviceObj = descriptor->get_associated_service()->config_object();
    frag_conn.set_obj("associated_service", &serviceObj);
    fragOutObjs.push_back(frag_conn);
  }    
 
  // Add output queueus of data requests and Fragments
  std::vector<const conffwk::ConfigObject*> fa_output_objs;
  for (auto& fNet : fragOutObjs) {
    fa_output_objs.push_back(&fNet);
  }
 
  for (auto& q : req_queues) {
    fa_output_objs.push_back(&q->config_object());
  }
 
  frag_aggr.set_obj("configuration", &aggregator_conf->config_object());
  frag_aggr.set_objs("inputs", { &fa_net_obj, &frag_queue_obj });
  frag_aggr.set_objs("outputs", fa_output_objs);
 
  modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(frag_aggr.UID()));
 
  obj_fac.update_modules(modules);
}

◆ generate_modules() [2/2]

void dunedaq::appmodel::NP02ReadoutApplication::generate_modules ( std::shared_ptr< appmodel::ConfigurationHelper > ) const

overridevirtual

Generate daq module dal objects for streams of thie ReadoutApplication on the fly

Implements dunedaq::appmodel::SmartDaqApplication.

◆ get() [1/4]

std::vector< const dunedaq::conffwk::DalObject * > dunedaq::appmodel::NP02ReadoutApplication::get	(	const std::string &	name,
		bool	upcast_unregistered = true ) const

virtual

Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject pointers.

Parameters are:

Parameters

name	name of the relationship or algorithm

Returns: value of relationship or result of algorithm

Exceptions

std::exception if there is no relationship or algorithm with such name in this and base classes

Reimplemented from dunedaq::appmodel::ReadoutApplication.

Definition at line 66 of file NP02ReadoutApplication.cpp.

    {
      std::vector<const dunedaq::conffwk::DalObject *> vec;
 
      if (!get(name, vec, upcast_unregistered, true))
        throw_get_ex(name, s_class_name, this);
 
      return vec;
    }

◆ get() [2/4]

virtual std::vector< const dunedaq::conffwk::DalObject * > dunedaq::appmodel::NP02ReadoutApplication::get	(	const std::string &	name,
		bool	upcast_unregistered = true ) const

virtual

Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject pointers.

Parameters are:

Parameters

name	name of the relationship or algorithm

Returns: value of relationship or result of algorithm

Exceptions

std::exception if there is no relationship or algorithm with such name in this and base classes

Reimplemented from dunedaq::appmodel::ReadoutApplication.

◆ get() [3/4]

bool dunedaq::appmodel::NP02ReadoutApplication::get	(	const std::string &	name,
		std::vector< const dunedaq::conffwk::DalObject * > &	vec,
		bool	upcast_unregistered,
		bool	first_call ) const

protected

Definition at line 76 of file NP02ReadoutApplication.cpp.

    {
      if (first_call)
        {
          std::lock_guard scoped_lock(m_mutex);
 
          check();
          check_init();
 
          if (get_rel_objects(name, upcast_unregistered, vec))
            return true;
        }
 
      if (ReadoutApplication::get(name, vec, upcast_unregistered, false)) return true;
 
      if (first_call)
        return get_algo_objects(name, vec);
 
      return false;
    }

◆ get() [4/4]

bool dunedaq::appmodel::NP02ReadoutApplication::get	(	const std::string &	name,
		std::vector< const dunedaq::conffwk::DalObject * > &	vec,
		bool	upcast_unregistered,
		bool	first_call ) const

protected

◆ init() [1/2]

void dunedaq::appmodel::NP02ReadoutApplication::init ( bool init_children )

protectedvirtual

Initialize object (method generated by genconffwk)

Parameters

init_children if true, initialize referenced objects

Reimplemented from dunedaq::appmodel::ReadoutApplication.

Definition at line 55 of file NP02ReadoutApplication.cpp.

    {
      ReadoutApplication::init(init_children);
 
      TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
    }

◆ init() [2/2]

virtual void dunedaq::appmodel::NP02ReadoutApplication::init ( bool init_children )

protectedvirtual

Initialize object (method generated by genconffwk)

Parameters

init_children if true, initialize referenced objects

Reimplemented from dunedaq::appmodel::ReadoutApplication.

◆ print() [1/2]

void dunedaq::appmodel::NP02ReadoutApplication::print	(	unsigned int	offset,
		bool	print_header,
		std::ostream &	s ) const

virtual

Print details of the NP02ReadoutApplication object.

Parameters are:

Parameters

offset	number of spaces to shift object right (useful to print nested objects)
print_header	if false, do not print object header (to print attributes of base classes)
s	output stream

Reimplemented from dunedaq::appmodel::ReadoutApplication.

Definition at line 35 of file NP02ReadoutApplication.cpp.

    {
      check_init();
 
      try {
 
        if (print_header)
          p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
 
 
          // print direct super-classes
 
        dunedaq::appmodel::ReadoutApplication::print(indent, false, s);
      }
      catch (dunedaq::conffwk::Exception & ex) {
        dunedaq::conffwk::DalObject::p_error(s, ex);
      }
    }

◆ print() [2/2]

virtual void dunedaq::appmodel::NP02ReadoutApplication::print	(	unsigned int	offset,
		bool	print_header,
		std::ostream &	s ) const

virtual

Print details of the NP02ReadoutApplication object.

Parameters are:

Parameters

offset	number of spaces to shift object right (useful to print nested objects)
print_header	if false, do not print object header (to print attributes of base classes)
s	output stream

Reimplemented from dunedaq::appmodel::ReadoutApplication.

Friends And Related Symbol Documentation

◆ conffwk::Configuration

conffwk::Configuration

friend

Definition at line 25 of file NP02ReadoutApplication.hpp.

◆ conffwk::DalFactory

conffwk::DalFactory

friend

Definition at line 27 of file NP02ReadoutApplication.hpp.

◆ conffwk::DalObject

conffwk::DalObject

friend

Definition at line 26 of file NP02ReadoutApplication.hpp.

◆ conffwk::DalRegistry

conffwk::DalRegistry

friend

Definition at line 28 of file NP02ReadoutApplication.hpp.

Member Data Documentation

◆ s_class_name

static const std::string & dunedaq::appmodel::NP02ReadoutApplication::s_class_name

static

The name of the configuration class.

Definition at line 40 of file NP02ReadoutApplication.hpp.

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

/github/workspace/dunedaq/build/appmodel/codegen/include/appmodel/NP02ReadoutApplication.hpp
/github/workspace/dunedaq/build/appmodel/codegen/src/NP02ReadoutApplication.hpp
/github/workspace/dunedaq/sourcecode/appmodel/src/NP02ReadoutApplication.cpp
/github/workspace/dunedaq/build/appmodel/codegen/src/NP02ReadoutApplication.cpp

Public Member Functions

Static Public Attributes

Protected Member Functions

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ NP02ReadoutApplication() [1/2]

◆ ~NP02ReadoutApplication() [1/2]

◆ NP02ReadoutApplication() [2/2]

◆ ~NP02ReadoutApplication() [2/2]

Member Function Documentation

◆ generate_modules() [1/2]

◆ generate_modules() [2/2]

◆ get() [1/4]

◆ get() [2/4]

◆ get() [3/4]

◆ get() [4/4]

◆ init() [1/2]

◆ init() [2/2]

◆ print() [1/2]

◆ print() [2/2]

Friends And Related Symbol Documentation

◆ conffwk::Configuration

◆ conffwk::DalFactory

◆ conffwk::DalObject

◆ conffwk::DalRegistry

Member Data Documentation

◆ s_class_name