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.
 
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.
 
virtual std::vector< const dunedaq::confmodel::DaqModule * > 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 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.
 
virtual std::vector< const dunedaq::confmodel::DaqModule * > 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 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
 
- 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_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_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_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 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_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 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::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
 
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 36 of file ReadoutApplication.cpp.

36 :
37 dunedaq::conffwk::DalObject(db, o),
38 SmartDaqApplication(db, o),
39 dunedaq::confmodel::ResourceSetDisableAND(db, o),
40 m_uses (nullptr),
41 m_link_handler (nullptr),
42 m_tp_handler (nullptr),
43 m_data_reader (nullptr),
44 m_data_recorder (nullptr)
45
46 {
47 ;
48 }
dunedaq::appmodel::ReadoutApplication::m_uses
const dunedaq::appmodel::RoHwConfig * m_uses
Definition ReadoutApplication.hpp:97
dunedaq::appmodel::ReadoutApplication::m_tp_handler
const dunedaq::appmodel::DataHandlerConf * m_tp_handler
Definition ReadoutApplication.hpp:99
dunedaq::appmodel::ReadoutApplication::m_data_reader
const dunedaq::appmodel::DataReaderConf * m_data_reader
Definition ReadoutApplication.hpp:100
dunedaq::appmodel::ReadoutApplication::m_data_recorder
const dunedaq::appmodel::DataRecorderConf * m_data_recorder
Definition ReadoutApplication.hpp:101
dunedaq::appmodel::ReadoutApplication::m_link_handler
const dunedaq::appmodel::DataHandlerConf * m_link_handler
Definition ReadoutApplication.hpp:98
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 115 of file ReadoutApplication.cpp.

116 {
117 }

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

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

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

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

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

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

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

227{ return s_detector_connections; }
dunedaq::appmodel::ReadoutApplication::s_detector_connections
static const std::string s_detector_connections
Definition ReadoutApplication.hpp:219

◆ __get_detector_connections_str() [2/2]

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

Definition at line 227 of file ReadoutApplication.hpp.

227{ return s_detector_connections; }

◆ __get_link_handler_str() [1/2]

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

Definition at line 223 of file ReadoutApplication.hpp.

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

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

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

◆ __get_ta_generation_enabled_str() [2/2]

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

Definition at line 115 of file ReadoutApplication.hpp.

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

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

◆ __get_tp_generation_enabled_str() [2/2]

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

Definition at line 114 of file ReadoutApplication.hpp.

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

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

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

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

221{ return s_tp_source_ids; }

◆ __get_uses_str() [1/2]

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

Definition at line 222 of file ReadoutApplication.hpp.

222{ return s_uses; }

◆ __get_uses_str() [2/2]

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

Definition at line 222 of file ReadoutApplication.hpp.

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

72 {
73 return to_resources(get_detector_connections());
74}
dunedaq::appmodel::ReadoutApplication::get_detector_connections
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 r...
Definition ReadoutApplication.hpp:408
to_resources
std::vector< const dunedaq::confmodel::Resource * > to_resources(const std::vector< T * > &vector_of_children)
Definition ResourceSet.hpp:108

◆ 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]

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

Implements dunedaq::appmodel::SmartDaqApplication.

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

Definition at line 77 of file ReadoutApplication.cpp.

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

Implements 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::appmodel::SmartDaqApplication.

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

Definition at line 119 of file ReadoutApplication.cpp.

120 {
121 std::vector<const dunedaq::conffwk::DalObject *> vec;
122
123 if (!get(name, vec, upcast_unregistered, true))
124 throw_get_ex(name, s_class_name, this);
125
126 return vec;
127 }
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:119
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::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 129 of file ReadoutApplication.cpp.

130 {
131 if (first_call)
132 {
133 std::lock_guard scoped_lock(m_mutex);
134
135 check();
136 check_init();
137
138 if (get_rel_objects(name, upcast_unregistered, vec))
139 return true;
140 }
141
142 if (SmartDaqApplication::get(name, vec, upcast_unregistered, false)) return true;
143 if (ResourceSetDisableAND::get(name, vec, upcast_unregistered, false)) return true;
144
145 if (first_call)
146 return get_algo_objects(name, vec);
147
148 return false;
149 }
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 125 of file ReadoutApplication.hpp.

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

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

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

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

352 {
353 std::lock_guard scoped_lock(m_mutex);
354 check();
355 check_init();
356 if (!m_data_reader)
357 {
358 std::ostringstream text;
359 text << "relationship \"" << s_data_reader << "\" of object " << this << " is not set";
360 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
361 }
362 return m_data_reader;
363 }
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 351 of file ReadoutApplication.hpp.

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

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

383 {
384 std::lock_guard scoped_lock(m_mutex);
385 check();
386 check_init();
387 return m_data_recorder;
388 }

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

383 {
384 std::lock_guard scoped_lock(m_mutex);
385 check();
386 check_init();
387 return m_data_recorder;
388 }

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

409 {
410 std::lock_guard scoped_lock(m_mutex);
411 check();
412 check_init();
413 return m_detector_connections;
414 }
dunedaq::appmodel::ReadoutApplication::m_detector_connections
std::vector< const dunedaq::confmodel::DetectorToDaqConnection * > m_detector_connections
Definition ReadoutApplication.hpp:102

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

409 {
410 std::lock_guard scoped_lock(m_mutex);
411 check();
412 check_init();
413 return m_detector_connections;
414 }

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

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

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

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

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

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

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

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

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

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

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

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

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

327 {
328 std::lock_guard scoped_lock(m_mutex);
329 check();
330 check_init();
331 return m_tp_handler;
332 }

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

327 {
328 std::lock_guard scoped_lock(m_mutex);
329 check();
330 check_init();
331 return m_tp_handler;
332 }

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

238 {
239 std::lock_guard scoped_lock(m_mutex);
240 check();
241 check_init();
242 return m_tp_source_ids;
243 }
dunedaq::appmodel::ReadoutApplication::m_tp_source_ids
std::vector< const dunedaq::appmodel::SourceIDConf * > m_tp_source_ids
Definition ReadoutApplication.hpp:96

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

238 {
239 std::lock_guard scoped_lock(m_mutex);
240 check();
241 check_init();
242 return m_tp_source_ids;
243 }

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

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

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

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

◆ 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::appmodel::SmartDaqApplication.

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

Definition at line 91 of file ReadoutApplication.cpp.

92 {
93 SmartDaqApplication::init(init_children);
94 ResourceSetDisableAND::init(init_children);
95
96 TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
97
98 try {
99 p_obj.get(s_application_name, m_application_name);
100 p_obj.get(s_tp_generation_enabled, m_tp_generation_enabled);
101 p_obj.get(s_ta_generation_enabled, m_ta_generation_enabled);
102 p_registry._ref<dunedaq::appmodel::SourceIDConf>(p_obj, s_tp_source_ids, m_tp_source_ids, init_children);
103 m_uses = p_registry._ref<dunedaq::appmodel::RoHwConfig>(p_obj, s_uses, init_children);
104 m_link_handler = p_registry._ref<dunedaq::appmodel::DataHandlerConf>(p_obj, s_link_handler, init_children);
105 m_tp_handler = p_registry._ref<dunedaq::appmodel::DataHandlerConf>(p_obj, s_tp_handler, init_children);
106 m_data_reader = p_registry._ref<dunedaq::appmodel::DataReaderConf>(p_obj, s_data_reader, init_children);
107 m_data_recorder = p_registry._ref<dunedaq::appmodel::DataRecorderConf>(p_obj, s_data_recorder, init_children);
108 p_registry._ref<dunedaq::confmodel::DetectorToDaqConnection>(p_obj, s_detector_connections, m_detector_connections, init_children);
109 }
110 catch (dunedaq::conffwk::Exception & ex) {
111 throw_init_ex(ex);
112 }
113 }
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::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
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::appmodel::SmartDaqApplication.

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

Definition at line 51 of file ReadoutApplication.cpp.

52 {
53 check_init();
54
55 try {
56 const std::string str(indent+2, ' ');
57
58 if (print_header)
59 p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
60
61
62 // print direct super-classes
63
64 dunedaq::appmodel::SmartDaqApplication::print(indent, false, s);
65 dunedaq::confmodel::ResourceSetDisableAND::print(indent, false, s);
66
67
68 // print direct attributes
69
70 dunedaq::conffwk::p_sv_attr(s, str, s_application_name, m_application_name);
71 dunedaq::conffwk::p_sv_attr(s, str, s_tp_generation_enabled, m_tp_generation_enabled);
72 dunedaq::conffwk::p_sv_attr(s, str, s_ta_generation_enabled, m_ta_generation_enabled);
73
74
75 // print direct relationships
76
77 dunedaq::conffwk::p_mv_rel(s, str, s_tp_source_ids, m_tp_source_ids);
78 dunedaq::conffwk::p_sv_rel(s, str, indent, s_uses, m_uses);
79 dunedaq::conffwk::p_sv_rel(s, str, s_link_handler, m_link_handler);
80 dunedaq::conffwk::p_sv_rel(s, str, s_tp_handler, m_tp_handler);
81 dunedaq::conffwk::p_sv_rel(s, str, s_data_reader, m_data_reader);
82 dunedaq::conffwk::p_sv_rel(s, str, s_data_recorder, m_data_recorder);
83 dunedaq::conffwk::p_mv_rel(s, str, s_detector_connections, m_detector_connections);
84 }
85 catch (dunedaq::conffwk::Exception & ex) {
86 dunedaq::conffwk::DalObject::p_error(s, ex);
87 }
88 }
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::ResourceSetDisableAND::print
virtual void print(unsigned int offset, bool print_header, std::ostream &s) const
Print details of the ResourceSetDisableAND object.
Definition ResourceSetDisableAND.cpp:24
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
tde_stream_db_gen.str
str
Definition tde_stream_db_gen.py:123

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

Definition at line 140 of file ReadoutApplication.hpp.

141 {
142 std::lock_guard scoped_lock(m_mutex);
143 check();
144 clear();
145 p_obj.set_by_ref(s_application_name, value);
146 }
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 140 of file ReadoutApplication.hpp.

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

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

172 {
173 _set_object(s_data_reader, value);
174 }
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 176 of file ReadoutApplication.cpp.

177 {
178 _set_object(s_data_recorder, value);
179 }

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

Definition at line 181 of file ReadoutApplication.cpp.

182 {
183 _set_objects(s_detector_connections, value);
184 }
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_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
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 161 of file ReadoutApplication.cpp.

162 {
163 _set_object(s_link_handler, value);
164 }

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

203 {
204 std::lock_guard scoped_lock(m_mutex);
205 check();
206 clear();
207 p_obj.set_by_val(s_ta_generation_enabled, value);
208 }
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 202 of file ReadoutApplication.hpp.

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

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

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

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

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

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

167 {
168 _set_object(s_tp_handler, value);
169 }

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

152 {
153 _set_objects(s_tp_source_ids, value);
154 }

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

157 {
158 _set_object(s_uses, value);
159 }

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

◆ s_data_recorder

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

Definition at line 218 of file ReadoutApplication.hpp.

◆ s_detector_connections

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

Definition at line 219 of file ReadoutApplication.hpp.

◆ s_link_handler

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

Definition at line 215 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 111 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 110 of file ReadoutApplication.hpp.

◆ s_tp_handler

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

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

◆ s_uses

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

Definition at line 214 of file ReadoutApplication.hpp.

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