dunedaq::appmodel::ReadoutApplication Class Reference

#include <ReadoutApplication.hpp>

Inheritance diagram for dunedaq::appmodel::ReadoutApplication:

Collaboration diagram for dunedaq::appmodel::ReadoutApplication:

Public Member Functions
virtual void	print (unsigned int offset, bool print_header, std::ostream &s) const
	Print details of the ReadoutApplication 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.
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.
void	generate_modules (const confmodel::Session *) const override
virtual std::vector< const Resource * >	contained_resources () const override
virtual void	print (unsigned int offset, bool print_header, std::ostream &s) const
	Print details of the ReadoutApplication 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.
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.
void	generate_modules (const confmodel::Session *) 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 Member Functions
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_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 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

Static Public Attributes
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 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
	ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
virtual	~ReadoutApplication () 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
	ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
virtual	~ReadoutApplication () 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::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

Private Attributes
std::string	m_application_name
bool	m_tp_generation_enabled
bool	m_ta_generation_enabled
std::vector< const dunedaq::appmodel::SourceIDConf * >	m_tp_source_ids
const dunedaq::appmodel::RoHwConfig *	m_uses
const dunedaq::appmodel::DataHandlerConf *	m_link_handler
const dunedaq::appmodel::DataHandlerConf *	m_tp_handler
const dunedaq::appmodel::DataReaderConf *	m_data_reader
const dunedaq::appmodel::DataRecorderConf *	m_data_recorder
const dunedaq::appmodel::FragmentAggregatorConf *	m_fragment_aggregator
std::vector< const dunedaq::confmodel::DetectorToDaqConnection * >	m_detector_connections

Friends
class	conffwk::Configuration
class	conffwk::DalObject
class	conffwk::DalFactory
class	conffwk::DalRegistry

Additional Inherited Members
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 42 of file ReadoutApplication.hpp.

Constructor & Destructor Documentation

ReadoutApplication() [1/2]

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

protectednoexcept

Definition at line 37 of file ReadoutApplication.cpp.

                                                                                                        :
      dunedaq::conffwk::DalObject(db, o),
      SmartDaqApplication(db, o),
      dunedaq::confmodel::ResourceSetDisableAND(db, o),
      m_uses (nullptr),
      m_link_handler (nullptr),
      m_tp_handler (nullptr),
      m_data_reader (nullptr),
      m_data_recorder (nullptr),
      m_fragment_aggregator (nullptr)
 
    {
      ;
    }

~ReadoutApplication() [1/2]

dunedaq::appmodel::ReadoutApplication::~ReadoutApplication ( )

protectedvirtualnoexcept

Definition at line 119 of file ReadoutApplication.cpp.

    {
    }

ReadoutApplication() [2/2]

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

protectednoexcept

~ReadoutApplication() [2/2]

virtual dunedaq::appmodel::ReadoutApplication::~ReadoutApplication ( )

protectedvirtualnoexcept

Member Function Documentation

__get_application_name_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_application_name_str ( )

inlinestaticnoexcept

Definition at line 114 of file ReadoutApplication.hpp.

{ return s_application_name; }

__get_application_name_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_application_name_str ( )

inlinestaticnoexcept

Definition at line 114 of file ReadoutApplication.hpp.

{ return s_application_name; }

__get_data_reader_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_data_reader_str ( )

inlinestaticnoexcept

Definition at line 227 of file ReadoutApplication.hpp.

{ return s_data_reader; }

__get_data_reader_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_data_reader_str ( )

inlinestaticnoexcept

Definition at line 227 of file ReadoutApplication.hpp.

{ return s_data_reader; }

__get_data_recorder_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_data_recorder_str ( )

inlinestaticnoexcept

Definition at line 228 of file ReadoutApplication.hpp.

{ return s_data_recorder; }

__get_data_recorder_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_data_recorder_str ( )

inlinestaticnoexcept

Definition at line 228 of file ReadoutApplication.hpp.

{ return s_data_recorder; }

__get_detector_connections_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_detector_connections_str ( )

inlinestaticnoexcept

Definition at line 230 of file ReadoutApplication.hpp.

{ return s_detector_connections; }

__get_detector_connections_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_detector_connections_str ( )

inlinestaticnoexcept

Definition at line 230 of file ReadoutApplication.hpp.

{ return s_detector_connections; }

__get_fragment_aggregator_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_fragment_aggregator_str ( )

inlinestaticnoexcept

Definition at line 229 of file ReadoutApplication.hpp.

{ return s_fragment_aggregator; }

__get_fragment_aggregator_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_fragment_aggregator_str ( )

inlinestaticnoexcept

Definition at line 229 of file ReadoutApplication.hpp.

{ return s_fragment_aggregator; }

__get_link_handler_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_link_handler_str ( )

inlinestaticnoexcept

Definition at line 225 of file ReadoutApplication.hpp.

{ return s_link_handler; }

__get_link_handler_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_link_handler_str ( )

inlinestaticnoexcept

Definition at line 225 of file ReadoutApplication.hpp.

{ return s_link_handler; }

__get_ta_generation_enabled_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_ta_generation_enabled_str ( )

inlinestaticnoexcept

Definition at line 116 of file ReadoutApplication.hpp.

{ return s_ta_generation_enabled; }

__get_ta_generation_enabled_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_ta_generation_enabled_str ( )

inlinestaticnoexcept

Definition at line 116 of file ReadoutApplication.hpp.

{ return s_ta_generation_enabled; }

__get_tp_generation_enabled_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_tp_generation_enabled_str ( )

inlinestaticnoexcept

Definition at line 115 of file ReadoutApplication.hpp.

{ return s_tp_generation_enabled; }

__get_tp_generation_enabled_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_tp_generation_enabled_str ( )

inlinestaticnoexcept

Definition at line 115 of file ReadoutApplication.hpp.

{ return s_tp_generation_enabled; }

__get_tp_handler_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_tp_handler_str ( )

inlinestaticnoexcept

Definition at line 226 of file ReadoutApplication.hpp.

{ return s_tp_handler; }

__get_tp_handler_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_tp_handler_str ( )

inlinestaticnoexcept

Definition at line 226 of file ReadoutApplication.hpp.

{ return s_tp_handler; }

__get_tp_source_ids_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_tp_source_ids_str ( )

inlinestaticnoexcept

Definition at line 223 of file ReadoutApplication.hpp.

{ return s_tp_source_ids; }

__get_tp_source_ids_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_tp_source_ids_str ( )

inlinestaticnoexcept

Definition at line 223 of file ReadoutApplication.hpp.

{ return s_tp_source_ids; }

__get_uses_str() [1/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_uses_str ( )

inlinestaticnoexcept

Definition at line 224 of file ReadoutApplication.hpp.

{ return s_uses; }

__get_uses_str() [2/2]

static const std::string & dunedaq::appmodel::ReadoutApplication::__get_uses_str ( )

inlinestaticnoexcept

Definition at line 224 of file ReadoutApplication.hpp.

{ return s_uses; }

contained_resources() [1/2]

std::vector< const confmodel::Resource * > dunedaq::appmodel::ReadoutApplication::contained_resources ( ) const

overridevirtual

Virtual method to obtain the list of all contained Resources. Used internally by the core disabled logic. Not intended to be used in application code as that should be using individual relationships of the derived classes.

Implements dunedaq::confmodel::ResourceSet.

Definition at line 73 of file ReadoutApplication.cpp.

                                              {
  return to_resources(get_detector_connections());
}

contained_resources() [2/2]

virtual std::vector< const Resource * > dunedaq::appmodel::ReadoutApplication::contained_resources ( ) const

overridevirtual

Virtual method to obtain the list of all contained Resources. Used internally by the core disabled logic. Not intended to be used in application code as that should be using individual relationships of the derived classes.

Implements dunedaq::confmodel::ResourceSet.

generate_modules() [1/2]

void dunedaq::appmodel::ReadoutApplication::generate_modules ( const confmodel::Session * session ) const

overridevirtual

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

Implements dunedaq::appmodel::SmartDaqApplication.

Definition at line 78 of file ReadoutApplication.cpp.

{
 
  TLOG_DEBUG(6) << "Generating modules for application " << this->UID();
 
  ConfigObjectFactory obj_fac(this);
  // conffwk::Configuration& confdb = this->configuration();
 
  //
  // 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_input_qdesc = nullptr;
  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? It is the base class for several DataHandler types (e.g. FDDataHandlerModule, SNBDataHandlerModule)
    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 {
        dlh_input_qdesc = rule->get_descriptor();
      }
    } else if (destination_class == "FragmentAggregatorModule") {
      fa_output_qdesc = rule->get_descriptor();
    }
  }
 
  if (dlh_input_qdesc == nullptr) {
    throw(BadConf(ERS_HERE, "No data link handler input queue descriptor given"));
  }
  if (dlh_reqinput_qdesc == nullptr) {
    throw(BadConf(ERS_HERE, "No data link handler request input queue descriptor given"));
  }
 
  //
  // 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();
    }
  }
 
  if (fa_net_desc == nullptr) {
    throw(BadConf(ERS_HERE, "No Fragment Aggregator network descriptor given"));
  }
  if (ts_net_desc == nullptr && dlh_conf->get_generate_timesync()) {
    throw(BadConf(ERS_HERE, "No Time Sync network descriptor given but time sync generation is enabled"));
  }
 
  // 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);
 
  //
  // 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<const confmodel::DetectorStream*> all_enabled_det_streams;
  std::map<uint32_t, const confmodel::Connection*> data_queues_by_sid;
 
  // std::vector<const conffwk::ConfigObject*> d2d_conn_objs;
  uint16_t conn_idx = 0;
 
  for (auto d2d_conn : get_detector_connections()) {
    if (d2d_conn->is_disabled(*session)) {
      TLOG_DEBUG(7) << "Ignoring disabled DetectorToDaqConnection " << d2d_conn->UID();
      continue;
    }
 
    TLOG_DEBUG(6) << "Processing DetectorToDaqConnection " << d2d_conn->UID();
 
    // Are these tests necessary? Schema does not allow 0 cardinality
    // for these relationships!!  TODO
    if (d2d_conn->senders().empty()) {
      throw(BadConf(ERS_HERE, "DetectorToDaqConnection does not contain senders"));
    }
    if (d2d_conn->receiver() == nullptr) {
      throw(BadConf(ERS_HERE, "DetectorToDaqConnection does not contain a receiver"));
    }
 
    // Find senders and receiver
    auto det_senders = d2d_conn->senders();
    auto det_receiver = d2d_conn->receiver();
 
    std::vector<const confmodel::DetectorStream*> enabled_det_streams;
    // Loop over streams
    for (auto stream : d2d_conn->streams()) {
 
      // Are we sure?
      if (stream->is_disabled(*session)) {
        TLOG_DEBUG(7) << "Ignoring disabled DetectorStream " << stream->UID();
        continue;
      }
 
      all_enabled_det_streams.push_back(stream);
      enabled_det_streams.push_back(stream);
    }
 
 
    // 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 (!d2d_conn->castable("NetworkDetectorToDaqConnection")) {
        throw(BadConf(ERS_HERE, fmt::format("{} requires NetworkDetectorToDaqConnection, found {} of class {}", reader_class, d2d_conn->UID(), d2d_conn->class_name())));
      }
      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())));
      }
    }
    else if (reader_class == "FelixReaderModule") {
      if (!d2d_conn->castable("FelixDetectorToDaqConnection")) {
        throw(BadConf(ERS_HERE, fmt::format("{} requires FelixDetectorToDaqConnection, found {} of class {}", reader_class, d2d_conn->UID(), d2d_conn->class_name())));
      }
      if (!det_receiver->cast<appmodel::FelixDataReceiver>()) {
        throw(BadConf(ERS_HERE, fmt::format("FelixReaderModule requires FelixDataReceiver, found {} of class {}", det_receiver->UID(), det_receiver->class_name())));
      }
    }
  // }
 
  //-----------------------------------------------------------------
  //
  // 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->config_object()});
 
    // Create the raw data queues
    std::vector<const conffwk::ConfigObject*> data_queue_objs;
    // keep a map for convenience
 
    // Create data queues
    for (auto ds : enabled_det_streams) {
      conffwk::ConfigObject queue_obj = obj_fac.create_queue_sid_obj(dlh_input_qdesc, ds);
      const auto* data_queue = obj_fac.get_dal<confmodel::Connection>(queue_obj.UID());
      data_queue_objs.push_back(&data_queue->config_object());
      data_queues_by_sid[ds->get_source_id()] = data_queue;
    }
 
    reader_obj.set_objs("outputs", data_queue_objs);
 
    modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(reader_obj.UID()));
  }
 
 
  //-----------------------------------------------------------------
  //
  // Prepare the tp handlers and related queues
  //
  std::vector<const confmodel::Connection*> tp_queues;
  if (get_tp_generation_enabled()) {
    if (tp_input_qdesc == nullptr) {
        throw(BadConf(ERS_HERE, "TP generation is enabled but no TP input queue descriptor given"));
    }
    if (tp_net_desc == nullptr) {
        throw(BadConf(ERS_HERE, "TP generation is enabled but no TPSet network descriptor given"));
    }
    if (ta_net_desc == nullptr) {
      throw(BadConf(ERS_HERE, "TP generation is enabled but no TriggerActivity network descriptor given"));
    }
    // Create TP handler object
    auto tph_conf_obj = tph_conf->config_object();
    auto tpsrc_ids = get_tp_source_ids();
 
    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(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 hankder
      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<const conffwk::ConfigObject*> tp_queue_objs;
  for (auto q : tp_queues) {
    tp_queue_objs.push_back(&q->config_object());
  }
 
  //-----------------------------------------------------------------
  //
  // Create datalink handlers
  //
  // Recover the emulation flag
  auto emulation_mode = reader_conf->get_emulation_mode();
  for (auto 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", &dlh_conf->config_object());
 
    std::vector<const conffwk::ConfigObject*> dlh_ins, dlh_outs;
 
    // Add datalink-handler queue to the inputs
    dlh_ins.push_back(&data_queues_by_sid.at(sid)->config_object());
 
    // 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);
    }
 
    for (auto tpq : tp_queue_objs) {
      dlh_outs.push_back(tpq);
    }
    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
  auto sessionApps = session->enabled_applications();
  std::vector<conffwk::ConfigObject> fragOutObjs;
  for (auto app : sessionApps) {
    auto dfapp = app->cast<appmodel::DFApplication>();
    if (dfapp == nullptr)
      continue;
 
    auto dfNRules = dfapp->get_network_rules();
    for (auto rule : dfNRules) {
      auto descriptor = rule->get_descriptor();
      auto data_type = descriptor->get_data_type();
      if (data_type == "Fragment") {
        std::string dreqNetUid(descriptor->get_uid_base() + dfapp->UID());
        // conffwk::ConfigObject frag_conn;
        // confdb.create(dbfile, "NetworkConnection", dreqNetUid, frag_conn);
        auto frag_conn = obj_fac.create("NetworkConnection", dreqNetUid);
 
        frag_conn.set_by_val<std::string>("data_type", descriptor->get_data_type());
 
        // Override capacity, set to 2x expected number of Fragments
        frag_conn.set_by_val<int>("capacity", all_enabled_det_streams.size() * 2);
        frag_conn.set_by_val<std::string>("connection_type", descriptor->get_connection_type());
 
        auto serviceObj = descriptor->get_associated_service()->config_object();
        frag_conn.set_obj("associated_service", &serviceObj);
        fragOutObjs.push_back(frag_conn);
      } // If network rule has TriggerDecision type of data
    }   // Loop over Apps network rules
  }     // loop over Session specific Apps
 
  // 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::ReadoutApplication::generate_modules ( const confmodel::Session * ) 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::ReadoutApplication::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::SmartDaqApplication.

Reimplemented in dunedaq::appmodel::NP02ReadoutApplication, and dunedaq::appmodel::NP02ReadoutApplication.

Definition at line 123 of file ReadoutApplication.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::ReadoutApplication::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::SmartDaqApplication.

Reimplemented in dunedaq::appmodel::NP02ReadoutApplication, and dunedaq::appmodel::NP02ReadoutApplication.

get() [3/4]

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

protected

Definition at line 133 of file ReadoutApplication.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 (SmartDaqApplication::get(name, vec, upcast_unregistered, false)) return true;
      if (ResourceSetDisableAND::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::ReadoutApplication::get ( const std::string & name, std::vector< const dunedaq::conffwk::DalObject * > & vec, bool upcast_unregistered, bool first_call ) const

protected

get_application_name() [1/2]

const std::string & dunedaq::appmodel::ReadoutApplication::get_application_name ( ) const

inline

Get "application_name" attribute value.

Returns

the attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 126 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            check_init();
            return m_application_name;
          }

get_application_name() [2/2]

const std::string & dunedaq::appmodel::ReadoutApplication::get_application_name ( ) const

inline

Get "application_name" attribute value.

Returns

the attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 126 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            check_init();
            return m_application_name;
          }

get_data_reader() [1/2]

const dunedaq::appmodel::DataReaderConf * dunedaq::appmodel::ReadoutApplication::get_data_reader ( ) const

inline

Get "data_reader" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 354 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          if (!m_data_reader)
            {
              std::ostringstream text;
              text << "relationship \"" << s_data_reader << "\" of object " << this << " is not set";
              throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
            }
          return m_data_reader;
        }

get_data_reader() [2/2]

const dunedaq::appmodel::DataReaderConf * dunedaq::appmodel::ReadoutApplication::get_data_reader ( ) const

inline

Get "data_reader" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 354 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          if (!m_data_reader)
            {
              std::ostringstream text;
              text << "relationship \"" << s_data_reader << "\" of object " << this << " is not set";
              throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
            }
          return m_data_reader;
        }

get_data_recorder() [1/2]

const dunedaq::appmodel::DataRecorderConf * dunedaq::appmodel::ReadoutApplication::get_data_recorder ( ) const

inline

Get "data_recorder" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 385 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          return m_data_recorder;
        }

get_data_recorder() [2/2]

const dunedaq::appmodel::DataRecorderConf * dunedaq::appmodel::ReadoutApplication::get_data_recorder ( ) const

inline

Get "data_recorder" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 385 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          return m_data_recorder;
        }

get_detector_connections() [1/2]

const std::vector< const dunedaq::confmodel::DetectorToDaqConnection * > & dunedaq::appmodel::ReadoutApplication::get_detector_connections ( ) const

inline

Get "detector_connections" relationship value. The list of detector channels to be read out by this readout application.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 442 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          return m_detector_connections;
        }

get_detector_connections() [2/2]

const std::vector< const dunedaq::confmodel::DetectorToDaqConnection * > & dunedaq::appmodel::ReadoutApplication::get_detector_connections ( ) const

inline

Get "detector_connections" relationship value. The list of detector channels to be read out by this readout application.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 442 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          return m_detector_connections;
        }

get_fragment_aggregator() [1/2]

const dunedaq::appmodel::FragmentAggregatorConf * dunedaq::appmodel::ReadoutApplication::get_fragment_aggregator ( ) const

inline

Get "fragment_aggregator" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 410 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          if (!m_fragment_aggregator)
            {
              std::ostringstream text;
              text << "relationship \"" << s_fragment_aggregator << "\" of object " << this << " is not set";
              throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
            }
          return m_fragment_aggregator;
        }

get_fragment_aggregator() [2/2]

const dunedaq::appmodel::FragmentAggregatorConf * dunedaq::appmodel::ReadoutApplication::get_fragment_aggregator ( ) const

inline

Get "fragment_aggregator" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 410 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          if (!m_fragment_aggregator)
            {
              std::ostringstream text;
              text << "relationship \"" << s_fragment_aggregator << "\" of object " << this << " is not set";
              throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
            }
          return m_fragment_aggregator;
        }

get_link_handler() [1/2]

const dunedaq::appmodel::DataHandlerConf * dunedaq::appmodel::ReadoutApplication::get_link_handler ( ) const

inline

Get "link_handler" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 298 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          if (!m_link_handler)
            {
              std::ostringstream text;
              text << "relationship \"" << s_link_handler << "\" of object " << this << " is not set";
              throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
            }
          return m_link_handler;
        }

get_link_handler() [2/2]

const dunedaq::appmodel::DataHandlerConf * dunedaq::appmodel::ReadoutApplication::get_link_handler ( ) const

inline

Get "link_handler" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 298 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          if (!m_link_handler)
            {
              std::ostringstream text;
              text << "relationship \"" << s_link_handler << "\" of object " << this << " is not set";
              throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
            }
          return m_link_handler;
        }

get_ta_generation_enabled() [1/2]

bool dunedaq::appmodel::ReadoutApplication::get_ta_generation_enabled ( ) const

inline

Get "ta_generation_enabled" attribute value.

Returns

the attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 188 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            check_init();
            return m_ta_generation_enabled;
          }

get_ta_generation_enabled() [2/2]

bool dunedaq::appmodel::ReadoutApplication::get_ta_generation_enabled ( ) const

inline

Get "ta_generation_enabled" attribute value.

Returns

the attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 188 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            check_init();
            return m_ta_generation_enabled;
          }

get_tp_generation_enabled() [1/2]

bool dunedaq::appmodel::ReadoutApplication::get_tp_generation_enabled ( ) const

inline

Get "tp_generation_enabled" attribute value.

Returns

the attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 157 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            check_init();
            return m_tp_generation_enabled;
          }

get_tp_generation_enabled() [2/2]

bool dunedaq::appmodel::ReadoutApplication::get_tp_generation_enabled ( ) const

inline

Get "tp_generation_enabled" attribute value.

Returns

the attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 157 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            check_init();
            return m_tp_generation_enabled;
          }

get_tp_handler() [1/2]

const dunedaq::appmodel::DataHandlerConf * dunedaq::appmodel::ReadoutApplication::get_tp_handler ( ) const

inline

Get "tp_handler" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 329 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          return m_tp_handler;
        }

get_tp_handler() [2/2]

const dunedaq::appmodel::DataHandlerConf * dunedaq::appmodel::ReadoutApplication::get_tp_handler ( ) const

inline

Get "tp_handler" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 329 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          return m_tp_handler;
        }

get_tp_source_ids() [1/2]

const std::vector< const dunedaq::appmodel::SourceIDConf * > & dunedaq::appmodel::ReadoutApplication::get_tp_source_ids ( ) const

inline

Get "tp_source_ids" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 240 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          return m_tp_source_ids;
        }

get_tp_source_ids() [2/2]

const std::vector< const dunedaq::appmodel::SourceIDConf * > & dunedaq::appmodel::ReadoutApplication::get_tp_source_ids ( ) const

inline

Get "tp_source_ids" relationship value.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 240 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          return m_tp_source_ids;
        }

get_uses() [1/2]

const dunedaq::appmodel::RoHwConfig * dunedaq::appmodel::ReadoutApplication::get_uses ( ) const

inline

Get "uses" relationship value. Configuration of the host hardware resources used by this application.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 266 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          if (!m_uses)
            {
              std::ostringstream text;
              text << "relationship \"" << s_uses << "\" of object " << this << " is not set";
              throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
            }
          return m_uses;
        }

get_uses() [2/2]

const dunedaq::appmodel::RoHwConfig * dunedaq::appmodel::ReadoutApplication::get_uses ( ) const

inline

Get "uses" relationship value. Configuration of the host hardware resources used by this application.

Returns

the relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 266 of file ReadoutApplication.hpp.

        {
          std::lock_guard scoped_lock(m_mutex);
          check();
          check_init();
          if (!m_uses)
            {
              std::ostringstream text;
              text << "relationship \"" << s_uses << "\" of object " << this << " is not set";
              throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
            }
          return m_uses;
        }

init() [1/2]

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

protectedvirtual

Initialize object (method generated by genconffwk)

Parameters

init_children

if true, initialize referenced objects

Reimplemented from dunedaq::appmodel::SmartDaqApplication.

Reimplemented in dunedaq::appmodel::NP02ReadoutApplication, and dunedaq::appmodel::NP02ReadoutApplication.

Definition at line 94 of file ReadoutApplication.cpp.

    {
      SmartDaqApplication::init(init_children);
      ResourceSetDisableAND::init(init_children);
 
      TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
 
      try {
        p_obj.get(s_application_name, m_application_name);
        p_obj.get(s_tp_generation_enabled, m_tp_generation_enabled);
        p_obj.get(s_ta_generation_enabled, m_ta_generation_enabled);
        p_registry._ref<dunedaq::appmodel::SourceIDConf>(p_obj, s_tp_source_ids, m_tp_source_ids, init_children);
        m_uses = p_registry._ref<dunedaq::appmodel::RoHwConfig>(p_obj, s_uses, init_children);
        m_link_handler = p_registry._ref<dunedaq::appmodel::DataHandlerConf>(p_obj, s_link_handler, init_children);
        m_tp_handler = p_registry._ref<dunedaq::appmodel::DataHandlerConf>(p_obj, s_tp_handler, init_children);
        m_data_reader = p_registry._ref<dunedaq::appmodel::DataReaderConf>(p_obj, s_data_reader, init_children);
        m_data_recorder = p_registry._ref<dunedaq::appmodel::DataRecorderConf>(p_obj, s_data_recorder, init_children);
        m_fragment_aggregator = p_registry._ref<dunedaq::appmodel::FragmentAggregatorConf>(p_obj, s_fragment_aggregator, init_children);
        p_registry._ref<dunedaq::confmodel::DetectorToDaqConnection>(p_obj, s_detector_connections, m_detector_connections, init_children);
      }
      catch (dunedaq::conffwk::Exception & ex) {
        throw_init_ex(ex);
      }
    }

init() [2/2]

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

protectedvirtual

Initialize object (method generated by genconffwk)

Parameters

init_children

if true, initialize referenced objects

Reimplemented from dunedaq::appmodel::SmartDaqApplication.

Reimplemented in dunedaq::appmodel::NP02ReadoutApplication, and dunedaq::appmodel::NP02ReadoutApplication.

print() [1/2]

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

virtual

Print details of the ReadoutApplication 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::SmartDaqApplication.

Reimplemented in dunedaq::appmodel::NP02ReadoutApplication, and dunedaq::appmodel::NP02ReadoutApplication.

Definition at line 53 of file ReadoutApplication.cpp.

    {
      check_init();
 
      try {
        const std::string str(indent+2, ' ');
 
        if (print_header)
          p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
 
 
          // print direct super-classes
 
        dunedaq::appmodel::SmartDaqApplication::print(indent, false, s);
        dunedaq::confmodel::ResourceSetDisableAND::print(indent, false, s);
 
 
          // print direct attributes
 
        dunedaq::conffwk::p_sv_attr(s, str, s_application_name, m_application_name);
        dunedaq::conffwk::p_sv_attr(s, str, s_tp_generation_enabled, m_tp_generation_enabled);
        dunedaq::conffwk::p_sv_attr(s, str, s_ta_generation_enabled, m_ta_generation_enabled);
 
 
          // print direct relationships
 
        dunedaq::conffwk::p_mv_rel(s, str, s_tp_source_ids, m_tp_source_ids);
        dunedaq::conffwk::p_sv_rel(s, str, indent, s_uses, m_uses);
        dunedaq::conffwk::p_sv_rel(s, str, s_link_handler, m_link_handler);
        dunedaq::conffwk::p_sv_rel(s, str, s_tp_handler, m_tp_handler);
        dunedaq::conffwk::p_sv_rel(s, str, s_data_reader, m_data_reader);
        dunedaq::conffwk::p_sv_rel(s, str, s_data_recorder, m_data_recorder);
        dunedaq::conffwk::p_sv_rel(s, str, s_fragment_aggregator, m_fragment_aggregator);
        dunedaq::conffwk::p_mv_rel(s, str, s_detector_connections, m_detector_connections);
      }
      catch (dunedaq::conffwk::Exception & ex) {
        dunedaq::conffwk::DalObject::p_error(s, ex);
      }
    }

print() [2/2]

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

virtual

Print details of the ReadoutApplication 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::SmartDaqApplication.

Reimplemented in dunedaq::appmodel::NP02ReadoutApplication, and dunedaq::appmodel::NP02ReadoutApplication.

set_application_name() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_application_name ( const std::string & value )

inline

Set "application_name" attribute value.

Parameters

value

new attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 141 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            clear();
            p_obj.set_by_ref(s_application_name, value);
          }

set_application_name() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_application_name ( const std::string & value )

inline

Set "application_name" attribute value.

Parameters

value

new attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 141 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            clear();
            p_obj.set_by_ref(s_application_name, value);
          }

set_data_reader() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_data_reader

(

const dunedaq::appmodel::DataReaderConf *

value

)

Set "data_reader" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 175 of file ReadoutApplication.cpp.

    {
      _set_object(s_data_reader, value);
    }

set_data_reader() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_data_reader

(

const dunedaq::appmodel::DataReaderConf *

value

)

Set "data_reader" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

set_data_recorder() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_data_recorder

(

const dunedaq::appmodel::DataRecorderConf *

value

)

Set "data_recorder" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 180 of file ReadoutApplication.cpp.

    {
      _set_object(s_data_recorder, value);
    }

set_data_recorder() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_data_recorder

(

const dunedaq::appmodel::DataRecorderConf *

value

)

Set "data_recorder" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

set_detector_connections() [1/2]

void dunedaq::appmodel::ReadoutApplication::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.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 190 of file ReadoutApplication.cpp.

    {
      _set_objects(s_detector_connections, value);
    }

set_detector_connections() [2/2]

void dunedaq::appmodel::ReadoutApplication::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.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

set_fragment_aggregator() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_fragment_aggregator

(

const dunedaq::appmodel::FragmentAggregatorConf *

value

)

Set "fragment_aggregator" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 185 of file ReadoutApplication.cpp.

    {
      _set_object(s_fragment_aggregator, value);
    }

set_fragment_aggregator() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_fragment_aggregator

(

const dunedaq::appmodel::FragmentAggregatorConf *

value

)

Set "fragment_aggregator" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

set_link_handler() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_link_handler

(

const dunedaq::appmodel::DataHandlerConf *

value

)

Set "link_handler" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 165 of file ReadoutApplication.cpp.

    {
      _set_object(s_link_handler, value);
    }

set_link_handler() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_link_handler

(

const dunedaq::appmodel::DataHandlerConf *

value

)

Set "link_handler" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

set_ta_generation_enabled() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_ta_generation_enabled ( bool value )

inline

Set "ta_generation_enabled" attribute value.

Parameters

value

new attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 203 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            clear();
            p_obj.set_by_val(s_ta_generation_enabled, value);
          }

set_ta_generation_enabled() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_ta_generation_enabled ( bool value )

inline

Set "ta_generation_enabled" attribute value.

Parameters

value

new attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 203 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            clear();
            p_obj.set_by_val(s_ta_generation_enabled, value);
          }

set_tp_generation_enabled() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_tp_generation_enabled ( bool value )

inline

Set "tp_generation_enabled" attribute value.

Parameters

value

new attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 172 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            clear();
            p_obj.set_by_val(s_tp_generation_enabled, value);
          }

set_tp_generation_enabled() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_tp_generation_enabled ( bool value )

inline

Set "tp_generation_enabled" attribute value.

Parameters

value

new attribute value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 172 of file ReadoutApplication.hpp.

          {
            std::lock_guard scoped_lock(m_mutex);
            check();
            clear();
            p_obj.set_by_val(s_tp_generation_enabled, value);
          }

set_tp_handler() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_tp_handler

(

const dunedaq::appmodel::DataHandlerConf *

value

)

Set "tp_handler" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 170 of file ReadoutApplication.cpp.

    {
      _set_object(s_tp_handler, value);
    }

set_tp_handler() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_tp_handler

(

const dunedaq::appmodel::DataHandlerConf *

value

)

Set "tp_handler" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

set_tp_source_ids() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_tp_source_ids

(

const std::vector< const dunedaq::appmodel::SourceIDConf * > &

value

)

Set "tp_source_ids" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 155 of file ReadoutApplication.cpp.

    {
      _set_objects(s_tp_source_ids, value);
    }

set_tp_source_ids() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_tp_source_ids

(

const std::vector< const dunedaq::appmodel::SourceIDConf * > &

value

)

Set "tp_source_ids" relationship value.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

set_uses() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_uses

(

const dunedaq::appmodel::RoHwConfig *

value

)

Set "uses" relationship value. Configuration of the host hardware resources used by this application.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 160 of file ReadoutApplication.cpp.

    {
      _set_object(s_uses, value);
    }

set_uses() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_uses

(

const dunedaq::appmodel::RoHwConfig *

value

)

Set "uses" relationship value. Configuration of the host hardware resources used by this application.

Parameters

value

new relationship value

Exceptions

dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Friends And Related Symbol Documentation

conffwk::Configuration

conffwk::Configuration

friend

Definition at line 44 of file ReadoutApplication.hpp.

conffwk::DalFactory

conffwk::DalFactory

friend

Definition at line 46 of file ReadoutApplication.hpp.

conffwk::DalObject

conffwk::DalObject

friend

Definition at line 45 of file ReadoutApplication.hpp.

conffwk::DalRegistry

conffwk::DalRegistry

friend

Definition at line 47 of file ReadoutApplication.hpp.

Member Data Documentation

m_application_name

std::string dunedaq::appmodel::ReadoutApplication::m_application_name

private

Definition at line 93 of file ReadoutApplication.hpp.

m_data_reader

const dunedaq::appmodel::DataReaderConf * dunedaq::appmodel::ReadoutApplication::m_data_reader

private

Definition at line 100 of file ReadoutApplication.hpp.

m_data_recorder

const dunedaq::appmodel::DataRecorderConf * dunedaq::appmodel::ReadoutApplication::m_data_recorder

private

Definition at line 101 of file ReadoutApplication.hpp.

m_detector_connections

std::vector< const dunedaq::confmodel::DetectorToDaqConnection * > dunedaq::appmodel::ReadoutApplication::m_detector_connections

private

Definition at line 103 of file ReadoutApplication.hpp.

m_fragment_aggregator

const dunedaq::appmodel::FragmentAggregatorConf * dunedaq::appmodel::ReadoutApplication::m_fragment_aggregator

private

Definition at line 102 of file ReadoutApplication.hpp.

m_link_handler

const dunedaq::appmodel::DataHandlerConf * dunedaq::appmodel::ReadoutApplication::m_link_handler

private

Definition at line 98 of file ReadoutApplication.hpp.

m_ta_generation_enabled

bool dunedaq::appmodel::ReadoutApplication::m_ta_generation_enabled

private

Definition at line 95 of file ReadoutApplication.hpp.

m_tp_generation_enabled

bool dunedaq::appmodel::ReadoutApplication::m_tp_generation_enabled

private

Definition at line 94 of file ReadoutApplication.hpp.

m_tp_handler

const dunedaq::appmodel::DataHandlerConf * dunedaq::appmodel::ReadoutApplication::m_tp_handler

private

Definition at line 99 of file ReadoutApplication.hpp.

m_tp_source_ids

std::vector< const dunedaq::appmodel::SourceIDConf * > dunedaq::appmodel::ReadoutApplication::m_tp_source_ids

private

Definition at line 96 of file ReadoutApplication.hpp.

m_uses

const dunedaq::appmodel::RoHwConfig * dunedaq::appmodel::ReadoutApplication::m_uses

private

Definition at line 97 of file ReadoutApplication.hpp.

s_application_name

static const std::string dunedaq::appmodel::ReadoutApplication::s_application_name = "application_name"

inlinestatic

Definition at line 110 of file ReadoutApplication.hpp.

s_class_name

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

static

The name of the configuration class.

Definition at line 59 of file ReadoutApplication.hpp.

s_data_reader

static const std::string dunedaq::appmodel::ReadoutApplication::s_data_reader = "data_reader"

inlinestatic

Definition at line 218 of file ReadoutApplication.hpp.

s_data_recorder

static const std::string dunedaq::appmodel::ReadoutApplication::s_data_recorder = "data_recorder"

inlinestatic

Definition at line 219 of file ReadoutApplication.hpp.

s_detector_connections

static const std::string dunedaq::appmodel::ReadoutApplication::s_detector_connections = "detector_connections"

inlinestatic

Definition at line 221 of file ReadoutApplication.hpp.

s_fragment_aggregator

static const std::string dunedaq::appmodel::ReadoutApplication::s_fragment_aggregator = "fragment_aggregator"

inlinestatic

Definition at line 220 of file ReadoutApplication.hpp.

s_link_handler

static const std::string dunedaq::appmodel::ReadoutApplication::s_link_handler = "link_handler"

inlinestatic

Definition at line 216 of file ReadoutApplication.hpp.

s_ta_generation_enabled

static const std::string dunedaq::appmodel::ReadoutApplication::s_ta_generation_enabled = "ta_generation_enabled"

inlinestatic

Definition at line 112 of file ReadoutApplication.hpp.

s_tp_generation_enabled

static const std::string dunedaq::appmodel::ReadoutApplication::s_tp_generation_enabled = "tp_generation_enabled"

inlinestatic

Definition at line 111 of file ReadoutApplication.hpp.

s_tp_handler

static const std::string dunedaq::appmodel::ReadoutApplication::s_tp_handler = "tp_handler"

inlinestatic

Definition at line 217 of file ReadoutApplication.hpp.

s_tp_source_ids

static const std::string dunedaq::appmodel::ReadoutApplication::s_tp_source_ids = "tp_source_ids"

inlinestatic

Definition at line 214 of file ReadoutApplication.hpp.

s_uses

static const std::string dunedaq::appmodel::ReadoutApplication::s_uses = "uses"

inlinestatic

Definition at line 215 of file ReadoutApplication.hpp.

---

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

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