DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
Public Member Functions | Static Public Member Functions | Static Public Attributes | Protected Member Functions | Private Attributes | Friends | List of all members
dunedaq::appmodel::ReadoutApplication Class Reference

#include <ReadoutApplication.hpp>

Inheritance diagram for dunedaq::appmodel::ReadoutApplication:
[legend]
Collaboration diagram for dunedaq::appmodel::ReadoutApplication:
[legend]

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.
 
virtual std::vector< const dunedaq::confmodel::DaqModule * > generate_modules (const confmodel::Session *) 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.
 
virtual std::vector< const dunedaq::confmodel::DaqModule * > generate_modules (const confmodel::Session *) const override
 
- Public Member Functions inherited from dunedaq::confmodel::ResourceSetAND
- Public Member Functions inherited from dunedaq::confmodel::ResourceSet
const std::vector< const dunedaq::confmodel::ResourceBase * > & get_contains () const
 Get "contains" relationship value. A resource set is a container of resources to easily implement group operations (add/remove, enable/disable).
 
void set_contains (const std::vector< const dunedaq::confmodel::ResourceBase * > &value)
 Set "contains" relationship value. A resource set is a container of resources to easily implement group operations (add/remove, enable/disable).
 
const std::vector< const dunedaq::confmodel::ResourceBase * > & get_contains () const
 Get "contains" relationship value. A resource set is a container of resources to easily implement group operations (add/remove, enable/disable).
 
void set_contains (const std::vector< const dunedaq::confmodel::ResourceBase * > &value)
 Set "contains" relationship value. A resource set is a container of resources to easily implement group operations (add/remove, enable/disable).
 
- Public Member Functions inherited from dunedaq::confmodel::ResourceBase
- Public Member Functions inherited from dunedaq::confmodel::Component
void get_parents (const dunedaq::confmodel::Session &session, std::list< std::vector< const dunedaq::confmodel::Component * > > &parents) const
 
bool disabled (const dunedaq::confmodel::Session &session) const
 
void get_parents (const dunedaq::confmodel::Session &session, std::list< std::vector< const dunedaq::confmodel::Component * > > &parents) const
 
bool disabled (const dunedaq::confmodel::Session &session) 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::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 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.
 
const std::vector< std::string > construct_commandline_parameters (const conffwk::Configuration &confdb, const dunedaq::confmodel::Session *session) const
 
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 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.
 
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
 

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_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 Public Member Functions inherited from dunedaq::confmodel::ResourceSet
static const std::string & __get_contains_str () noexcept
 
static const std::string & __get_contains_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 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_action_plans_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 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 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 Public Attributes inherited from dunedaq::confmodel::ResourceSetAND
static const std::string & s_class_name
 
- Static Public Attributes inherited from dunedaq::confmodel::ResourceSet
static const std::string & s_class_name
 
static const std::string s_contains = "contains"
 
- Static Public Attributes inherited from dunedaq::confmodel::ResourceBase
static const std::string & s_class_name
 
- Static Public Attributes inherited from dunedaq::confmodel::Component
static const std::string & s_class_name
 
- 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 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"
 

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::confmodel::ResourceSetAND
 ResourceSetAND (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~ResourceSetAND () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
 ResourceSetAND (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~ResourceSetAND () 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::ResourceBase
 ResourceBase (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~ResourceBase () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
 ResourceBase (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~ResourceBase () 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::Component
 Component (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~Component () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
 Component (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~Component () 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::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::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
 

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
 

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 41 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 35 of file ReadoutApplication.cpp.

35 :
36 dunedaq::conffwk::DalObject(db, o),
37 dunedaq::confmodel::ResourceSetAND(db, o),
38 SmartDaqApplication(db, o),
39 m_uses (nullptr),
40 m_link_handler (nullptr),
41 m_tp_handler (nullptr),
42 m_data_reader (nullptr),
43 m_data_recorder (nullptr)
44
45 {
46 ;
47 }
dunedaq::appmodel::ReadoutApplication::m_uses
const dunedaq::appmodel::RoHwConfig * m_uses
Definition ReadoutApplication.hpp:96
dunedaq::appmodel::ReadoutApplication::m_tp_handler
const dunedaq::appmodel::DataHandlerConf * m_tp_handler
Definition ReadoutApplication.hpp:98
dunedaq::appmodel::ReadoutApplication::m_data_reader
const dunedaq::appmodel::DataReaderConf * m_data_reader
Definition ReadoutApplication.hpp:99
dunedaq::appmodel::ReadoutApplication::m_data_recorder
const dunedaq::appmodel::DataRecorderConf * m_data_recorder
Definition ReadoutApplication.hpp:100
dunedaq::appmodel::ReadoutApplication::m_link_handler
const dunedaq::appmodel::DataHandlerConf * m_link_handler
Definition ReadoutApplication.hpp:97
dunedaq::appmodel::SmartDaqApplication::SmartDaqApplication
SmartDaqApplication(conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
Definition SmartDaqApplication.cpp:23
dunedaq::conffwk::DalObject
The base class for any generated DAL object.
Definition DalObject.hpp:45

◆ ~ReadoutApplication() [1/2]

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

Definition at line 112 of file ReadoutApplication.cpp.

113 {
114 }

◆ 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 111 of file ReadoutApplication.hpp.

111{ 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 111 of file ReadoutApplication.hpp.

111{ 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 222 of file ReadoutApplication.hpp.

222{ 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 222 of file ReadoutApplication.hpp.

222{ 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 223 of file ReadoutApplication.hpp.

223{ 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 223 of file ReadoutApplication.hpp.

223{ return s_data_recorder; }

◆ __get_link_handler_str() [1/2]

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

Definition at line 220 of file ReadoutApplication.hpp.

220{ 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 220 of file ReadoutApplication.hpp.

220{ 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 113 of file ReadoutApplication.hpp.

113{ return s_ta_generation_enabled; }
dunedaq::appmodel::ReadoutApplication::s_ta_generation_enabled
static const std::string s_ta_generation_enabled
Definition ReadoutApplication.hpp:109

◆ __get_ta_generation_enabled_str() [2/2]

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

Definition at line 113 of file ReadoutApplication.hpp.

113{ 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 112 of file ReadoutApplication.hpp.

112{ return s_tp_generation_enabled; }
dunedaq::appmodel::ReadoutApplication::s_tp_generation_enabled
static const std::string s_tp_generation_enabled
Definition ReadoutApplication.hpp:108

◆ __get_tp_generation_enabled_str() [2/2]

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

Definition at line 112 of file ReadoutApplication.hpp.

112{ 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 221 of file ReadoutApplication.hpp.

221{ 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 221 of file ReadoutApplication.hpp.

221{ 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 218 of file ReadoutApplication.hpp.

218{ 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 218 of file ReadoutApplication.hpp.

218{ return s_tp_source_ids; }

◆ __get_uses_str() [1/2]

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

Definition at line 219 of file ReadoutApplication.hpp.

219{ return s_uses; }

◆ __get_uses_str() [2/2]

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

Definition at line 219 of file ReadoutApplication.hpp.

219{ return s_uses; }

◆ generate_modules() [1/2]

std::vector< const confmodel::DaqModule * > dunedaq::appmodel::ReadoutApplication::generate_modules ( const confmodel::Session * session) const
overridevirtual

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

Reimplemented from dunedaq::appmodel::SmartDaqApplication.

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

Definition at line 71 of file ReadoutApplication.cpp.

72{
73
74 TLOG_DEBUG(6) << "Generating modules for application " << this->UID();
75
76 ConfigObjectFactory obj_fac(this);
77 // conffwk::Configuration& confdb = this->configuration();
78
79 //
80 // Extract basic configuration objects
81 //
82
83 // Data reader
84 auto reader_conf = get_data_reader();
85 if (reader_conf == 0) {
86 throw(BadConf(ERS_HERE, "No DataReaderModule configuration given"));
87 }
88 std::string reader_class = reader_conf->get_template_for();
89
90 // Link handler
91 auto dlh_conf = get_link_handler();
92 // What is template for?
93 auto dlh_class = dlh_conf->get_template_for();
94
95 auto tph_conf = get_tp_handler();
96 if (tph_conf==nullptr && get_tp_generation_enabled()) {
97 throw(BadConf(ERS_HERE, "TP generation is enabled but there is no TP data handler configuration"));
98 }
99
100 std::string tph_class = "";
101 if (tph_conf != nullptr && get_tp_generation_enabled()) {
102 tph_class = tph_conf->get_template_for();
103 }
104
105 //
106 // Process the queue rules looking for inputs to our DL/TP handler modules
107 //
108 const QueueDescriptor* dlh_input_qdesc = nullptr;
109 const QueueDescriptor* dlh_reqinput_qdesc = nullptr;
110 const QueueDescriptor* tp_input_qdesc = nullptr;
111 // const QueueDescriptor* tpReqInputQDesc = nullptr;
112 const QueueDescriptor* fa_output_qdesc = nullptr;
113
114 for (auto rule : get_queue_rules()) {
115 auto destination_class = rule->get_destination_class();
116 auto data_type = rule->get_descriptor()->get_data_type();
117 // Why datahander here?
118 if (destination_class == "DataHandlerModule" || destination_class == dlh_class || destination_class == tph_class) {
119 if (data_type == "DataRequest") {
120 dlh_reqinput_qdesc = rule->get_descriptor();
121 } else if ((data_type == "TriggerPrimitive" || data_type == "TriggerPrimitiveVector") && get_tp_generation_enabled()) {
122 tp_input_qdesc = rule->get_descriptor();
123 } else {
124 dlh_input_qdesc = rule->get_descriptor();
125 }
126 } else if (destination_class == "FragmentAggregatorModule") {
127 fa_output_qdesc = rule->get_descriptor();
128 }
129 }
130
131 //
132 // Process the network rules looking for the Fragment Aggregator and TP handler data reuest inputs
133 //
134 const NetworkConnectionDescriptor* fa_net_desc = nullptr;
135 const NetworkConnectionDescriptor* tp_net_desc = nullptr;
136 const NetworkConnectionDescriptor* ta_net_desc = nullptr;
137 const NetworkConnectionDescriptor* ts_net_desc = nullptr;
138 for (auto rule : get_network_rules()) {
139 auto endpoint_class = rule->get_endpoint_class();
140 auto data_type = rule->get_descriptor()->get_data_type();
141
142 if (endpoint_class == "FragmentAggregatorModule") {
143 fa_net_desc = rule->get_descriptor();
144 } else if (data_type == "TPSet") {
145 tp_net_desc = rule->get_descriptor();
146 } else if (data_type == "TriggerActivity") {
147 ta_net_desc = rule->get_descriptor();
148 } else if (data_type == "TimeSync") {
149 ts_net_desc = rule->get_descriptor();
150 }
151 }
152
153 // Create here the Queue on which all data fragments are forwarded to the fragment aggregator
154 // and a container for the queues of data request to TP handler and DLH
155 if (fa_output_qdesc == nullptr) {
156 throw(BadConf(ERS_HERE, "No fragment output queue descriptor given"));
157 }
158 std::vector<const confmodel::Connection*> req_queues;
159 conffwk::ConfigObject frag_queue_obj = obj_fac.create_queue_obj(fa_output_qdesc);
160
161 //
162 // Scan Detector 2 DAQ connections to extract sender, receiver and stream information
163 //
164
165 std::vector<const confmodel::DaqModule*> modules;
166
167 // Loop over the detector to daq connections and generate one data reader per connection
168 // and the cooresponding datalink handlers
169
170 // Collect all streams
171 std::vector<const confmodel::DetectorStream*> all_enabled_det_streams;
172 std::map<uint32_t, const confmodel::Connection*> data_queues_by_sid;
173
174 // std::vector<const conffwk::ConfigObject*> d2d_conn_objs;
175 uint16_t conn_idx = 0;
176
177 for (auto d2d_conn_res : get_contains()) {
178
179 // Are we sure?
180 if (d2d_conn_res->disabled(*session)) {
181 TLOG_DEBUG(7) << "Ignoring disabled DetectorToDaqConnection " << d2d_conn_res->UID();
182 continue;
183 }
184
185 // d2d_conn_objs.push_back(&d2d_conn_res->config_object());
186
187 TLOG_DEBUG(6) << "Processing DetectorToDaqConnection " << d2d_conn_res->UID();
188 // get the readout groups and the interfaces and streams therein; 1 reaout group corresponds to 1 data reader module
189 auto d2d_conn = d2d_conn_res->cast<confmodel::DetectorToDaqConnection>();
190
191 if (!d2d_conn) {
192 throw(BadConf(ERS_HERE, "ReadoutApplication contains something other than DetectorToDaqConnection"));
193 }
194
195 if (d2d_conn->get_contains().empty()) {
196 throw(BadConf(ERS_HERE, "DetectorToDaqConnection does not contain sebders or receivers"));
197 }
198
199 // Loop over detector 2 daq connections to find senders and receivers
200 auto det_senders = d2d_conn->get_senders();
201 auto det_receiver = d2d_conn->get_receiver();
202
203 std::vector<const confmodel::DetectorStream*> enabled_det_streams;
204 // Loop over senders
205 for (auto stream : d2d_conn->get_streams()) {
206
207 // Are we sure?
208 if (stream->disabled(*session)) {
209 TLOG_DEBUG(7) << "Ignoring disabled DetectorStream " << stream->UID();
210 continue;
211 }
212
213 // loop over streams
214 all_enabled_det_streams.push_back(stream);
215 enabled_det_streams.push_back(stream);
216 }
217
218
219
220 // Here I want to resolve the type of connection (network, felix, or?)
221 // Rules of engagement: if the receiver interface is network or felix, the receivers should be castable to the counterpart
222 if (reader_class == "DPDKReaderModule" || reader_class == "SocketReaderModule") {
223 if ((reader_class == "DPDKReaderModule" && !det_receiver->cast<appmodel::DPDKReceiver>()) ||
224 (reader_class == "SocketReaderModule" && !det_receiver->cast<appmodel::SocketReceiver>())) {
225 throw(BadConf(ERS_HERE, fmt::format("{} requires NWDetDataReceiver, found {} of class {}", reader_class, det_receiver->UID(), det_receiver->class_name())));
226 }
227
228 bool all_nw_senders = true;
229 for (auto s : det_senders) {
230 all_nw_senders &= (s->cast<appmodel::NWDetDataSender>() != nullptr);
231 }
232
233 // Ensure that all senders are compatible with receiver
234 if (!all_nw_senders) {
235 throw(BadConf(ERS_HERE, "Non-network DetDataSener found with NWreceiver"));
236 }
237 }
238 else if (reader_class == "FelixReaderModule") {
239 if (!det_receiver->cast<appmodel::FelixDataReceiver>()) {
240 throw(BadConf(ERS_HERE, fmt::format("FelixReaderModule requires FelixDataReceiver, found {} of class {}", det_receiver->UID(), det_receiver->class_name())));
241 }
242
243 bool all_flx_senders = true;
244 for (auto s : det_senders) {
245 all_flx_senders &= (s->cast<appmodel::FelixDataSender>() != nullptr);
246 }
247
248 // Ensure that all senders are compatible with receiver
249 if (!all_flx_senders) {
250 throw(BadConf(ERS_HERE, "Non-felix DetDataSener found with FelixDataReceiver"));
251 }
252 }
253 // }
254
255 //-----------------------------------------------------------------
256 //
257 // Create DataReaderModule object
258 //
259
260 //
261 // Instantiate DataReaderModule of type DPDKReaderModule
262 //
263
264 // Create the Data reader object
265
266 std::string reader_uid(fmt::format("datareader-{}-{}", this->UID(), std::to_string(conn_idx++)));
267 TLOG_DEBUG(6) << fmt::format("creating OKS configuration object for Data reader class {} with id {}", reader_class, reader_uid);
268 auto reader_obj = obj_fac.create(reader_class, reader_uid);
269
270 // Populate configuration and interfaces (leave output queues for later)
271 reader_obj.set_obj("configuration", &reader_conf->config_object());
272 reader_obj.set_objs("connections", {&d2d_conn_res->config_object()});
273
274 // Create the raw data queues
275 std::vector<const conffwk::ConfigObject*> data_queue_objs;
276 // keep a map for convenience
277
278 // Create data queues
279 for (auto ds : enabled_det_streams) {
280 conffwk::ConfigObject queue_obj = obj_fac.create_queue_sid_obj(dlh_input_qdesc, ds);
281 const auto* data_queue = obj_fac.get_dal<confmodel::Connection>(queue_obj.UID());
282 data_queue_objs.push_back(&data_queue->config_object());
283 data_queues_by_sid[ds->get_source_id()] = data_queue;
284 }
285
286 reader_obj.set_objs("outputs", data_queue_objs);
287
288 modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(reader_obj.UID()));
289
290 }
291
292
293 //-----------------------------------------------------------------
294 //
295 // Prepare the tp handlers and related queues
296 //
297 std::vector<const confmodel::Connection*> tp_queues;
298 if (get_tp_generation_enabled()) {
299
300 // Create TP handler object
301 auto tph_conf_obj = tph_conf->config_object();
302 auto tpsrc_ids = get_tp_source_ids();
303
304 for (auto sid : tpsrc_ids) {
305 conffwk::ConfigObject tp_queue_obj;
306 conffwk::ConfigObject tpreq_queue_obj;
307 std::string tp_uid("tphandler-" + std::to_string(sid->get_sid()));
308 auto tph_obj = obj_fac.create(tph_class, tp_uid);
309 tph_obj.set_by_val<uint32_t>("source_id", sid->get_sid());
310 tph_obj.set_by_val<uint32_t>("detector_id", 1); // 1 == kDAQ
311 tph_obj.set_by_val<bool>("post_processing_enabled", get_ta_generation_enabled());
312 tph_obj.set_obj("module_configuration", &tph_conf_obj);
313
314 // Create the TPs aggregator queue (from RawData Handlers to TP handlers)
315 tp_queue_obj = obj_fac.create_queue_sid_obj(tp_input_qdesc, sid->get_sid());
316 tp_queue_obj.set_by_val<uint32_t>("recv_timeout_ms", 50);
317 tp_queue_obj.set_by_val<uint32_t>("send_timeout_ms", 1);
318
319 tp_queues.push_back(obj_fac.get_dal<confmodel::Connection>(tp_queue_obj.UID()));
320 // Create tp data requests queue from Fragment Aggregator
321 tpreq_queue_obj = obj_fac.create_queue_sid_obj(dlh_reqinput_qdesc, sid->get_sid());
322 req_queues.push_back(obj_fac.get_dal<confmodel::Connection>(tpreq_queue_obj.UID()));
323
324 // Create the tp(set) publishing service
325 conffwk::ConfigObject tp_net_obj = obj_fac.create_net_obj(tp_net_desc, tp_uid);
326
327 // Create the ta(set) publishing service
328 conffwk::ConfigObject ta_net_obj = obj_fac.create_net_obj(ta_net_desc, tp_uid);
329
330 // Register queues with tp hankder
331 tph_obj.set_objs("inputs", { &tp_queue_obj, &tpreq_queue_obj });
332 tph_obj.set_objs("outputs", { &tp_net_obj, &ta_net_obj, &frag_queue_obj });
333 modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(tph_obj.UID()));
334 }
335 }
336
337 // Add output queueus of tps
338 std::vector<const conffwk::ConfigObject*> tp_queue_objs;
339 for (auto q : tp_queues) {
340 tp_queue_objs.push_back(&q->config_object());
341 }
342
343 //-----------------------------------------------------------------
344 //
345 // Create datalink handlers
346 //
347 // Recover the emulation flag
348 auto emulation_mode = reader_conf->get_emulation_mode();
349 for (auto ds : all_enabled_det_streams) {
350
351 uint32_t sid = ds->get_source_id();
352 TLOG_DEBUG(6) << fmt::format("Processing stream {}, id {}, det id {}", ds->UID(), ds->get_source_id(), ds->get_geo_id()->get_detector_id());
353 std::string uid(fmt::format("DLH-{}", sid));
354 TLOG_DEBUG(6) << fmt::format("creating OKS configuration object for Data Link Handler class {}, if {}", dlh_class, sid);
355 auto dlh_obj = obj_fac.create(dlh_class, uid);
356 dlh_obj.set_by_val<uint32_t>("source_id", sid);
357 dlh_obj.set_by_val<uint32_t>("detector_id", ds->get_geo_id()->get_detector_id());
358 dlh_obj.set_by_val<bool>("post_processing_enabled", get_tp_generation_enabled());
359 dlh_obj.set_by_val<bool>("emulation_mode", emulation_mode);
360 dlh_obj.set_obj("geo_id", &ds->get_geo_id()->config_object());
361 dlh_obj.set_obj("module_configuration", &dlh_conf->config_object());
362
363 std::vector<const conffwk::ConfigObject*> dlh_ins, dlh_outs;
364
365 // Add datalink-handler queue to the inputs
366 dlh_ins.push_back(&data_queues_by_sid.at(sid)->config_object());
367
368 // Create request queue
369 conffwk::ConfigObject req_queue_obj = obj_fac.create_queue_sid_obj(dlh_reqinput_qdesc, ds);
370
371
372 // Add the requessts queue dal pointer to the outputs of the FragmentAggregatorModule
373 req_queues.push_back(obj_fac.get_dal<confmodel::Connection>(req_queue_obj.UID()));
374 dlh_ins.push_back(&req_queue_obj);
375 dlh_outs.push_back(&frag_queue_obj);
376
377
378 // Time Sync network connection
379 if (dlh_conf->get_generate_timesync()) {
380 // Add timestamp endpoint
381 conffwk::ConfigObject ts_net_obj = obj_fac.create_net_obj(ts_net_desc, std::to_string(sid));
382 dlh_outs.push_back(&ts_net_obj);
383 }
384
385 for (auto tpq : tp_queue_objs) {
386 dlh_outs.push_back(tpq);
387 }
388 dlh_obj.set_objs("inputs", dlh_ins);
389 dlh_obj.set_objs("outputs", dlh_outs);
390
391 modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(dlh_obj.UID()));
392 }
393
394
395 // Finally create Fragment Aggregator
396 std::string faUid("fragmentaggregator-" + UID());
397 // conffwk::ConfigObject frag_aggr;
398 TLOG_DEBUG(7) << "creating OKS configuration object for Fragment Aggregator class ";
399 auto frag_aggr = obj_fac.create("FragmentAggregatorModule", faUid);
400 conffwk::ConfigObject fa_net_obj = obj_fac.create_net_obj(fa_net_desc);
401
402 // Process special Network rules!
403 // Looking for Fragment rules from DFAppplications in current Session
404 auto sessionApps = session->get_enabled_applications();
405 std::vector<conffwk::ConfigObject> fragOutObjs;
406 for (auto app : sessionApps) {
407 auto dfapp = app->cast<appmodel::DFApplication>();
408 if (dfapp == nullptr)
409 continue;
410
411 auto dfNRules = dfapp->get_network_rules();
412 for (auto rule : dfNRules) {
413 auto descriptor = rule->get_descriptor();
414 auto data_type = descriptor->get_data_type();
415 if (data_type == "Fragment") {
416 std::string dreqNetUid(descriptor->get_uid_base() + dfapp->UID());
417 // conffwk::ConfigObject frag_conn;
418 // confdb.create(dbfile, "NetworkConnection", dreqNetUid, frag_conn);
419 auto frag_conn = obj_fac.create("NetworkConnection", dreqNetUid);
420
421 frag_conn.set_by_val<std::string>("data_type", descriptor->get_data_type());
422 frag_conn.set_by_val<std::string>("connection_type", descriptor->get_connection_type());
423
424 auto serviceObj = descriptor->get_associated_service()->config_object();
425 frag_conn.set_obj("associated_service", &serviceObj);
426 fragOutObjs.push_back(frag_conn);
427 } // If network rule has TriggerDecision type of data
428 } // Loop over Apps network rules
429 } // loop over Session specific Apps
430
431 // Add output queueus of data requests and Fragments
432 std::vector<const conffwk::ConfigObject*> fa_output_objs;
433 for (auto& fNet : fragOutObjs) {
434 fa_output_objs.push_back(&fNet);
435 }
436
437 for (auto& q : req_queues) {
438 fa_output_objs.push_back(&q->config_object());
439 }
440
441 frag_aggr.set_objs("inputs", { &fa_net_obj, &frag_queue_obj });
442 frag_aggr.set_objs("outputs", fa_output_objs);
443
444 modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(frag_aggr.UID()));
445
446 return modules;
447}
ERS_HERE
#define ERS_HERE
Definition LocalContext.hpp:130
dunedaq::appmodel::ReadoutApplication::get_tp_handler
const dunedaq::appmodel::DataHandlerConf * get_tp_handler() const
Get "tp_handler" relationship value.
Definition ReadoutApplication.hpp:322
dunedaq::appmodel::ReadoutApplication::get_ta_generation_enabled
bool get_ta_generation_enabled() const
Get "ta_generation_enabled" attribute value.
Definition ReadoutApplication.hpp:185
dunedaq::appmodel::ReadoutApplication::get_tp_source_ids
const std::vector< const dunedaq::appmodel::SourceIDConf * > & get_tp_source_ids() const
Get "tp_source_ids" relationship value.
Definition ReadoutApplication.hpp:233
dunedaq::appmodel::ReadoutApplication::get_link_handler
const dunedaq::appmodel::DataHandlerConf * get_link_handler() const
Get "link_handler" relationship value.
Definition ReadoutApplication.hpp:291
dunedaq::appmodel::ReadoutApplication::get_data_reader
const dunedaq::appmodel::DataReaderConf * get_data_reader() const
Get "data_reader" relationship value.
Definition ReadoutApplication.hpp:347
dunedaq::appmodel::ReadoutApplication::get_tp_generation_enabled
bool get_tp_generation_enabled() const
Get "tp_generation_enabled" attribute value.
Definition ReadoutApplication.hpp:154
dunedaq::appmodel::SmartDaqApplication::get_network_rules
const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > & get_network_rules() const
Get "network_rules" relationship value.
Definition SmartDaqApplication.hpp:176
dunedaq::appmodel::SmartDaqApplication::get_queue_rules
const std::vector< const dunedaq::appmodel::QueueConnectionRule * > & get_queue_rules() const
Get "queue_rules" relationship value.
Definition SmartDaqApplication.hpp:151
dunedaq::conffwk::DalObject::UID
const std::string & UID() const noexcept
Definition DalObject.hpp:128
dunedaq::confmodel::ResourceSet::get_contains
const std::vector< const dunedaq::confmodel::ResourceBase * > & get_contains() const
Get "contains" relationship value. A resource set is a container of resources to easily implement gro...
Definition ResourceSet.hpp:94
TLOG_DEBUG
#define TLOG_DEBUG(lvl,...)
Definition Logging.hpp:112

◆ generate_modules() [2/2]

virtual std::vector< const dunedaq::confmodel::DaqModule * > dunedaq::appmodel::ReadoutApplication::generate_modules ( const confmodel::Session * ) const
overridevirtual

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

Reimplemented from dunedaq::appmodel::SmartDaqApplication.

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

◆ 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
namename of the relationship or algorithm
Returns
value of relationship or result of algorithm
Exceptions
std::exceptionif there is no relationship or algorithm with such name in this and base classes

Reimplemented from dunedaq::confmodel::ResourceSetAND.

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

Definition at line 116 of file ReadoutApplication.cpp.

117 {
118 std::vector<const dunedaq::conffwk::DalObject *> vec;
119
120 if (!get(name, vec, upcast_unregistered, true))
121 throw_get_ex(name, s_class_name, this);
122
123 return vec;
124 }
dunedaq::appmodel::ReadoutApplication::get
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...
Definition ReadoutApplication.cpp:116
dunedaq::conffwk::DalObject::throw_get_ex
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.
Definition DalObject.cpp:82

◆ 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
namename of the relationship or algorithm
Returns
value of relationship or result of algorithm
Exceptions
std::exceptionif there is no relationship or algorithm with such name in this and base classes

Reimplemented from dunedaq::confmodel::ResourceSetAND.

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 126 of file ReadoutApplication.cpp.

127 {
128 if (first_call)
129 {
130 std::lock_guard scoped_lock(m_mutex);
131
132 check();
133 check_init();
134
135 if (get_rel_objects(name, upcast_unregistered, vec))
136 return true;
137 }
138
139 if (ResourceSetAND::get(name, vec, upcast_unregistered, false)) return true;
140 if (SmartDaqApplication::get(name, vec, upcast_unregistered, false)) return true;
141
142 if (first_call)
143 return get_algo_objects(name, vec);
144
145 return false;
146 }
dunedaq::appmodel::SmartDaqApplication::get
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...
Definition SmartDaqApplication.cpp:83
dunedaq::conffwk::DalObject::get_rel_objects
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.
Definition DalObject.cpp:8
dunedaq::conffwk::DalObject::m_mutex
std::mutex m_mutex
Used to protect changes of DAL object.
Definition DalObject.hpp:108
dunedaq::conffwk::DalObject::get_algo_objects
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.
Definition DalObject.cpp:25
dunedaq::conffwk::DalObject::check_init
void check_init() const
Check and initialize object if necessary.
Definition DalObject.hpp:405

◆ 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 123 of file ReadoutApplication.hpp.

124 {
125 std::lock_guard scoped_lock(m_mutex);
126 check();
127 check_init();
128 return m_application_name;
129 }

◆ 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 123 of file ReadoutApplication.hpp.

124 {
125 std::lock_guard scoped_lock(m_mutex);
126 check();
127 check_init();
128 return m_application_name;
129 }

◆ 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 347 of file ReadoutApplication.hpp.

348 {
349 std::lock_guard scoped_lock(m_mutex);
350 check();
351 check_init();
352 if (!m_data_reader)
353 {
354 std::ostringstream text;
355 text << "relationship \"" << s_data_reader << "\" of object " << this << " is not set";
356 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
357 }
358 return m_data_reader;
359 }
Generic
Generic configuration exception.

◆ 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 347 of file ReadoutApplication.hpp.

348 {
349 std::lock_guard scoped_lock(m_mutex);
350 check();
351 check_init();
352 if (!m_data_reader)
353 {
354 std::ostringstream text;
355 text << "relationship \"" << s_data_reader << "\" of object " << this << " is not set";
356 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
357 }
358 return m_data_reader;
359 }

◆ 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 378 of file ReadoutApplication.hpp.

379 {
380 std::lock_guard scoped_lock(m_mutex);
381 check();
382 check_init();
383 return m_data_recorder;
384 }

◆ 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 378 of file ReadoutApplication.hpp.

379 {
380 std::lock_guard scoped_lock(m_mutex);
381 check();
382 check_init();
383 return m_data_recorder;
384 }

◆ 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 291 of file ReadoutApplication.hpp.

292 {
293 std::lock_guard scoped_lock(m_mutex);
294 check();
295 check_init();
296 if (!m_link_handler)
297 {
298 std::ostringstream text;
299 text << "relationship \"" << s_link_handler << "\" of object " << this << " is not set";
300 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
301 }
302 return m_link_handler;
303 }

◆ 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 291 of file ReadoutApplication.hpp.

292 {
293 std::lock_guard scoped_lock(m_mutex);
294 check();
295 check_init();
296 if (!m_link_handler)
297 {
298 std::ostringstream text;
299 text << "relationship \"" << s_link_handler << "\" of object " << this << " is not set";
300 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
301 }
302 return m_link_handler;
303 }

◆ 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 185 of file ReadoutApplication.hpp.

186 {
187 std::lock_guard scoped_lock(m_mutex);
188 check();
189 check_init();
190 return m_ta_generation_enabled;
191 }

◆ 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 185 of file ReadoutApplication.hpp.

186 {
187 std::lock_guard scoped_lock(m_mutex);
188 check();
189 check_init();
190 return m_ta_generation_enabled;
191 }

◆ 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 154 of file ReadoutApplication.hpp.

155 {
156 std::lock_guard scoped_lock(m_mutex);
157 check();
158 check_init();
159 return m_tp_generation_enabled;
160 }

◆ 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 154 of file ReadoutApplication.hpp.

155 {
156 std::lock_guard scoped_lock(m_mutex);
157 check();
158 check_init();
159 return m_tp_generation_enabled;
160 }

◆ 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 322 of file ReadoutApplication.hpp.

323 {
324 std::lock_guard scoped_lock(m_mutex);
325 check();
326 check_init();
327 return m_tp_handler;
328 }

◆ 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 322 of file ReadoutApplication.hpp.

323 {
324 std::lock_guard scoped_lock(m_mutex);
325 check();
326 check_init();
327 return m_tp_handler;
328 }

◆ 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 233 of file ReadoutApplication.hpp.

234 {
235 std::lock_guard scoped_lock(m_mutex);
236 check();
237 check_init();
238 return m_tp_source_ids;
239 }
dunedaq::appmodel::ReadoutApplication::m_tp_source_ids
std::vector< const dunedaq::appmodel::SourceIDConf * > m_tp_source_ids
Definition ReadoutApplication.hpp:95

◆ 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 233 of file ReadoutApplication.hpp.

234 {
235 std::lock_guard scoped_lock(m_mutex);
236 check();
237 check_init();
238 return m_tp_source_ids;
239 }

◆ 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 259 of file ReadoutApplication.hpp.

260 {
261 std::lock_guard scoped_lock(m_mutex);
262 check();
263 check_init();
264 if (!m_uses)
265 {
266 std::ostringstream text;
267 text << "relationship \"" << s_uses << "\" of object " << this << " is not set";
268 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
269 }
270 return m_uses;
271 }

◆ 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 259 of file ReadoutApplication.hpp.

260 {
261 std::lock_guard scoped_lock(m_mutex);
262 check();
263 check_init();
264 if (!m_uses)
265 {
266 std::ostringstream text;
267 text << "relationship \"" << s_uses << "\" of object " << this << " is not set";
268 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
269 }
270 return m_uses;
271 }

◆ init() [1/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Reimplemented from dunedaq::confmodel::ResourceSetAND.

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

Definition at line 89 of file ReadoutApplication.cpp.

90 {
91 ResourceSetAND::init(init_children);
92 SmartDaqApplication::init(init_children);
93
94 TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
95
96 try {
97 p_obj.get(s_application_name, m_application_name);
98 p_obj.get(s_tp_generation_enabled, m_tp_generation_enabled);
99 p_obj.get(s_ta_generation_enabled, m_ta_generation_enabled);
100 p_registry._ref<dunedaq::appmodel::SourceIDConf>(p_obj, s_tp_source_ids, m_tp_source_ids, init_children);
101 m_uses = p_registry._ref<dunedaq::appmodel::RoHwConfig>(p_obj, s_uses, init_children);
102 m_link_handler = p_registry._ref<dunedaq::appmodel::DataHandlerConf>(p_obj, s_link_handler, init_children);
103 m_tp_handler = p_registry._ref<dunedaq::appmodel::DataHandlerConf>(p_obj, s_tp_handler, init_children);
104 m_data_reader = p_registry._ref<dunedaq::appmodel::DataReaderConf>(p_obj, s_data_reader, init_children);
105 m_data_recorder = p_registry._ref<dunedaq::appmodel::DataRecorderConf>(p_obj, s_data_recorder, init_children);
106 }
107 catch (dunedaq::conffwk::Exception & ex) {
108 throw_init_ex(ex);
109 }
110 }
dunedaq::appmodel::SmartDaqApplication::init
virtual void init(bool init_children)
Definition SmartDaqApplication.cpp:62
dunedaq::conffwk::ConfigObject::get
void get(const std::string &name, T &value)
Get value of object's attribute or relationship.
Definition ConfigObject.hpp:278
dunedaq::conffwk::DalObject::throw_init_ex
void throw_init_ex(dunedaq::conffwk::Exception &ex)
throw object initialisation exception (i.e.
Definition DalObject.cpp:74
dunedaq::conffwk::DalObject::p_registry
DalRegistry & p_registry
Configuration object.
Definition DalObject.hpp:114
dunedaq::conffwk::DalObject::p_obj
ConfigObject p_obj
Config object used by given template object.
Definition DalObject.hpp:117
dunedaq::conffwk::DalRegistry::_ref
const T * _ref(ConfigObject &obj, const std::string &name, bool read_children)
Get signle value of object's relation and instantiate result with it (multi-thread safe).
Definition DalRegistry.hxx:164

◆ init() [2/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Reimplemented from dunedaq::confmodel::ResourceSetAND.

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
offsetnumber of spaces to shift object right (useful to print nested objects)
print_headerif false, do not print object header (to print attributes of base classes)
soutput stream

Reimplemented from dunedaq::confmodel::ResourceSetAND.

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

Definition at line 50 of file ReadoutApplication.cpp.

51 {
52 check_init();
53
54 try {
55 const std::string str(indent+2, ' ');
56
57 if (print_header)
58 p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
59
60
61 // print direct super-classes
62
63 dunedaq::confmodel::ResourceSetAND::print(indent, false, s);
64 dunedaq::appmodel::SmartDaqApplication::print(indent, false, s);
65
66
67 // print direct attributes
68
69 dunedaq::conffwk::p_sv_attr(s, str, s_application_name, m_application_name);
70 dunedaq::conffwk::p_sv_attr(s, str, s_tp_generation_enabled, m_tp_generation_enabled);
71 dunedaq::conffwk::p_sv_attr(s, str, s_ta_generation_enabled, m_ta_generation_enabled);
72
73
74 // print direct relationships
75
76 dunedaq::conffwk::p_mv_rel(s, str, s_tp_source_ids, m_tp_source_ids);
77 dunedaq::conffwk::p_sv_rel(s, str, indent, s_uses, m_uses);
78 dunedaq::conffwk::p_sv_rel(s, str, s_link_handler, m_link_handler);
79 dunedaq::conffwk::p_sv_rel(s, str, s_tp_handler, m_tp_handler);
80 dunedaq::conffwk::p_sv_rel(s, str, s_data_reader, m_data_reader);
81 dunedaq::conffwk::p_sv_rel(s, str, s_data_recorder, m_data_recorder);
82 }
83 catch (dunedaq::conffwk::Exception & ex) {
84 dunedaq::conffwk::DalObject::p_error(s, ex);
85 }
86 }
dunedaq::appmodel::SmartDaqApplication::print
virtual void print(unsigned int offset, bool print_header, std::ostream &s) const
Print details of the SmartDaqApplication object.
Definition SmartDaqApplication.cpp:33
dunedaq::conffwk::DalObject::p_hdr
void p_hdr(std::ostream &s, unsigned int indent, const std::string &cl, const char *nm=nullptr) const
print object headers
Definition DalObject.cpp:65
dunedaq::conffwk::DalObject::p_error
static void p_error(std::ostream &s, dunedaq::conffwk::Exception &ex)
print error text
Definition DalObject.cpp:59
dunedaq::confmodel::ResourceSetAND::print
virtual void print(unsigned int offset, bool print_header, std::ostream &s) const
Print details of the ResourceSetAND object.
Definition ResourceSetAND.cpp:35
dunedaq::conffwk::p_sv_rel
void p_sv_rel(std::ostream &s, const std::string &str, const std::string &name, const DalObject *obj)
print weak single-value relationship
Definition DalObject.cpp:105
dunedaq::conffwk::p_mv_rel
void p_mv_rel(std::ostream &s, const std::string &str, const std::string &name, const T &objs) noexcept
print weak multi-value relationship
Definition DalObjectPrint.hpp:114
dunedaq::conffwk::p_sv_attr
void p_sv_attr(std::ostream &s, const std::string &str, const std::string &name, const T &val) noexcept
print single-value attribute
Definition DalObjectPrint.hpp:61

◆ 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
offsetnumber of spaces to shift object right (useful to print nested objects)
print_headerif false, do not print object header (to print attributes of base classes)
soutput stream

Reimplemented from dunedaq::confmodel::ResourceSetAND.

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
valuenew attribute value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 138 of file ReadoutApplication.hpp.

139 {
140 std::lock_guard scoped_lock(m_mutex);
141 check();
142 clear();
143 p_obj.set_by_ref(s_application_name, value);
144 }
dunedaq::conffwk::ConfigObject::set_by_ref
void set_by_ref(const std::string &name, T &value)
Set attribute value.
Definition ConfigObject.hpp:412

◆ set_application_name() [2/2]

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

Set "application_name" attribute value.

Parameters
valuenew attribute value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 138 of file ReadoutApplication.hpp.

139 {
140 std::lock_guard scoped_lock(m_mutex);
141 check();
142 clear();
143 p_obj.set_by_ref(s_application_name, value);
144 }

◆ set_data_reader() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_data_reader ( const dunedaq::appmodel::DataReaderConf * value)

Set "data_reader" relationship value.

Parameters
valuenew relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 168 of file ReadoutApplication.cpp.

169 {
170 _set_object(s_data_reader, value);
171 }
dunedaq::conffwk::DalObject::_set_object
void _set_object(const std::string &name, const T *value)
Helper method for generated set single-value relationship methods.
Definition DalObject.hpp:417

◆ set_data_reader() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_data_reader ( const dunedaq::appmodel::DataReaderConf * value)

Set "data_reader" relationship value.

Parameters
valuenew 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
valuenew relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 173 of file ReadoutApplication.cpp.

174 {
175 _set_object(s_data_recorder, value);
176 }

◆ set_data_recorder() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_data_recorder ( const dunedaq::appmodel::DataRecorderConf * value)

Set "data_recorder" relationship value.

Parameters
valuenew 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
valuenew relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 158 of file ReadoutApplication.cpp.

159 {
160 _set_object(s_link_handler, value);
161 }

◆ set_link_handler() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_link_handler ( const dunedaq::appmodel::DataHandlerConf * value)

Set "link_handler" relationship value.

Parameters
valuenew 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
valuenew attribute value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 200 of file ReadoutApplication.hpp.

201 {
202 std::lock_guard scoped_lock(m_mutex);
203 check();
204 clear();
205 p_obj.set_by_val(s_ta_generation_enabled, value);
206 }
dunedaq::conffwk::ConfigObject::set_by_val
void set_by_val(const std::string &name, T value)
Set attribute value.
Definition ConfigObject.hpp:391

◆ set_ta_generation_enabled() [2/2]

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

Set "ta_generation_enabled" attribute value.

Parameters
valuenew attribute value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 200 of file ReadoutApplication.hpp.

201 {
202 std::lock_guard scoped_lock(m_mutex);
203 check();
204 clear();
205 p_obj.set_by_val(s_ta_generation_enabled, value);
206 }

◆ set_tp_generation_enabled() [1/2]

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

Set "tp_generation_enabled" attribute value.

Parameters
valuenew attribute value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 169 of file ReadoutApplication.hpp.

170 {
171 std::lock_guard scoped_lock(m_mutex);
172 check();
173 clear();
174 p_obj.set_by_val(s_tp_generation_enabled, value);
175 }

◆ set_tp_generation_enabled() [2/2]

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

Set "tp_generation_enabled" attribute value.

Parameters
valuenew attribute value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 169 of file ReadoutApplication.hpp.

170 {
171 std::lock_guard scoped_lock(m_mutex);
172 check();
173 clear();
174 p_obj.set_by_val(s_tp_generation_enabled, value);
175 }

◆ set_tp_handler() [1/2]

void dunedaq::appmodel::ReadoutApplication::set_tp_handler ( const dunedaq::appmodel::DataHandlerConf * value)

Set "tp_handler" relationship value.

Parameters
valuenew relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 163 of file ReadoutApplication.cpp.

164 {
165 _set_object(s_tp_handler, value);
166 }

◆ set_tp_handler() [2/2]

void dunedaq::appmodel::ReadoutApplication::set_tp_handler ( const dunedaq::appmodel::DataHandlerConf * value)

Set "tp_handler" relationship value.

Parameters
valuenew 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
valuenew relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 148 of file ReadoutApplication.cpp.

149 {
150 _set_objects(s_tp_source_ids, value);
151 }
dunedaq::conffwk::DalObject::_set_objects
void _set_objects(const std::string &name, const std::vector< const T * > &value)
Helper method for generated set multi-value relationship methods.
Definition DalObject.hpp:428

◆ 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
valuenew 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
valuenew relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 153 of file ReadoutApplication.cpp.

154 {
155 _set_object(s_uses, value);
156 }

◆ 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
valuenew relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Friends And Related Symbol Documentation

◆ conffwk::Configuration

conffwk::Configuration
friend

Definition at line 43 of file ReadoutApplication.hpp.

◆ conffwk::DalFactory

conffwk::DalFactory
friend

Definition at line 45 of file ReadoutApplication.hpp.

◆ conffwk::DalObject

conffwk::DalObject
friend

Definition at line 44 of file ReadoutApplication.hpp.

◆ conffwk::DalRegistry

conffwk::DalRegistry
friend

Definition at line 46 of file ReadoutApplication.hpp.

Member Data Documentation

◆ m_application_name

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

Definition at line 92 of file ReadoutApplication.hpp.

◆ m_data_reader

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

Definition at line 99 of file ReadoutApplication.hpp.

◆ m_data_recorder

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

Definition at line 100 of file ReadoutApplication.hpp.

◆ m_link_handler

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

Definition at line 97 of file ReadoutApplication.hpp.

◆ m_ta_generation_enabled

bool dunedaq::appmodel::ReadoutApplication::m_ta_generation_enabled
private

Definition at line 94 of file ReadoutApplication.hpp.

◆ m_tp_generation_enabled

bool dunedaq::appmodel::ReadoutApplication::m_tp_generation_enabled
private

Definition at line 93 of file ReadoutApplication.hpp.

◆ m_tp_handler

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

Definition at line 98 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 95 of file ReadoutApplication.hpp.

◆ m_uses

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

Definition at line 96 of file ReadoutApplication.hpp.

◆ s_application_name

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

Definition at line 107 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 58 of file ReadoutApplication.hpp.

◆ s_data_reader

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

Definition at line 215 of file ReadoutApplication.hpp.

◆ s_data_recorder

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

Definition at line 216 of file ReadoutApplication.hpp.

◆ s_link_handler

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

Definition at line 213 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 109 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 108 of file ReadoutApplication.hpp.

◆ s_tp_handler

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

Definition at line 214 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 211 of file ReadoutApplication.hpp.

◆ s_uses

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

Definition at line 212 of file ReadoutApplication.hpp.

The documentation for this class was generated from the following files:
Generated on Sat Jun 28 2025 for DUNE-DAQ by doxygen 1.12.0