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

#include <NP02ReadoutApplication.hpp>

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

Public Member Functions

virtual void print (unsigned int offset, bool print_header, std::ostream &s) const
 Print details of the NP02ReadoutApplication object.
 
virtual std::vector< const dunedaq::conffwk::DalObject * > get (const std::string &name, bool upcast_unregistered=true) const
 Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject pointers.
 
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 NP02ReadoutApplication object.
 
virtual std::vector< const dunedaq::conffwk::DalObject * > get (const std::string &name, bool upcast_unregistered=true) const
 Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject pointers.
 
virtual std::vector< const dunedaq::confmodel::DaqModule * > generate_modules (const confmodel::Session *) const override
 
- Public Member Functions inherited from dunedaq::appmodel::ReadoutApplication
const std::string & get_application_name () const
 Get "application_name" attribute value.
 
void set_application_name (const std::string &value)
 Set "application_name" attribute value.
 
bool get_tp_generation_enabled () const
 Get "tp_generation_enabled" attribute value.
 
void set_tp_generation_enabled (bool value)
 Set "tp_generation_enabled" attribute value.
 
bool get_ta_generation_enabled () const
 Get "ta_generation_enabled" attribute value.
 
void set_ta_generation_enabled (bool value)
 Set "ta_generation_enabled" attribute value.
 
const std::vector< const dunedaq::appmodel::SourceIDConf * > & get_tp_source_ids () const
 Get "tp_source_ids" relationship value.
 
void set_tp_source_ids (const std::vector< const dunedaq::appmodel::SourceIDConf * > &value)
 Set "tp_source_ids" relationship value.
 
const dunedaq::appmodel::RoHwConfig * get_uses () const
 Get "uses" relationship value. Configuration of the host hardware resources used by this application.
 
void set_uses (const dunedaq::appmodel::RoHwConfig *value)
 Set "uses" relationship value. Configuration of the host hardware resources used by this application.
 
const dunedaq::appmodel::DataHandlerConf * get_link_handler () const
 Get "link_handler" relationship value.
 
void set_link_handler (const dunedaq::appmodel::DataHandlerConf *value)
 Set "link_handler" relationship value.
 
const dunedaq::appmodel::DataHandlerConf * get_tp_handler () const
 Get "tp_handler" relationship value.
 
void set_tp_handler (const dunedaq::appmodel::DataHandlerConf *value)
 Set "tp_handler" relationship value.
 
const dunedaq::appmodel::DataReaderConf * get_data_reader () const
 Get "data_reader" relationship value.
 
void set_data_reader (const dunedaq::appmodel::DataReaderConf *value)
 Set "data_reader" relationship value.
 
const dunedaq::appmodel::DataRecorderConf * get_data_recorder () const
 Get "data_recorder" relationship value.
 
void set_data_recorder (const dunedaq::appmodel::DataRecorderConf *value)
 Set "data_recorder" relationship value.
 
const 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.
 
- 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 Attributes

static const std::string & s_class_name
 
- Static Public Attributes inherited from dunedaq::appmodel::ReadoutApplication
static const std::string & s_class_name
 
static const std::string s_application_name = "application_name"
 
static const std::string s_tp_generation_enabled = "tp_generation_enabled"
 
static const std::string s_ta_generation_enabled = "ta_generation_enabled"
 
static const std::string s_tp_source_ids = "tp_source_ids"
 
static const std::string s_uses = "uses"
 
static const std::string s_link_handler = "link_handler"
 
static const std::string s_tp_handler = "tp_handler"
 
static const std::string s_data_reader = "data_reader"
 
static const std::string s_data_recorder = "data_recorder"
 
- Static 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

 NP02ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~NP02ReadoutApplication () noexcept
 
virtual void init (bool init_children)
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
 NP02ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~NP02ReadoutApplication () noexcept
 
virtual void init (bool init_children)
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
- Protected Member Functions inherited from dunedaq::appmodel::ReadoutApplication
 ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~ReadoutApplication () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
 ReadoutApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~ReadoutApplication () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
- Protected Member Functions inherited from dunedaq::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
 

Friends

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

Additional Inherited Members

- Static Public Member Functions inherited from dunedaq::appmodel::ReadoutApplication
static const std::string & __get_application_name_str () noexcept
 
static const std::string & __get_tp_generation_enabled_str () noexcept
 
static const std::string & __get_ta_generation_enabled_str () noexcept
 
static const std::string & __get_tp_source_ids_str () noexcept
 
static const std::string & __get_uses_str () noexcept
 
static const std::string & __get_link_handler_str () noexcept
 
static const std::string & __get_tp_handler_str () noexcept
 
static const std::string & __get_data_reader_str () noexcept
 
static const std::string & __get_data_recorder_str () noexcept
 
static const std::string & __get_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
 
- 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 33 of file NP02ReadoutApplication.hpp.

Constructor & Destructor Documentation

◆ NP02ReadoutApplication() [1/2]

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

Definition at line 26 of file NP02ReadoutApplication.cpp.

26 :
27 dunedaq::conffwk::DalObject(db, o),
28 ReadoutApplication(db, o)
29
30 {
31 ;
32 }
dunedaq::appmodel::ReadoutApplication::ReadoutApplication
ReadoutApplication(conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
Definition ReadoutApplication.cpp:35
dunedaq::conffwk::DalObject
The base class for any generated DAL object.
Definition DalObject.hpp:45

◆ ~NP02ReadoutApplication() [1/2]

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

Definition at line 62 of file NP02ReadoutApplication.cpp.

63 {
64 }

◆ NP02ReadoutApplication() [2/2]

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

◆ ~NP02ReadoutApplication() [2/2]

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

Member Function Documentation

◆ generate_modules() [1/2]

std::vector< const confmodel::DaqModule * > dunedaq::appmodel::NP02ReadoutApplication::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::ReadoutApplication.

Definition at line 72 of file NP02ReadoutApplication.cpp.

73{
74
75 TLOG_DEBUG(6) << "Generating modules for application " << this->UID();
76
77 ConfigObjectFactory obj_fac(this);
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<std::pair<int16_t, 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
178 std::set<int16_t> numas;
179 for (auto d2d_conn_res : get_contains()) {
180 uint16_t receiver_numa = 0;
181
182 // Are we sure?
183 if (d2d_conn_res->disabled(*session)) {
184 TLOG_DEBUG(7) << "Ignoring disabled DetectorToDaqConnection " << d2d_conn_res->UID();
185 continue;
186 }
187
188 d2d_conn_objs.push_back(&d2d_conn_res->config_object());
189
190 TLOG_DEBUG(6) << "Processing DetectorToDaqConnection " << d2d_conn_res->UID();
191 // get the readout groups and the interfaces and streams therein; 1 reaout group corresponds to 1 data reader module
192 auto d2d_conn = d2d_conn_res->cast<confmodel::DetectorToDaqConnection>();
193
194 if (!d2d_conn) {
195 throw(BadConf(ERS_HERE, "NP02ReadoutApplication contains something other than DetectorToDaqConnection"));
196 }
197
198 if (d2d_conn->get_contains().empty()) {
199 throw(BadConf(ERS_HERE, "DetectorToDaqConnection does not contain sebders or receivers"));
200 }
201
202 // Loop over detector 2 daq connections to find senders and receivers
203 auto det_senders = d2d_conn->get_senders();
204 auto det_receiver = d2d_conn->get_receiver();
205
206
207 // Here I want to resolve the type of connection (network, felix, or?)
208 // Rules of engagement: if the receiver interface is network or felix, the receivers should be castable to the counterpart
209 if (reader_class == "DPDKReaderModule" || reader_class == "SocketReaderModule") {
210 if ((reader_class == "DPDKReaderModule" && !det_receiver->cast<appmodel::DPDKReceiver>()) ||
211 (reader_class == "SocketReaderModule" && !det_receiver->cast<appmodel::SocketReceiver>())) {
212 throw(BadConf(ERS_HERE, fmt::format("{} requires NWDetDataReceiver, found {} of class {}", reader_class, det_receiver->UID(), det_receiver->class_name())));
213 }
214
215 if (reader_class == "DPDKReaderModule") {
216 auto dpdk_reciever = det_receiver->cast<appmodel::DPDKReceiver>();
217 receiver_numa = (int16_t)dpdk_reciever->get_uses()->get_numa_id();
218 }
219
220 bool all_nw_senders = true;
221 for (auto s : det_senders) {
222 all_nw_senders &= (s->cast<appmodel::NWDetDataSender>() != nullptr);
223 }
224
225 // Ensure that all senders are compatible with receiver
226 if (!all_nw_senders) {
227 throw(BadConf(ERS_HERE, "Non-network DetDataSener found with NWreceiver"));
228 }
229 }
230
231 std::vector<const confmodel::DetectorStream*> enabled_det_streams;
232 // Loop over senders
233 for (auto stream : d2d_conn->get_streams()) {
234
235 // Are we sure?
236 if (stream->disabled(*session)) {
237 TLOG_DEBUG(7) << "Ignoring disabled DetectorStream " << stream->UID();
238 continue;
239 }
240
241 // loop over streams
242 all_enabled_det_streams.push_back(std::make_pair(receiver_numa, stream));
243 enabled_det_streams.push_back(stream);
244 numas.insert(receiver_numa);
245 }
246
247 }
248
249 //-----------------------------------------------------------------
250 //
251 // Create DataReaderModule object
252 //
253
254 //
255 // Instantiate DataReaderModule of type DPDKReaderModule
256 //
257
258 // Create the Data reader object
259
260 std::string reader_uid(fmt::format("datareader-{}-{}", this->UID(), std::to_string(conn_idx++)));
261 TLOG_DEBUG(6) << fmt::format("creating OKS configuration object for Data reader class {} with id {}", reader_class, reader_uid);
262 auto reader_obj = obj_fac.create(reader_class, reader_uid);
263
264 // Populate configuration and interfaces (leave output queues for later)
265 reader_obj.set_obj("configuration", &reader_conf->config_object());
266 reader_obj.set_objs("connections", d2d_conn_objs);
267
268 // Create the raw data queues
269 std::vector<const conffwk::ConfigObject*> data_queue_objs;
270 // keep a map for convenience
271
272 // Create data queues
273 for (auto& [numa, ds] : all_enabled_det_streams) {
274 conffwk::ConfigObject queue_obj = obj_fac.create_queue_sid_obj(dlh_input_qdesc, ds);
275 const auto* data_queue = obj_fac.get_dal<confmodel::Connection>(queue_obj.UID());
276 data_queue_objs.push_back(&data_queue->config_object());
277 data_queues_by_sid[ds->get_source_id()] = data_queue;
278 }
279
280 reader_obj.set_objs("outputs", data_queue_objs);
281
282 modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(reader_obj.UID()));
283
284
285
286
287 //-----------------------------------------------------------------
288 //
289 // Prepare the tp handlers and related queues
290 //
291 std::vector<const confmodel::Connection*> tp_queues;
292 if (get_tp_generation_enabled()) {
293
294 // Create TP handler object
295 auto tph_conf_obj = tph_conf->config_object();
296 auto tpsrc_ids = get_tp_source_ids();
297
298 for (auto sid : tpsrc_ids) {
299 conffwk::ConfigObject tp_queue_obj;
300 conffwk::ConfigObject tpreq_queue_obj;
301 std::string tp_uid("tphandler-" + std::to_string(sid->get_sid()));
302 auto tph_obj = obj_fac.create(tph_class, tp_uid);
303 tph_obj.set_by_val<uint32_t>("source_id", sid->get_sid());
304 tph_obj.set_by_val<uint32_t>("detector_id", 1); // 1 == kDAQ
305 tph_obj.set_by_val<bool>("post_processing_enabled", get_ta_generation_enabled());
306 tph_obj.set_obj("module_configuration", &tph_conf_obj);
307
308 // Create the TPs aggregator queue (from RawData Handlers to TP handlers)
309 tp_queue_obj = obj_fac.create_queue_sid_obj(tp_input_qdesc, sid->get_sid());
310 tp_queue_obj.set_by_val<uint32_t>("recv_timeout_ms", 50);
311 tp_queue_obj.set_by_val<uint32_t>("send_timeout_ms", 1);
312
313 tp_queues.push_back(obj_fac.get_dal<confmodel::Connection>(tp_queue_obj.UID()));
314 // Create tp data requests queue from Fragment Aggregator
315 tpreq_queue_obj = obj_fac.create_queue_sid_obj(dlh_reqinput_qdesc, sid->get_sid());
316 req_queues.push_back(obj_fac.get_dal<confmodel::Connection>(tpreq_queue_obj.UID()));
317
318 // Create the tp(set) publishing service
319 conffwk::ConfigObject tp_net_obj = obj_fac.create_net_obj(tp_net_desc, tp_uid);
320
321 // Create the ta(set) publishing service
322 conffwk::ConfigObject ta_net_obj = obj_fac.create_net_obj(ta_net_desc, tp_uid);
323
324 // Register queues with tp hankder
325 tph_obj.set_objs("inputs", { &tp_queue_obj, &tpreq_queue_obj });
326 tph_obj.set_objs("outputs", { &tp_net_obj, &ta_net_obj, &frag_queue_obj });
327 modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(tph_obj.UID()));
328 }
329 }
330
331 // Add output queueus of tps
332 std::vector<const conffwk::ConfigObject*> tp_queue_objs;
333 for (auto q : tp_queues) {
334 tp_queue_objs.push_back(&q->config_object());
335 }
336
337 //-----------------------------------------------------------------
338 //
339 // Create datalink handlers
340 //
341 // Recover the emulation flag
342
343 auto lb_conf = dlh_conf->get_latency_buffer();
344
345 std::map<int16_t, conffwk::ConfigObject> numa_dhlconf_map;
346 for ( int16_t numa : numas ) {
347 auto lb_confobj_numa = obj_fac.create(lb_conf->class_name(), fmt::format("{}-numa{}",lb_conf->UID(), numa));
348 lb_confobj_numa.set_by_val<uint32_t>("size", lb_conf->get_size());
349 lb_confobj_numa.set_by_val<bool>("numa_aware", lb_conf->get_numa_aware());
350 lb_confobj_numa.set_by_val<int16_t>("numa_node", numa);
351 lb_confobj_numa.set_by_val<bool>("intrinsic_allocator", lb_conf->get_intrinsic_allocator());
352 lb_confobj_numa.set_by_val<uint32_t>("alignment_size", lb_conf->get_alignment_size());
353 lb_confobj_numa.set_by_val<bool>("preallocation", lb_conf->get_preallocation());
354
355 auto dhl_confobj_numa = obj_fac.create(dlh_conf->class_name(), fmt::format("{}-numa{}",dlh_conf->UID(), numa));
356 dhl_confobj_numa.set_by_val<std::string>("template_for", dlh_conf->get_template_for());
357 dhl_confobj_numa.set_by_val<std::string>("input_data_type", dlh_conf->get_input_data_type());
358 dhl_confobj_numa.set_by_val<bool>("generate_timesync", dlh_conf->get_generate_timesync());
359 dhl_confobj_numa.set_by_val<uint64_t>("post_processing_delay_ticks", dlh_conf->get_post_processing_delay_ticks());
360 dhl_confobj_numa.set_by_val<std::string>("input_data_type", dlh_conf->get_input_data_type());
361 dhl_confobj_numa.set_obj("request_handler", &dlh_conf->get_request_handler()->config_object());
362 dhl_confobj_numa.set_obj("latency_buffer", &lb_confobj_numa);
363 dhl_confobj_numa.set_obj("data_processor", &dlh_conf->get_data_processor()->config_object());
364
365
366 numa_dhlconf_map[numa] = dhl_confobj_numa;
367
368 }
369
370 auto emulation_mode = reader_conf->get_emulation_mode();
371 for (auto& [numa, ds] : all_enabled_det_streams) {
372
373 uint32_t sid = ds->get_source_id();
374 TLOG_DEBUG(6) << fmt::format("Processing stream {}, id {}, det id {}", ds->UID(), ds->get_source_id(), ds->get_geo_id()->get_detector_id());
375 std::string uid(fmt::format("DLH-{}", sid));
376 TLOG_DEBUG(6) << fmt::format("creating OKS configuration object for Data Link Handler class {}, if {}", dlh_class, sid);
377 auto dlh_obj = obj_fac.create(dlh_class, uid);
378 dlh_obj.set_by_val<uint32_t>("source_id", sid);
379 dlh_obj.set_by_val<uint32_t>("detector_id", ds->get_geo_id()->get_detector_id());
380 dlh_obj.set_by_val<bool>("post_processing_enabled", get_tp_generation_enabled());
381 dlh_obj.set_by_val<bool>("emulation_mode", emulation_mode);
382 dlh_obj.set_obj("geo_id", &ds->get_geo_id()->config_object());
383 dlh_obj.set_obj("module_configuration", &numa_dhlconf_map[numa]);
384 std::vector<const conffwk::ConfigObject*> dlh_ins, dlh_outs;
385
386 // Add datalink-handler queue to the inputs
387 dlh_ins.push_back(&data_queues_by_sid.at(sid)->config_object());
388
389 // Create request queue
390 conffwk::ConfigObject req_queue_obj = obj_fac.create_queue_sid_obj(dlh_reqinput_qdesc, ds);
391
392
393 // Add the requessts queue dal pointer to the outputs of the FragmentAggregatorModule
394 req_queues.push_back(obj_fac.get_dal<confmodel::Connection>(req_queue_obj.UID()));
395 dlh_ins.push_back(&req_queue_obj);
396 dlh_outs.push_back(&frag_queue_obj);
397
398
399 // Time Sync network connection
400 if (dlh_conf->get_generate_timesync()) {
401 // Add timestamp endpoint
402 conffwk::ConfigObject ts_net_obj = obj_fac.create_net_obj(ts_net_desc, std::to_string(sid));
403 dlh_outs.push_back(&ts_net_obj);
404 }
405
406 for (auto tpq : tp_queue_objs) {
407 dlh_outs.push_back(tpq);
408 }
409 dlh_obj.set_objs("inputs", dlh_ins);
410 dlh_obj.set_objs("outputs", dlh_outs);
411
412 modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(dlh_obj.UID()));
413 }
414
415
416 // Finally create Fragment Aggregator
417 std::string faUid("fragmentaggregator-" + UID());
418 // conffwk::ConfigObject frag_aggr;
419 TLOG_DEBUG(7) << "creating OKS configuration object for Fragment Aggregator class ";
420 auto frag_aggr = obj_fac.create("FragmentAggregatorModule", faUid);
421 conffwk::ConfigObject fa_net_obj = obj_fac.create_net_obj(fa_net_desc);
422
423 // Process special Network rules!
424 // Looking for Fragment rules from DFAppplications in current Session
425 auto sessionApps = session->get_enabled_applications();
426 std::vector<conffwk::ConfigObject> fragOutObjs;
427 for (auto app : sessionApps) {
428 auto dfapp = app->cast<appmodel::DFApplication>();
429 if (dfapp == nullptr)
430 continue;
431
432 auto dfNRules = dfapp->get_network_rules();
433 for (auto rule : dfNRules) {
434 auto descriptor = rule->get_descriptor();
435 auto data_type = descriptor->get_data_type();
436 if (data_type == "Fragment") {
437 std::string dreqNetUid(descriptor->get_uid_base() + dfapp->UID());
438 // conffwk::ConfigObject frag_conn;
439 // config->create(dbfile, "NetworkConnection", dreqNetUid, frag_conn);
440 auto frag_conn = obj_fac.create("NetworkConnection", dreqNetUid);
441
442 frag_conn.set_by_val<std::string>("data_type", descriptor->get_data_type());
443 frag_conn.set_by_val<std::string>("connection_type", descriptor->get_connection_type());
444
445 auto serviceObj = descriptor->get_associated_service()->config_object();
446 frag_conn.set_obj("associated_service", &serviceObj);
447 fragOutObjs.push_back(frag_conn);
448 } // If network rule has TriggerDecision type of data
449 } // Loop over Apps network rules
450 } // loop over Session specific Apps
451
452 // Add output queueus of data requests and Fragments
453 std::vector<const conffwk::ConfigObject*> fa_output_objs;
454 for (auto& fNet : fragOutObjs) {
455 fa_output_objs.push_back(&fNet);
456 }
457
458 for (auto& q : req_queues) {
459 fa_output_objs.push_back(&q->config_object());
460 }
461
462 frag_aggr.set_objs("inputs", { &fa_net_obj, &frag_queue_obj });
463 frag_aggr.set_objs("outputs", fa_output_objs);
464
465 modules.push_back(obj_fac.get_dal<confmodel::DaqModule>(frag_aggr.UID()));
466
467 return modules;
468}
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::NP02ReadoutApplication::generate_modules ( const confmodel::Session * ) const
overridevirtual

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

Reimplemented from dunedaq::appmodel::ReadoutApplication.

◆ get() [1/4]

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

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

Parameters are:

Parameters
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::ReadoutApplication.

Definition at line 66 of file NP02ReadoutApplication.cpp.

67 {
68 std::vector<const dunedaq::conffwk::DalObject *> vec;
69
70 if (!get(name, vec, upcast_unregistered, true))
71 throw_get_ex(name, s_class_name, this);
72
73 return vec;
74 }
dunedaq::appmodel::NP02ReadoutApplication::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 NP02ReadoutApplication.cpp:66
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::NP02ReadoutApplication::get ( const std::string & name,
bool upcast_unregistered = true ) const
virtual

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

Parameters are:

Parameters
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::ReadoutApplication.

◆ get() [3/4]

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

Definition at line 76 of file NP02ReadoutApplication.cpp.

77 {
78 if (first_call)
79 {
80 std::lock_guard scoped_lock(m_mutex);
81
82 check();
83 check_init();
84
85 if (get_rel_objects(name, upcast_unregistered, vec))
86 return true;
87 }
88
89 if (ReadoutApplication::get(name, vec, upcast_unregistered, false)) return true;
90
91 if (first_call)
92 return get_algo_objects(name, vec);
93
94 return false;
95 }
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::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::NP02ReadoutApplication::get ( const std::string & name,
std::vector< const dunedaq::conffwk::DalObject * > & vec,
bool upcast_unregistered,
bool first_call ) const
protected

◆ init() [1/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Reimplemented from dunedaq::appmodel::ReadoutApplication.

Definition at line 55 of file NP02ReadoutApplication.cpp.

56 {
57 ReadoutApplication::init(init_children);
58
59 TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
60 }
dunedaq::appmodel::ReadoutApplication::init
virtual void init(bool init_children)
Definition ReadoutApplication.cpp:89

◆ init() [2/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Reimplemented from dunedaq::appmodel::ReadoutApplication.

◆ print() [1/2]

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

Print details of the NP02ReadoutApplication object.

Parameters are:

Parameters
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::ReadoutApplication.

Definition at line 35 of file NP02ReadoutApplication.cpp.

36 {
37 check_init();
38
39 try {
40
41 if (print_header)
42 p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
43
44
45 // print direct super-classes
46
47 dunedaq::appmodel::ReadoutApplication::print(indent, false, s);
48 }
49 catch (dunedaq::conffwk::Exception & ex) {
50 dunedaq::conffwk::DalObject::p_error(s, ex);
51 }
52 }
dunedaq::appmodel::ReadoutApplication::print
virtual void print(unsigned int offset, bool print_header, std::ostream &s) const
Print details of the ReadoutApplication object.
Definition ReadoutApplication.cpp:50
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

◆ print() [2/2]

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

Print details of the NP02ReadoutApplication object.

Parameters are:

Parameters
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::ReadoutApplication.

Friends And Related Symbol Documentation

◆ conffwk::Configuration

conffwk::Configuration
friend

Definition at line 35 of file NP02ReadoutApplication.hpp.

◆ conffwk::DalFactory

conffwk::DalFactory
friend

Definition at line 37 of file NP02ReadoutApplication.hpp.

◆ conffwk::DalObject

conffwk::DalObject
friend

Definition at line 36 of file NP02ReadoutApplication.hpp.

◆ conffwk::DalRegistry

conffwk::DalRegistry
friend

Definition at line 38 of file NP02ReadoutApplication.hpp.

Member Data Documentation

◆ s_class_name

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

The name of the configuration class.

Definition at line 50 of file NP02ReadoutApplication.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