DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
dunedaq::appmodel::DFApplication Class Reference

#include <DFApplication.hpp>

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

Public Member Functions

virtual void print (unsigned int offset, bool print_header, std::ostream &s) const
 Print details of the DFApplication 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 dunedaq::appmodel::TRBConfget_trb () const
 Get "trb" relationship value. Configuration of the TRB to be generated my get_modules()
 
void set_trb (const dunedaq::appmodel::TRBConf *value)
 Set "trb" relationship value. Configuration of the TRB to be generated my get_modules()
 
const std::vector< const dunedaq::appmodel::DataWriterConf * > & get_data_writers () const
 Get "data_writers" relationship value.
 
void set_data_writers (const std::vector< const dunedaq::appmodel::DataWriterConf * > &value)
 Set "data_writers" relationship value.
 
const dunedaq::appmodel::DFHWConfget_uses () const
 Get "uses" relationship value.
 
void set_uses (const dunedaq::appmodel::DFHWConf *value)
 Set "uses" relationship value.
 
void generate_modules (std::shared_ptr< appmodel::ConfigurationHelper >) const override
 
virtual void print (unsigned int offset, bool print_header, std::ostream &s) const
 Print details of the DFApplication 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 dunedaq::appmodel::TRBConfget_trb () const
 Get "trb" relationship value. Configuration of the TRB to be generated my get_modules()
 
void set_trb (const dunedaq::appmodel::TRBConf *value)
 Set "trb" relationship value. Configuration of the TRB to be generated my get_modules()
 
const std::vector< const dunedaq::appmodel::DataWriterConf * > & get_data_writers () const
 Get "data_writers" relationship value.
 
void set_data_writers (const std::vector< const dunedaq::appmodel::DataWriterConf * > &value)
 Set "data_writers" relationship value.
 
const dunedaq::appmodel::DFHWConfget_uses () const
 Get "uses" relationship value.
 
void set_uses (const dunedaq::appmodel::DFHWConf *value)
 Set "uses" relationship value.
 
void generate_modules (std::shared_ptr< appmodel::ConfigurationHelper >) const override
 
- Public Member Functions inherited from dunedaq::appmodel::SmartDaqApplication
const dunedaq::appmodel::SourceIDConfget_source_id () const
 Get "source_id" relationship value.
 
void set_source_id (const dunedaq::appmodel::SourceIDConf *value)
 Set "source_id" relationship value.
 
const std::vector< const dunedaq::appmodel::QueueConnectionRule * > & get_queue_rules () const
 Get "queue_rules" relationship value.
 
void set_queue_rules (const std::vector< const dunedaq::appmodel::QueueConnectionRule * > &value)
 Set "queue_rules" relationship value.
 
const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > & get_network_rules () const
 Get "network_rules" relationship value.
 
void set_network_rules (const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > &value)
 Set "network_rules" relationship value.
 
const dunedaq::appmodel::SourceIDConfget_source_id () const
 Get "source_id" relationship value.
 
void set_source_id (const dunedaq::appmodel::SourceIDConf *value)
 Set "source_id" relationship value.
 
const std::vector< const dunedaq::appmodel::QueueConnectionRule * > & get_queue_rules () const
 Get "queue_rules" relationship value.
 
void set_queue_rules (const std::vector< const dunedaq::appmodel::QueueConnectionRule * > &value)
 Set "queue_rules" relationship value.
 
const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > & get_network_rules () const
 Get "network_rules" relationship value.
 
void set_network_rules (const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > &value)
 Set "network_rules" relationship value.
 
- Public Member Functions inherited from dunedaq::confmodel::DaqApplication
const std::string & get_application_name () const
 Get "application_name" attribute value. Name of the application binary to run.
 
void set_application_name (const std::string &value)
 Set "application_name" attribute value. Name of the application binary to run.
 
const std::vector< const dunedaq::confmodel::DaqModule * > & get_modules () const
 Get "modules" relationship value.
 
void set_modules (const std::vector< const dunedaq::confmodel::DaqModule * > &value)
 Set "modules" relationship value.
 
const std::vector< const dunedaq::confmodel::ActionPlan * > & get_action_plans () const
 Get "action_plans" relationship value.
 
void set_action_plans (const std::vector< const dunedaq::confmodel::ActionPlan * > &value)
 Set "action_plans" relationship value.
 
std::set< const dunedaq::confmodel::HostComponent * > get_used_hostresources () const
 
const std::vector< std::string > construct_commandline_parameters (const conffwk::Configuration &confdb, const dunedaq::confmodel::Session *session) const
 
const std::string & get_application_name () const
 Get "application_name" attribute value. Name of the application binary to run.
 
void set_application_name (const std::string &value)
 Set "application_name" attribute value. Name of the application binary to run.
 
const std::vector< const dunedaq::confmodel::DaqModule * > & get_modules () const
 Get "modules" relationship value.
 
void set_modules (const std::vector< const dunedaq::confmodel::DaqModule * > &value)
 Set "modules" relationship value.
 
const std::vector< const dunedaq::confmodel::ActionPlan * > & get_action_plans () const
 Get "action_plans" relationship value.
 
void set_action_plans (const std::vector< const dunedaq::confmodel::ActionPlan * > &value)
 Set "action_plans" relationship value.
 
std::set< const dunedaq::confmodel::HostComponent * > get_used_hostresources () const
 
const std::vector< std::string > construct_commandline_parameters (const conffwk::Configuration &confdb, const dunedaq::confmodel::Session *session) const
 
- Public Member Functions inherited from dunedaq::confmodel::Application
const std::string & get_application_name () const
 Get "application_name" attribute value. Name of the application binary to run.
 
void set_application_name (const std::string &value)
 Set "application_name" attribute value. Name of the application binary to run.
 
const std::vector< std::string > & get_commandline_parameters () const
 Get "commandline_parameters" attribute value. command line parameters to add when starting the application.
 
void set_commandline_parameters (const std::vector< std::string > &value)
 Set "commandline_parameters" attribute value. command line parameters to add when starting the application.
 
const std::string & get_log_path () const
 Get "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.
 
void set_log_path (const std::string &value)
 Set "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.
 
const std::vector< const dunedaq::confmodel::VariableBase * > & get_application_environment () const
 Get "application_environment" relationship value. Define process environment for this application.
 
void set_application_environment (const std::vector< const dunedaq::confmodel::VariableBase * > &value)
 Set "application_environment" relationship value. Define process environment for this application.
 
const dunedaq::confmodel::VirtualHostget_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::OpMonConfget_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::VirtualHostget_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::OpMonConfget_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 ConfigObjectconfig_object () const
 
DalRegistryregistry () const noexcept
 
Configurationconfiguration () 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::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
 
virtual bool compute_disabled_state (const std::set< std::string > &) 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
 
virtual bool compute_disabled_state (const std::set< std::string > &) const
 

Static Public Member Functions

static const std::string & __get_trb_str () noexcept
 
static const std::string & __get_data_writers_str () noexcept
 
static const std::string & __get_uses_str () noexcept
 
static const std::string & __get_trb_str () noexcept
 
static const std::string & __get_data_writers_str () noexcept
 
static const std::string & __get_uses_str () noexcept
 
- Static Public Member Functions inherited from dunedaq::appmodel::SmartDaqApplication
static const std::string & __get_source_id_str () noexcept
 
static const std::string & __get_queue_rules_str () noexcept
 
static const std::string & __get_network_rules_str () noexcept
 
static const std::string & __get_source_id_str () noexcept
 
static const std::string & __get_queue_rules_str () noexcept
 
static const std::string & __get_network_rules_str () noexcept
 
- Static Public Member Functions inherited from dunedaq::confmodel::DaqApplication
static const std::string & __get_application_name_str () noexcept
 
static const std::string & __get_modules_str () noexcept
 
static const std::string & __get_action_plans_str () noexcept
 
static const std::string & __get_application_name_str () noexcept
 
static const std::string & __get_modules_str () noexcept
 
static const std::string & __get_action_plans_str () noexcept
 
- Static Public Member Functions inherited from dunedaq::confmodel::Application
static const std::string & __get_application_name_str () noexcept
 
static const std::string & __get_commandline_parameters_str () noexcept
 
static const std::string & __get_log_path_str () noexcept
 
static const std::string & __get_application_environment_str () noexcept
 
static const std::string & __get_runs_on_str () noexcept
 
static const std::string & __get_exposes_service_str () noexcept
 
static const std::string & __get_opmon_conf_str () noexcept
 
static const std::string & __get_application_name_str () noexcept
 
static const std::string & __get_commandline_parameters_str () noexcept
 
static const std::string & __get_log_path_str () noexcept
 
static const std::string & __get_application_environment_str () noexcept
 
static const std::string & __get_runs_on_str () noexcept
 
static const std::string & __get_exposes_service_str () noexcept
 
static const std::string & __get_opmon_conf_str () noexcept
 
- Static Public Member Functions inherited from dunedaq::conffwk::DalObject
static void p_null (std::ostream &s)
 print "(null)"
 
static void p_rm (std::ostream &s)
 print "(deleted object)"
 
static void p_error (std::ostream &s, dunedaq::conffwk::Exception &ex)
 print error text
 
static void throw_get_ex (const std::string &what, const std::string &class_name, const DalObject *obj)
 throw exception in generated get method (i.e.
 
static bool is_null (const DalObject *ref) noexcept
 check a pointer on DAL object is null
 

Static Public Attributes

static const std::string & s_class_name
 
static const std::string s_trb = "trb"
 
static const std::string s_data_writers = "data_writers"
 
static const std::string s_uses = "uses"
 
- Static Public Attributes inherited from dunedaq::appmodel::SmartDaqApplication
static const std::string & s_class_name
 
static const std::string s_source_id = "source_id"
 
static const std::string s_queue_rules = "queue_rules"
 
static const std::string s_network_rules = "network_rules"
 
- Static Public Attributes inherited from dunedaq::confmodel::DaqApplication
static const std::string & s_class_name
 
static const std::string s_application_name = "application_name"
 
static const std::string s_modules = "modules"
 
static const std::string s_action_plans = "action_plans"
 
- Static Public Attributes inherited from dunedaq::confmodel::Application
static const std::string & s_class_name
 
static const std::string s_application_name = "application_name"
 
static const std::string s_commandline_parameters = "commandline_parameters"
 
static const std::string s_log_path = "log_path"
 
static const std::string s_application_environment = "application_environment"
 
static const std::string s_runs_on = "runs_on"
 
static const std::string s_exposes_service = "exposes_service"
 
static const std::string s_opmon_conf = "opmon_conf"
 
- Static Public Attributes inherited from dunedaq::confmodel::Resource
static const std::string & s_class_name
 

Protected Member Functions

 DFApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~DFApplication () 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
 
 DFApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~DFApplication () noexcept
 
virtual void init (bool init_children)
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
- Protected Member Functions inherited from dunedaq::appmodel::SmartDaqApplication
 SmartDaqApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~SmartDaqApplication () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
 SmartDaqApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~SmartDaqApplication () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
- Protected Member Functions inherited from dunedaq::confmodel::DaqApplication
 DaqApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~DaqApplication () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
 DaqApplication (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~DaqApplication () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
- Protected Member Functions inherited from dunedaq::confmodel::Application
 Application (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~Application () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
 Application (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~Application () noexcept
 
bool get (const std::string &name, std::vector< const dunedaq::conffwk::DalObject * > &vec, bool upcast_unregistered, bool first_call) const
 
- Protected Member Functions inherited from dunedaq::conffwk::DalObject
 DalObject (DalRegistry &db, const ConfigObject &o) noexcept
 
virtual ~DalObject ()
 
void clear () noexcept
 
void check () const
 
bool is_deleted () const
 
void increment_created () noexcept
 
void increment_read () noexcept
 
void check_init () const
 Check and initialize object if necessary.
 
template<typename T >
void _set_object (const std::string &name, const T *value)
 Helper method for generated set single-value relationship methods.
 
template<typename T >
void _set_objects (const std::string &name, const std::vector< const T * > &value)
 Helper method for generated set multi-value relationship methods.
 
bool get_rel_objects (const std::string &name, bool upcast_unregistered, std::vector< const DalObject * > &objs) const
 Read relationship values as DAL objects using DAL factory.
 
bool get_algo_objects (const std::string &name, std::vector< const DalObject * > &objs) const
 Run algorithm and return result as DAL objects using DAL factory.
 
- Protected Member Functions inherited from dunedaq::confmodel::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

const dunedaq::appmodel::TRBConfm_trb
 
std::vector< const dunedaq::appmodel::DataWriterConf * > m_data_writers
 
const dunedaq::appmodel::DFHWConfm_uses
 

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
 
DalRegistryp_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 39 of file DFApplication.hpp.

Constructor & Destructor Documentation

◆ DFApplication() [1/2]

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

Definition at line 33 of file DFApplication.cpp.

33 :
37 m_trb (nullptr),
38 m_uses (nullptr)
39
40 {
41 ;
42 }
const dunedaq::appmodel::TRBConf * m_trb
const dunedaq::appmodel::DFHWConf * m_uses
SmartDaqApplication(conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
The base class for any generated DAL object.
Definition DalObject.hpp:45

◆ ~DFApplication() [1/2]

dunedaq::appmodel::DFApplication::~DFApplication ( )
protectedvirtualnoexcept

Definition at line 91 of file DFApplication.cpp.

92 {
93 }

◆ DFApplication() [2/2]

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

◆ ~DFApplication() [2/2]

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

Member Function Documentation

◆ __get_data_writers_str() [1/2]

static const std::string & dunedaq::appmodel::DFApplication::__get_data_writers_str ( )
inlinestaticnoexcept

Definition at line 104 of file DFApplication.hpp.

104{ return s_data_writers; }
static const std::string s_data_writers

◆ __get_data_writers_str() [2/2]

static const std::string & dunedaq::appmodel::DFApplication::__get_data_writers_str ( )
inlinestaticnoexcept

Definition at line 104 of file DFApplication.hpp.

104{ return s_data_writers; }

◆ __get_trb_str() [1/2]

static const std::string & dunedaq::appmodel::DFApplication::__get_trb_str ( )
inlinestaticnoexcept

Definition at line 103 of file DFApplication.hpp.

103{ return s_trb; }
static const std::string s_trb

◆ __get_trb_str() [2/2]

static const std::string & dunedaq::appmodel::DFApplication::__get_trb_str ( )
inlinestaticnoexcept

Definition at line 103 of file DFApplication.hpp.

103{ return s_trb; }

◆ __get_uses_str() [1/2]

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

Definition at line 105 of file DFApplication.hpp.

105{ return s_uses; }
static const std::string s_uses

◆ __get_uses_str() [2/2]

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

Definition at line 105 of file DFApplication.hpp.

105{ return s_uses; }

◆ generate_modules() [1/2]

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

Generate DaqModule dal objects for streams of the application on the fly

Implements dunedaq::appmodel::SmartDaqApplication.

Definition at line 123 of file DFApplication.cpp.

124 {
125
126 ConfigObjectFactory obj_fac(this);
127
128 std::vector<const confmodel::DaqModule*> modules;
129
130 // Containers for module specific config objects for output/input
131 // Prepare TRB output objects
132 std::vector<const conffwk::ConfigObject*> trbInputObjs;
133 std::vector<const conffwk::ConfigObject*> trbOutputObjs;
134 std::vector<const conffwk::ConfigObject*> trbSidNetObjs;
135
136 // -- First, we process expected Queue and Network connections and create their objects.
137
138 // Process the queue rules looking for the TriggerRecord queue between TRB and DataWriterModule
139 const QueueDescriptor* trQDesc = nullptr;
140 for (auto rule : get_queue_rules()) {
141 auto destination_class = rule->get_destination_class();
142 if (destination_class == "DataWriterModule") {
143 trQDesc = rule->get_descriptor();
144 }
145 }
146 if (trQDesc == nullptr) { // BadConf if no descriptor between TRB and DataWriterModule
147 throw(BadConf(ERS_HERE, "Could not find queue descriptor rule for TriggerRecords!"));
148 }
149 // Create queue connection config object
150 auto trQueueObj = obj_fac.create_queue_obj(trQDesc, UID());
151
152 // Place trigger record queue object into vector of output objs of TRB module
153 trbOutputObjs.push_back(&trQueueObj);
154
155 // Process the network rules looking for the Fragments and TriggerDecision inputs for TRB
156 const NetworkConnectionDescriptor* fragNetDesc = nullptr;
157 const NetworkConnectionDescriptor* trigdecNetDesc = nullptr;
158 const NetworkConnectionDescriptor* tokenNetDesc = nullptr;
159 const NetworkConnectionDescriptor* trmonReqNetDesc = nullptr;
160 const NetworkConnectionDescriptor* trmonTRNetDesc = nullptr;
161 for (auto rule : get_network_rules()) {
162 auto descriptor = rule->get_descriptor();
163 auto data_type = descriptor->get_data_type();
164 if (data_type == "Fragment") {
165 fragNetDesc = rule->get_descriptor();
166 } else if (data_type == "TriggerDecision") {
167 trigdecNetDesc = rule->get_descriptor();
168 } else if (data_type == "TriggerDecisionToken") {
169 tokenNetDesc = rule->get_descriptor();
170 } else if (data_type == "TRMonRequest") {
171 trmonReqNetDesc = rule->get_descriptor();
172 } else if (data_type == "TriggerRecord") {
173 trmonTRNetDesc = rule->get_descriptor();
174 }
175 }
176 if (fragNetDesc == nullptr) { // BadConf if no descriptor for Fragments into TRB
177 throw(BadConf(ERS_HERE, "Could not find network descriptor rule for input Fragments!"));
178 }
179 if (trigdecNetDesc == nullptr) { // BadCond if no descriptor for TriggerDecisions into TRB
180 throw(BadConf(ERS_HERE, "Could not find network descriptor rule for input TriggerDecisions!"));
181 }
182 if (tokenNetDesc == nullptr) { // BadCond if no descriptor for Tokens out of DataWriterModule
183 throw(BadConf(ERS_HERE, "Could not find network descriptor rule for output TriggerDecisionTokens!"));
184 }
185 if (get_source_id() == nullptr) {
186 throw(BadConf(ERS_HERE, "Could not retrieve SourceIDConf"));
187 }
188 // Create network connection config object
189 auto fragNetObj = obj_fac.create_net_obj(fragNetDesc, UID());
190 auto trigdecNetObj = obj_fac.create_net_obj(trigdecNetDesc, UID());
191 auto tokenNetObj = obj_fac.create_net_obj(tokenNetDesc, "");
192 conffwk::ConfigObject trmonReqNetObj;
193 conffwk::ConfigObject trmonTRNetObj;
194 if (trmonReqNetDesc != nullptr) {
195 trmonReqNetObj = obj_fac.create_net_obj(trmonReqNetDesc, UID());
196 }
197 if (trmonTRNetDesc != nullptr) {
198 trmonTRNetObj = obj_fac.create_net_obj(trmonTRNetDesc, "");
199 }
200
201 // Process special Network rules!
202 // Looking for DataRequest rules from ReadoutAppplications in current Session
203 std::vector<conffwk::ConfigObject> dreqNetObjs;
204 std::vector<conffwk::ConfigObject> sidNetObjs;
205 std::vector<std::shared_ptr<conffwk::ConfigObject>> sidObjs;
206 std::set<std::string> processed_apps;
207 for (auto uid: helper->get_app_uids("DFApplication")) {
208 processed_apps.insert(uid);
209 }
210
211 auto stream_src_ids = helper->get_stream_source_ids();
212 auto tp_src_ids = helper->get_tp_source_ids();
213 for (auto [uid, descriptor]:
214 helper->get_netdescriptors("DataRequest", "ReadoutApplication")) {
215 dreqNetObjs.emplace_back(obj_fac.create_net_obj(descriptor, uid));
216
217 std::string sidToNetUid(descriptor->get_uid_base() + uid + "-sids");
218 sidNetObjs.emplace_back(obj_fac.create("SourceIDToNetworkConnection", sidToNetUid));
219
220 fill_sourceid_object(obj_fac,
221 &dreqNetObjs.back(),
222 uid,
223 stream_src_ids.at(uid),
224 tp_src_ids.at(uid),
225 sidNetObjs.back(),
226 sidObjs);
227 processed_apps.insert(uid);
228 }
229
230 for (auto [uid, descriptor]:
231 helper->get_netdescriptors("DataRequest", "TPReplayApplication")) {
233 uid,
234 tp_src_ids.at(uid),
235 &dreqNetObjs,
236 &sidNetObjs,
237 descriptor,
238 sidObjs);
239 processed_apps.insert(uid);
240 }
241
242
243
244
245 for (auto [uid, descriptor]:
246 helper->get_netdescriptors("DataRequest", "FakeDataApplication")) {
247 dreqNetObjs.emplace_back(obj_fac.create_net_obj(descriptor, uid));
248
249 std::string sidToNetUid(descriptor->get_uid_base() + uid + "-sids");
250 sidNetObjs.emplace_back(obj_fac.create("SourceIDToNetworkConnection", sidToNetUid));
251
252 fill_sourceid_object(obj_fac,
253 &dreqNetObjs.back(),
254 uid,
255 stream_src_ids.at(uid),
256 {}, // No tp src_ids for FakeDataApplication
257 sidNetObjs.back(),
258 sidObjs);
259 processed_apps.insert(uid);
260 }
261
262 // now we treat the CTB which has 2 connections related to source IDs
263 const auto ctb_type = "CTBApplication";
264 for (auto [uid, descriptor]: helper->get_netdescriptors("DataRequest", ctb_type)) {
265
266 if (processed_apps.contains(uid)) {
267 continue;
268 }
269
270 for ( const auto & [uid, rel_sources] :
271 helper->get_all_app_source_ids(ctb_type) ) {
272 for ( auto [rel, id] : rel_sources ) {
273 std::string local_uid = uid;
274 local_uid += rel.find("LLT")!=std::string::npos ? "_LLT" : "_HLT";
275
276 dreqNetObjs.emplace_back(obj_fac.create_net_obj(descriptor, local_uid));
277 sidObjs.push_back(std::make_shared<conffwk::ConfigObject>(id->config_object()));
278
279 std::string sidToNetUid(descriptor->get_uid_base() + local_uid);
280 sidNetObjs.emplace_back(obj_fac.create("SourceIDToNetworkConnection", sidToNetUid));
281 sidNetObjs.back().set_objs("source_ids", {sidObjs.back().get()});
282 sidNetObjs.back().set_obj("netconn", &dreqNetObjs.back());
283
284 } // loop on relational sources
285
286 processed_apps.insert(uid);
287 } // loop over CTB apps
288 } // loop over descriptors for the CTB apps
289
290 auto app_sources = helper->get_app_source_ids();
291 // Now look at all Smart apps that are not Readout, FakeData or DF
292 for (auto [uid, descriptor]: helper->get_netdescriptors("DataRequest")) {
293
294
295 if (processed_apps.contains(uid)) {
296 continue;
297 }
298 if (app_sources.contains(uid)) {
299 dreqNetObjs.emplace_back(obj_fac.create_net_obj(descriptor, uid));
300
301 sidObjs.push_back(std::make_shared<conffwk::ConfigObject>(
302 app_sources.at(uid)->config_object()));
303
304 std::string sidToNetUid(descriptor->get_uid_base() + uid + "-sids");
305 sidNetObjs.emplace_back(obj_fac.create("SourceIDToNetworkConnection", sidToNetUid));
306 sidNetObjs.back().set_objs("source_ids", {sidObjs.back().get()});
307 sidNetObjs.back().set_obj("netconn", &dreqNetObjs.back());
308
309 processed_apps.insert(uid);
310 }
311 }
312
313
314 // Get pointers to objects here, after vector has been filled so they don't move on us
315 for (auto& obj : dreqNetObjs) {
316 trbOutputObjs.push_back(&obj);
317 }
318 for (auto& obj : sidNetObjs) {
319 trbSidNetObjs.push_back(&obj);
320 }
321
322 // -- Second, we create the Module objects and assign their configs, with the precreated
323 // -- connection config objects above.
324
325 // Get TRB Config Object
326 auto trbConf = get_trb();
327 if (trbConf == nullptr) {
328 throw(BadConf(ERS_HERE, "No DataWriterModule or TRB configuration given"));
329 }
330 auto trbConfObj = trbConf->config_object();
331 trbConfObj.set_by_val<uint32_t>("source_id", get_source_id()->get_sid());
332 trbInputObjs = { &trigdecNetObj, &fragNetObj };
333 if (trmonReqNetDesc != nullptr) {
334 trbInputObjs.push_back(&trmonReqNetObj);
335 }
336 if (trmonTRNetDesc != nullptr) {
337 trbOutputObjs.push_back(&trmonTRNetObj);
338 }
339 // Prepare TRB Module Object and assign its Config Object.
340 std::string trbUid(UID() + "-trb");
341 conffwk::ConfigObject trbObj = obj_fac.create("TRBModule", trbUid);
342 trbObj.set_obj("configuration", &trbConfObj);
343 trbObj.set_objs("inputs", trbInputObjs);
344 trbObj.set_objs("outputs", trbOutputObjs);
345 trbObj.set_obj("trigger_record_output", &trQueueObj);
346 trbObj.set_objs("request_connections", trbSidNetObjs);
347 // Push TRB Module Object from confdb
348 modules.push_back(obj_fac.get_dal<TRBModule>(trbUid));
349
350 // Get DataWriterModule Config Object (only one for now, maybe more later?)
351 auto dwrConfs = get_data_writers();
352 if (dwrConfs.size() == 0) {
353 throw(BadConf(ERS_HERE, "No DataWriterModule or TRB configuration given"));
354 }
355 uint dw_idx = 0;
356 for (auto dwrConf : dwrConfs) {
357 // auto fnParamsObj = dwrConf->get_data_store_params()->get_filename_params()->config_object();
358 // fnParamsObj.set_by_val<std::string>("writer_identifier", fmt::format("{}_datawriter-{}", UID(), dw_idx));
359 auto dwrConfObj = dwrConf->config_object();
360
361 // Prepare DataWriterModule Module Object and assign its Config Object.
362 std::string dwrUid(fmt::format("{}-dw-{}", UID(), dw_idx));
363 conffwk::ConfigObject dwrObj = obj_fac.create("DataWriterModule", dwrUid);
364 dwrObj.set_by_val("writer_identifier", fmt::format("{}_dw_{}", UID(), dw_idx));
365 dwrObj.set_obj("configuration", &dwrConfObj);
366 dwrObj.set_objs("inputs", { &trQueueObj });
367 dwrObj.set_objs("outputs", { &tokenNetObj });
368 // Push DataWriterModule Module Object from confdb
369 modules.push_back(obj_fac.get_dal<DataWriterModule>(dwrUid));
370 ++dw_idx;
371 }
372
373 obj_fac.update_modules(modules);
374}
#define ERS_HERE
const std::vector< const dunedaq::appmodel::DataWriterConf * > & get_data_writers() const
Get "data_writers" relationship value.
const dunedaq::appmodel::TRBConf * get_trb() const
Get "trb" relationship value. Configuration of the TRB to be generated my get_modules()
const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > & get_network_rules() const
Get "network_rules" relationship value.
const std::vector< const dunedaq::appmodel::QueueConnectionRule * > & get_queue_rules() const
Get "queue_rules" relationship value.
const dunedaq::appmodel::SourceIDConf * get_source_id() const
Get "source_id" relationship value.
uint32_t get_sid() const
Get "sid" attribute value.
const std::string & UID() const noexcept
static void fill_sourceid_object(const ConfigObjectFactory &obj_fac, const conffwk::ConfigObject *netConn, const std::string &uid, const std::vector< uint32_t > &stream_source_ids, const std::vector< const SourceIDConf * > &tp_source_ids, conffwk::ConfigObject &sidNetObj, std::vector< std::shared_ptr< conffwk::ConfigObject > > sidObjs)
void fill_replay_sourceid_object(const ConfigObjectFactory &obj_fac, const std::string &uid, const std::vector< const SourceIDConf * > &tp_source_ids, std::vector< conffwk::ConfigObject > *netConn, std::vector< conffwk::ConfigObject > *sidNetObj, const NetworkConnectionDescriptor *descriptor, std::vector< std::shared_ptr< conffwk::ConfigObject > > sidObjs)
msgpack::object obj

◆ generate_modules() [2/2]

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

Generate DaqModule dal objects for streams of the application on the fly

Implements dunedaq::appmodel::SmartDaqApplication.

◆ get() [1/4]

std::vector< const dunedaq::conffwk::DalObject * > dunedaq::appmodel::DFApplication::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.

Definition at line 95 of file DFApplication.cpp.

96 {
97 std::vector<const dunedaq::conffwk::DalObject *> vec;
98
99 if (!get(name, vec, upcast_unregistered, true))
100 throw_get_ex(name, s_class_name, this);
101
102 return vec;
103 }
static const std::string & s_class_name
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...
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::DFApplication::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.

◆ get() [3/4]

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

Definition at line 105 of file DFApplication.cpp.

106 {
107 if (first_call)
108 {
109 std::lock_guard scoped_lock(m_mutex);
110
111 check();
112 check_init();
113
114 if (get_rel_objects(name, upcast_unregistered, vec))
115 return true;
116 }
117
118 if (SmartDaqApplication::get(name, vec, upcast_unregistered, false)) return true;
119 if (Resource::get(name, vec, upcast_unregistered, false)) return true;
120
121 if (first_call)
122 return get_algo_objects(name, vec);
123
124 return false;
125 }
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...
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
std::mutex m_mutex
Used to protect changes of DAL object.
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
void check_init() const
Check and initialize object if necessary.

◆ get() [4/4]

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

◆ get_data_writers() [1/2]

const std::vector< const dunedaq::appmodel::DataWriterConf * > & dunedaq::appmodel::DFApplication::get_data_writers ( ) const
inline

Get "data_writers" relationship value.

Returns
the relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 148 of file DFApplication.hpp.

149 {
150 std::lock_guard scoped_lock(m_mutex);
151 check();
152 check_init();
153 if (m_data_writers.empty())
154 {
155 std::ostringstream text;
156 text << "relationship \"" << s_data_writers << "\" of object " << this << " is empty";
157 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
158 }
159 return m_data_writers;
160 }
std::vector< const dunedaq::appmodel::DataWriterConf * > m_data_writers
Generic configuration exception.

◆ get_data_writers() [2/2]

const std::vector< const dunedaq::appmodel::DataWriterConf * > & dunedaq::appmodel::DFApplication::get_data_writers ( ) const
inline

Get "data_writers" relationship value.

Returns
the relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 148 of file DFApplication.hpp.

149 {
150 std::lock_guard scoped_lock(m_mutex);
151 check();
152 check_init();
153 if (m_data_writers.empty())
154 {
155 std::ostringstream text;
156 text << "relationship \"" << s_data_writers << "\" of object " << this << " is empty";
157 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
158 }
159 return m_data_writers;
160 }

◆ get_trb() [1/2]

const dunedaq::appmodel::TRBConf * dunedaq::appmodel::DFApplication::get_trb ( ) const
inline

Get "trb" relationship value. Configuration of the TRB to be generated my get_modules()

Returns
the relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 116 of file DFApplication.hpp.

117 {
118 std::lock_guard scoped_lock(m_mutex);
119 check();
120 check_init();
121 if (!m_trb)
122 {
123 std::ostringstream text;
124 text << "relationship \"" << s_trb << "\" of object " << this << " is not set";
125 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
126 }
127 return m_trb;
128 }

◆ get_trb() [2/2]

const dunedaq::appmodel::TRBConf * dunedaq::appmodel::DFApplication::get_trb ( ) const
inline

Get "trb" relationship value. Configuration of the TRB to be generated my get_modules()

Returns
the relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 116 of file DFApplication.hpp.

117 {
118 std::lock_guard scoped_lock(m_mutex);
119 check();
120 check_init();
121 if (!m_trb)
122 {
123 std::ostringstream text;
124 text << "relationship \"" << s_trb << "\" of object " << this << " is not set";
125 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
126 }
127 return m_trb;
128 }

◆ get_uses() [1/2]

const dunedaq::appmodel::DFHWConf * dunedaq::appmodel::DFApplication::get_uses ( ) const
inline

Get "uses" relationship value.

Returns
the relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 179 of file DFApplication.hpp.

180 {
181 std::lock_guard scoped_lock(m_mutex);
182 check();
183 check_init();
184 if (!m_uses)
185 {
186 std::ostringstream text;
187 text << "relationship \"" << s_uses << "\" of object " << this << " is not set";
188 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
189 }
190 return m_uses;
191 }

◆ get_uses() [2/2]

const dunedaq::appmodel::DFHWConf * dunedaq::appmodel::DFApplication::get_uses ( ) const
inline

Get "uses" relationship value.

Returns
the relationship value
Exceptions
dunedaq::conffwk::Generic,dunedaq::conffwk::DeletedObject

Definition at line 179 of file DFApplication.hpp.

180 {
181 std::lock_guard scoped_lock(m_mutex);
182 check();
183 check_init();
184 if (!m_uses)
185 {
186 std::ostringstream text;
187 text << "relationship \"" << s_uses << "\" of object " << this << " is not set";
188 throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
189 }
190 return m_uses;
191 }

◆ init() [1/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Reimplemented from dunedaq::appmodel::SmartDaqApplication.

Definition at line 74 of file DFApplication.cpp.

75 {
76 SmartDaqApplication::init(init_children);
77 Resource::init(init_children);
78
79 TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
80
81 try {
85 }
86 catch (dunedaq::conffwk::Exception & ex) {
87 throw_init_ex(ex);
88 }
89 }
virtual void init(bool init_children)
void throw_init_ex(dunedaq::conffwk::Exception &ex)
throw object initialisation exception (i.e.
Definition DalObject.cpp:74
DalRegistry & p_registry
Configuration object.
ConfigObject p_obj
Config object used by given template object.
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).
#define TLOG_DEBUG(lvl,...)
Definition Logging.hpp:112

◆ init() [2/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Reimplemented from dunedaq::appmodel::SmartDaqApplication.

◆ print() [1/2]

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

Print details of the DFApplication 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.

Definition at line 45 of file DFApplication.cpp.

46 {
47 check_init();
48
49 try {
50 const std::string str(indent+2, ' ');
51
52 if (print_header)
53 p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
54
55
56 // print direct super-classes
57
60
61
62 // print direct relationships
63
67 }
68 catch (dunedaq::conffwk::Exception & ex) {
70 }
71 }
virtual void print(unsigned int offset, bool print_header, std::ostream &s) const
Print details of the SmartDaqApplication object.
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
static void p_error(std::ostream &s, dunedaq::conffwk::Exception &ex)
print error text
Definition DalObject.cpp:59
virtual void print(unsigned int offset, bool print_header, std::ostream &s) const
Print details of the Resource object.
Definition Resource.cpp:22
void p_sv_rel(std::ostream &s, const std::string &str, const std::string &name, const DalObject *obj)
print weak single-value relationship
void p_mv_rel(std::ostream &s, const std::string &str, const std::string &name, const T &objs) noexcept
print weak multi-value relationship

◆ print() [2/2]

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

Print details of the DFApplication 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.

◆ set_data_writers() [1/2]

void dunedaq::appmodel::DFApplication::set_data_writers ( const std::vector< const dunedaq::appmodel::DataWriterConf * > & value)

Set "data_writers" relationship value.

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

Definition at line 132 of file DFApplication.cpp.

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

◆ set_data_writers() [2/2]

void dunedaq::appmodel::DFApplication::set_data_writers ( const std::vector< const dunedaq::appmodel::DataWriterConf * > & value)

Set "data_writers" relationship value.

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

◆ set_trb() [1/2]

void dunedaq::appmodel::DFApplication::set_trb ( const dunedaq::appmodel::TRBConf * value)

Set "trb" relationship value. Configuration of the TRB to be generated my get_modules()

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

Definition at line 127 of file DFApplication.cpp.

128 {
129 _set_object(s_trb, value);
130 }
void _set_object(const std::string &name, const T *value)
Helper method for generated set single-value relationship methods.

◆ set_trb() [2/2]

void dunedaq::appmodel::DFApplication::set_trb ( const dunedaq::appmodel::TRBConf * value)

Set "trb" relationship value. Configuration of the TRB to be generated my get_modules()

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

◆ set_uses() [1/2]

void dunedaq::appmodel::DFApplication::set_uses ( const dunedaq::appmodel::DFHWConf * value)

Set "uses" relationship value.

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

Definition at line 137 of file DFApplication.cpp.

138 {
139 _set_object(s_uses, value);
140 }

◆ set_uses() [2/2]

void dunedaq::appmodel::DFApplication::set_uses ( const dunedaq::appmodel::DFHWConf * value)

Set "uses" relationship value.

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

Friends And Related Symbol Documentation

◆ conffwk::Configuration

Definition at line 41 of file DFApplication.hpp.

◆ conffwk::DalFactory

conffwk::DalFactory
friend

Definition at line 43 of file DFApplication.hpp.

◆ conffwk::DalObject

Definition at line 42 of file DFApplication.hpp.

◆ conffwk::DalRegistry

Definition at line 44 of file DFApplication.hpp.

Member Data Documentation

◆ m_data_writers

std::vector< const dunedaq::appmodel::DataWriterConf * > dunedaq::appmodel::DFApplication::m_data_writers
private

Definition at line 91 of file DFApplication.hpp.

◆ m_trb

const dunedaq::appmodel::TRBConf * dunedaq::appmodel::DFApplication::m_trb
private

Definition at line 90 of file DFApplication.hpp.

◆ m_uses

const dunedaq::appmodel::DFHWConf * dunedaq::appmodel::DFApplication::m_uses
private

Definition at line 92 of file DFApplication.hpp.

◆ s_class_name

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

The name of the configuration class.

Definition at line 56 of file DFApplication.hpp.

◆ s_data_writers

static const std::string dunedaq::appmodel::DFApplication::s_data_writers = "data_writers"
inlinestatic

Definition at line 100 of file DFApplication.hpp.

◆ s_trb

static const std::string dunedaq::appmodel::DFApplication::s_trb = "trb"
inlinestatic

Definition at line 99 of file DFApplication.hpp.

◆ s_uses

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

Definition at line 101 of file DFApplication.hpp.


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