#include <FakeDataApplication.hpp>

Inheritance diagram for dunedaq::appmodel::FakeDataApplication:

Collaboration diagram for dunedaq::appmodel::FakeDataApplication:

Public Member Functions
virtual void	print (unsigned int offset, bool print_header, std::ostream &s) const
	Print details of the FakeDataApplication object.
virtual std::vector< const dunedaq::conffwk::DalObject * >	get (const std::string &name, bool upcast_unregistered=true) const
	Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject pointers.
const std::string &	get_application_name () const
	Get "application_name" attribute value.
void	set_application_name (const std::string &value)
	Set "application_name" attribute value.
const std::vector< const dunedaq::appmodel::FakeDataProdConf * > &	get_producers () const
	Get "producers" relationship value. List of configurations of fake data producer modules to be used by this application.
void	set_producers (const std::vector< const dunedaq::appmodel::FakeDataProdConf * > &value)
	Set "producers" relationship value. List of configurations of fake data producer modules to be used by this application.
const dunedaq::appmodel::FragmentAggregatorConf *	get_fragment_aggregator () const
	Get "fragment_aggregator" relationship value.
void	set_fragment_aggregator (const dunedaq::appmodel::FragmentAggregatorConf *value)
	Set "fragment_aggregator" relationship value.
void	generate_modules (std::shared_ptr< appmodel::ConfigurationHelper >) const override
virtual std::vector< const ExcludableEntity * >	contained_excludable_entities () const override
virtual void	print (unsigned int offset, bool print_header, std::ostream &s) const
	Print details of the FakeDataApplication object.
virtual std::vector< const dunedaq::conffwk::DalObject * >	get (const std::string &name, bool upcast_unregistered=true) const
	Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject pointers.
const std::string &	get_application_name () const
	Get "application_name" attribute value.
void	set_application_name (const std::string &value)
	Set "application_name" attribute value.
const std::vector< const dunedaq::appmodel::FakeDataProdConf * > &	get_producers () const
	Get "producers" relationship value. List of configurations of fake data producer modules to be used by this application.
void	set_producers (const std::vector< const dunedaq::appmodel::FakeDataProdConf * > &value)
	Set "producers" relationship value. List of configurations of fake data producer modules to be used by this application.
const dunedaq::appmodel::FragmentAggregatorConf *	get_fragment_aggregator () const
	Get "fragment_aggregator" relationship value.
void	set_fragment_aggregator (const dunedaq::appmodel::FragmentAggregatorConf *value)
	Set "fragment_aggregator" relationship value.
void	generate_modules (std::shared_ptr< appmodel::ConfigurationHelper >) const override
virtual std::vector< const ExcludableEntity * >	contained_excludable_entities () const override
Public Member Functions inherited from dunedaq::confmodel::ExcludableEntitySetAND
bool	compute_excluded_state (const std::set< std::string > &excluded) const final
bool	compute_excluded_state (const std::set< std::string > &excluded) const final
Public Member Functions inherited from dunedaq::confmodel::ExcludableEntity
void	parents (const dunedaq::confmodel::Session &session, std::list< std::vector< const dunedaq::confmodel::ExcludableEntity * > > &parents) const
bool	is_excluded (const dunedaq::confmodel::ExcludableEntityTree &session) const
void	parents (const dunedaq::confmodel::Session &session, std::list< std::vector< const dunedaq::confmodel::ExcludableEntity * > > &parents) const
bool	is_excluded (const dunedaq::confmodel::ExcludableEntityTree &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 dunedaq::appmodel::SourceIDConf *	get_source_id () const
	Get "source_id" relationship value.
void	set_source_id (const dunedaq::appmodel::SourceIDConf *value)
	Set "source_id" relationship value.
const std::vector< const dunedaq::appmodel::QueueConnectionRule * > &	get_queue_rules () const
	Get "queue_rules" relationship value.
void	set_queue_rules (const std::vector< const dunedaq::appmodel::QueueConnectionRule * > &value)
	Set "queue_rules" relationship value.
const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > &	get_network_rules () const
	Get "network_rules" relationship value.
void	set_network_rules (const std::vector< const dunedaq::appmodel::NetworkConnectionRule * > &value)
	Set "network_rules" relationship value.
Public Member Functions inherited from dunedaq::confmodel::DaqApplication
const std::string &	get_application_name () const
	Get "application_name" attribute value. Name of the application binary to run.
void	set_application_name (const std::string &value)
	Set "application_name" attribute value. Name of the application binary to run.
const std::vector< const dunedaq::confmodel::DaqModule * > &	get_modules () const
	Get "modules" relationship value.
void	set_modules (const std::vector< const dunedaq::confmodel::DaqModule * > &value)
	Set "modules" relationship value.
const std::vector< const dunedaq::confmodel::ActionPlan * > &	get_action_plans () const
	Get "action_plans" relationship value.
void	set_action_plans (const std::vector< const dunedaq::confmodel::ActionPlan * > &value)
	Set "action_plans" relationship value.
std::set< const dunedaq::confmodel::HostComponent * >	get_used_host_components () 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_host_components () const
const std::vector< std::string >	construct_commandline_parameters (const conffwk::Configuration &confdb, const dunedaq::confmodel::Session *session) const
Public Member Functions inherited from dunedaq::confmodel::Application
const std::string &	get_application_name () const
	Get "application_name" attribute value. Name of the application binary to run.
void	set_application_name (const std::string &value)
	Set "application_name" attribute value. Name of the application binary to run.
const std::vector< std::string > &	get_commandline_parameters () const
	Get "commandline_parameters" attribute value. command line parameters to add when starting the application.
void	set_commandline_parameters (const std::vector< std::string > &value)
	Set "commandline_parameters" attribute value. command line parameters to add when starting the application.
const std::string &	get_log_path () const
	Get "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.
void	set_log_path (const std::string &value)
	Set "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.
const std::vector< const dunedaq::confmodel::VariableBase * > &	get_application_environment () const
	Get "application_environment" relationship value. Define process environment for this application.
void	set_application_environment (const std::vector< const dunedaq::confmodel::VariableBase * > &value)
	Set "application_environment" relationship value. Define process environment for this application.
const dunedaq::confmodel::VirtualHost *	get_runs_on () const
	Get "runs_on" relationship value. VirtualHost to run this application on.
void	set_runs_on (const dunedaq::confmodel::VirtualHost *value)
	Set "runs_on" relationship value. VirtualHost to run this application on.
const std::vector< const dunedaq::confmodel::Service * > &	get_exposes_service () const
	Get "exposes_service" relationship value. Services exposed i.e. provided by this application.
void	set_exposes_service (const std::vector< const dunedaq::confmodel::Service * > &value)
	Set "exposes_service" relationship value. Services exposed i.e. provided by this application.
const dunedaq::confmodel::OpMonConf *	get_opmon_conf () const
	Get "opmon_conf" relationship value. description of the monitoring behaviour in the application.
void	set_opmon_conf (const dunedaq::confmodel::OpMonConf *value)
	Set "opmon_conf" relationship value. description of the monitoring behaviour in the application.
const std::vector< std::string >	parse_commandline_parameters () const
const std::string &	get_application_name () const
	Get "application_name" attribute value. Name of the application binary to run.
void	set_application_name (const std::string &value)
	Set "application_name" attribute value. Name of the application binary to run.
const std::vector< std::string > &	get_commandline_parameters () const
	Get "commandline_parameters" attribute value. command line parameters to add when starting the application.
void	set_commandline_parameters (const std::vector< std::string > &value)
	Set "commandline_parameters" attribute value. command line parameters to add when starting the application.
const std::string &	get_log_path () const
	Get "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.
void	set_log_path (const std::string &value)
	Set "log_path" attribute value. Where the applications, controllers and infrastructure applications stdout/err go. This take precedence over the Session's log_path. If none of them is set, PWD is used.
const std::vector< const dunedaq::confmodel::VariableBase * > &	get_application_environment () const
	Get "application_environment" relationship value. Define process environment for this application.
void	set_application_environment (const std::vector< const dunedaq::confmodel::VariableBase * > &value)
	Set "application_environment" relationship value. Define process environment for this application.
const dunedaq::confmodel::VirtualHost *	get_runs_on () const
	Get "runs_on" relationship value. VirtualHost to run this application on.
void	set_runs_on (const dunedaq::confmodel::VirtualHost *value)
	Set "runs_on" relationship value. VirtualHost to run this application on.
const std::vector< const dunedaq::confmodel::Service * > &	get_exposes_service () const
	Get "exposes_service" relationship value. Services exposed i.e. provided by this application.
void	set_exposes_service (const std::vector< const dunedaq::confmodel::Service * > &value)
	Set "exposes_service" relationship value. Services exposed i.e. provided by this application.
const dunedaq::confmodel::OpMonConf *	get_opmon_conf () const
	Get "opmon_conf" relationship value. description of the monitoring behaviour in the application.
void	set_opmon_conf (const dunedaq::confmodel::OpMonConf *value)
	Set "opmon_conf" relationship value. description of the monitoring behaviour in the application.
const std::vector< std::string >	parse_commandline_parameters () const

Static Public Member Functions
static const std::string &	__get_application_name_str () noexcept
static const std::string &	__get_producers_str () noexcept
static const std::string &	__get_fragment_aggregator_str () noexcept
static const std::string &	__get_application_name_str () noexcept
static const std::string &	__get_producers_str () noexcept
static const std::string &	__get_fragment_aggregator_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_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 Attributes
static const std::string &	s_class_name
static const std::string	s_application_name = "application_name"
static const std::string	s_producers = "producers"
static const std::string	s_fragment_aggregator = "fragment_aggregator"
Static Public Attributes inherited from dunedaq::confmodel::ExcludableEntitySetAND
static const std::string &	s_class_name
Static Public Attributes inherited from dunedaq::confmodel::ExcludableEntitySet
static const std::string &	s_class_name
Static Public Attributes inherited from dunedaq::confmodel::ExcludableEntity
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 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"

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

Private Attributes
std::string	m_application_name
std::vector< const dunedaq::appmodel::FakeDataProdConf * >	m_producers
const dunedaq::appmodel::FragmentAggregatorConf *	m_fragment_aggregator

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

Additional Inherited Members
Protected Attributes inherited from dunedaq::conffwk::DalObject
std::mutex	m_mutex
	Used to protect changes of DAL object.
bool	p_was_read
	is true, if the object was read
DalRegistry &	p_registry
	Configuration object.
ConfigObject	p_obj
	Config object used by given template object.
std::string	p_UID
	Is used for template objects (see dqm_conffwk).

Detailed Description

Definition at line 38 of file FakeDataApplication.hpp.

Constructor & Destructor Documentation

◆ FakeDataApplication() [1/2]

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

protectednoexcept

Definition at line 32 of file FakeDataApplication.cpp.

                                                                                                          :
      dunedaq::conffwk::DalObject(db, o),
      dunedaq::confmodel::ExcludableEntitySetAND(db, o),
      SmartDaqApplication(db, o),
      m_fragment_aggregator (nullptr)
 
    {
      ;
    }

◆ ~FakeDataApplication() [1/2]

dunedaq::appmodel::FakeDataApplication::~FakeDataApplication ( )

protectedvirtualnoexcept

Definition at line 93 of file FakeDataApplication.cpp.

94 {

95 }

◆ FakeDataApplication() [2/2]

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

protectednoexcept

◆ ~FakeDataApplication() [2/2]

virtual dunedaq::appmodel::FakeDataApplication::~FakeDataApplication ( )

protectedvirtualnoexcept

Member Function Documentation

◆ __get_application_name_str() [1/2]

const std::string & dunedaq::appmodel::FakeDataApplication::__get_application_name_str ( )

inlinestaticnoexcept

Definition at line 100 of file FakeDataApplication.hpp.

100{ return s_application_name; }

dunedaq::appmodel::FakeDataApplication::s_application_name

static const std::string s_application_name

Definition FakeDataApplication.hpp:98

◆ __get_application_name_str() [2/2]

const std::string & dunedaq::appmodel::FakeDataApplication::__get_application_name_str ( )

inlinestaticnoexcept

Definition at line 100 of file FakeDataApplication.hpp.

100{ return s_application_name; }

◆ __get_fragment_aggregator_str() [1/2]

const std::string & dunedaq::appmodel::FakeDataApplication::__get_fragment_aggregator_str ( )

inlinestaticnoexcept

Definition at line 140 of file FakeDataApplication.hpp.

140{ return s_fragment_aggregator; }

dunedaq::appmodel::FakeDataApplication::s_fragment_aggregator

static const std::string s_fragment_aggregator

Definition FakeDataApplication.hpp:137

◆ __get_fragment_aggregator_str() [2/2]

const std::string & dunedaq::appmodel::FakeDataApplication::__get_fragment_aggregator_str ( )

inlinestaticnoexcept

Definition at line 140 of file FakeDataApplication.hpp.

140{ return s_fragment_aggregator; }

◆ __get_producers_str() [1/2]

const std::string & dunedaq::appmodel::FakeDataApplication::__get_producers_str ( )

inlinestaticnoexcept

Definition at line 139 of file FakeDataApplication.hpp.

139{ return s_producers; }

dunedaq::appmodel::FakeDataApplication::s_producers

static const std::string s_producers

Definition FakeDataApplication.hpp:136

◆ __get_producers_str() [2/2]

const std::string & dunedaq::appmodel::FakeDataApplication::__get_producers_str ( )

inlinestaticnoexcept

Definition at line 139 of file FakeDataApplication.hpp.

139{ return s_producers; }

◆ contained_excludable_entities() [1/2]

std::vector< const confmodel::ExcludableEntity * > dunedaq::appmodel::FakeDataApplication::contained_excludable_entities ( ) const

overridevirtual

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

Implements dunedaq::confmodel::ExcludableEntitySet.

Definition at line 45 of file FakeDataApplication.cpp.

{
  return to_resources(get_producers());
}

◆ contained_excludable_entities() [2/2]

virtual std::vector< const ExcludableEntity * > dunedaq::appmodel::FakeDataApplication::contained_excludable_entities ( ) const

overridevirtual

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

Implements dunedaq::confmodel::ExcludableEntitySet.

◆ generate_modules() [1/2]

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

overridevirtual

Generate daq module dal objects for streams of the FakeDataApplication on the fly

Implements dunedaq::appmodel::SmartDaqApplication.

Definition at line 51 of file FakeDataApplication.cpp.

{
  // oks::OksFile::set_nolock_mode(true);
 
  std::vector<const confmodel::DaqModule*> modules;
 
  ConfigObjectFactory obj_fac(this);
 
  // Process the queue rules looking for inputs to our DL/TP handler modules
  const QueueDescriptor* dlhReqInputQDesc = nullptr;
  const QueueDescriptor* faOutputQDesc = nullptr;
 
  for (auto rule : get_queue_rules()) {
    auto destination_class = rule->get_destination_class();
    auto data_type = rule->get_descriptor()->get_data_type();
    if (destination_class == "FakeDataProdModule") {
      if (data_type == "DataRequest") {
        dlhReqInputQDesc = rule->get_descriptor();
      }
    } else if (destination_class == "FragmentAggregatorModule") {
      faOutputQDesc = rule->get_descriptor();
    }
  }
  if (faOutputQDesc == nullptr) {
    throw(BadConf(ERS_HERE, "No fragment output queue descriptor given"));
  }
  if (dlhReqInputQDesc == nullptr) {
    throw(BadConf(ERS_HERE, "No DLH request input queue descriptor given"));
  }
  // Process the network rules looking for the Fragment Aggregator and TP handler data reuest inputs
  const NetworkConnectionDescriptor* faNetDesc = nullptr;
  const NetworkConnectionDescriptor* tsNetDesc = nullptr;
  for (auto rule : get_network_rules()) {
    auto endpoint_class = rule->get_endpoint_class();
    if (endpoint_class == "FragmentAggregatorModule") {
      faNetDesc = rule->get_descriptor();
    } else if (endpoint_class == "FakeDataProdModule") {
      tsNetDesc = rule->get_descriptor();
    }
  }
  if (faNetDesc == nullptr) {
    throw(BadConf(ERS_HERE, "No Fragment output network descriptor given"));
  }
  if (tsNetDesc == nullptr) {
    throw(BadConf(ERS_HERE, "No TimeSync output network descriptor given"));
  }
 
  // Create here the Queue on which all data fragments are forwarded to the fragment aggregator
  // and a container for the queues of data request to TP handler and DLH
 
  std::vector<const confmodel::Connection*> faOutputQueues;
 
  conffwk::ConfigObject faQueueObj = obj_fac.create_queue_obj(faOutputQDesc, UID());
 
  // Create a FakeDataProdModule for each stream of this Readout Group
  for (auto fdpConf : get_producers()) {
    if (helper->is_excluded(fdpConf)) {
      TLOG_DEBUG(7) << "Ignoring excluded FakeDataProdConf " << fdpConf->UID();
      continue;
    }
 
    auto stream = fdpConf->cast<appmodel::FakeDataProdConf>();
    if (stream == nullptr) {
      throw(BadConf(ERS_HERE, "ReadoutGroup contains something other than FakeDataProdConf"));
    }
 
    auto id = stream->get_source_id();
    std::string uid("FakeDataProdModule-" + std::to_string(id));
    TLOG_DEBUG(7) << "creating OKS configuration object for FakeDataProdModule";
    conffwk::ConfigObject dlhObj = obj_fac.create("FakeDataProdModule", uid);
    dlhObj.set_obj("configuration", &stream->config_object());
 
    // Time Sync network connection
    auto tsNetObj = obj_fac.create_net_obj(tsNetDesc, std::to_string(id));
 
    dlhObj.set_objs("outputs", { &faQueueObj, &tsNetObj });
 
    auto reqQueueObj = obj_fac.create_queue_sid_obj(dlhReqInputQDesc, id);
 
    // Add the requessts queue dal pointer to the outputs of the FragmentAggregatorModule
    faOutputQueues.push_back(
      obj_fac.get_dal<confmodel::Connection>(dlhReqInputQDesc->get_uid_base() + std::to_string(id)));
 
    dlhObj.set_objs("inputs", { &reqQueueObj });
 
    modules.push_back(obj_fac.get_dal<FakeDataProdModule>(uid));
  }
 
  // Finally create Fragment Aggregator
  auto aggregator_conf = get_fragment_aggregator();
  if (aggregator_conf == 0) {
    throw(BadConf(ERS_HERE, "No FragmentAggregatorModule configuration given"));
  }
  std::string faUid("fragmentaggregator-" + UID());
  TLOG_DEBUG(7) << "creating OKS configuration object for Fragment Aggregator class ";
  conffwk::ConfigObject faObj = obj_fac.create("FragmentAggregatorModule", faUid);
 
  // Add network connection to TRBs
  conffwk::ConfigObject faNetObj = obj_fac.create_net_obj(faNetDesc, UID());
 
  // Add output queueus of data requests
  std::vector<const conffwk::ConfigObject*> qObjs;
  for (auto q : faOutputQueues) {
    qObjs.push_back(&q->config_object());
  }
  faObj.set_obj("configuration", &aggregator_conf->config_object());
  faObj.set_objs("inputs", { &faNetObj, &faQueueObj });
  faObj.set_objs("outputs", qObjs);
 
  modules.push_back(obj_fac.get_dal<FragmentAggregatorModule>(faUid));
 
  obj_fac.update_modules(modules);
}

◆ generate_modules() [2/2]

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

overridevirtual

Generate daq module dal objects for streams of the FakeDataApplication on the fly

Implements dunedaq::appmodel::SmartDaqApplication.

◆ get() [1/4]

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

virtual

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

Parameters are:

Parameters

name	name of the relationship or algorithm

Returns: value of relationship or result of algorithm

Exceptions

std::exception if there is no relationship or algorithm with such name in this and base classes

Reimplemented from dunedaq::confmodel::ExcludableEntitySetAND.

Definition at line 97 of file FakeDataApplication.cpp.

    {
      std::vector<const dunedaq::conffwk::DalObject *> vec;
 
      if (!get(name, vec, upcast_unregistered, true))
        throw_get_ex(name, s_class_name, this);
 
      return vec;
    }

◆ get() [2/4]

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

virtual

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

Parameters are:

Parameters

name	name of the relationship or algorithm

Returns: value of relationship or result of algorithm

Exceptions

std::exception if there is no relationship or algorithm with such name in this and base classes

Reimplemented from dunedaq::confmodel::ExcludableEntitySetAND.

◆ get() [3/4]

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

protected

Definition at line 107 of file FakeDataApplication.cpp.

    {
      if (first_call)
        {
          std::lock_guard scoped_lock(m_mutex);
 
          check();
          check_init();
 
          if (get_rel_objects(name, upcast_unregistered, vec))
            return true;
        }
 
      if (ExcludableEntitySetAND::get(name, vec, upcast_unregistered, false)) return true;
      if (SmartDaqApplication::get(name, vec, upcast_unregistered, false)) return true;
 
      if (first_call)
        return get_algo_objects(name, vec);
 
      return false;
    }

◆ get() [4/4]

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

protected

◆ get_application_name() [1/2]

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

inline

Get "application_name" attribute value.

Returns: the attribute value

Exceptions

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

Definition at line 110 of file FakeDataApplication.hpp.

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

◆ get_application_name() [2/2]

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

inline

Get "application_name" attribute value.

Returns: the attribute value

Exceptions

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

Definition at line 110 of file FakeDataApplication.hpp.

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

◆ get_fragment_aggregator() [1/2]

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

inline

Get "fragment_aggregator" relationship value.

Returns: the relationship value

Exceptions

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

Definition at line 183 of file FakeDataApplication.hpp.

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

◆ get_fragment_aggregator() [2/2]

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

inline

Get "fragment_aggregator" relationship value.

Returns: the relationship value

Exceptions

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

Definition at line 183 of file FakeDataApplication.hpp.

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

◆ get_producers() [1/2]

const std::vector< const dunedaq::appmodel::FakeDataProdConf * > & dunedaq::appmodel::FakeDataApplication::get_producers ( ) const

inline

Get "producers" relationship value. List of configurations of fake data producer modules to be used by this application.

Returns: the relationship value

Exceptions

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

Definition at line 151 of file FakeDataApplication.hpp.

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

◆ get_producers() [2/2]

const std::vector< const dunedaq::appmodel::FakeDataProdConf * > & dunedaq::appmodel::FakeDataApplication::get_producers ( ) const

inline

Get "producers" relationship value. List of configurations of fake data producer modules to be used by this application.

Returns: the relationship value

Exceptions

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

Definition at line 151 of file FakeDataApplication.hpp.

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

◆ init() [1/2]

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

protectedvirtual

Initialize object (method generated by genconffwk)

Parameters

init_children if true, initialize referenced objects

Reimplemented from dunedaq::confmodel::ExcludableEntitySetAND.

Definition at line 76 of file FakeDataApplication.cpp.

    {
      ExcludableEntitySetAND::init(init_children);
      SmartDaqApplication::init(init_children);
 
      TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
 
      try {
        p_obj.get(s_application_name, m_application_name);
        p_registry._ref<dunedaq::appmodel::FakeDataProdConf>(p_obj, s_producers, m_producers, init_children);
        m_fragment_aggregator = p_registry._ref<dunedaq::appmodel::FragmentAggregatorConf>(p_obj, s_fragment_aggregator, init_children);
      }
      catch (dunedaq::conffwk::Exception & ex) {
        throw_init_ex(ex);
      }
    }

◆ init() [2/2]

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

protectedvirtual

Initialize object (method generated by genconffwk)

Parameters

init_children if true, initialize referenced objects

Reimplemented from dunedaq::confmodel::ExcludableEntitySetAND.

◆ print() [1/2]

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

virtual

Print details of the FakeDataApplication object.

Parameters are:

Parameters

offset	number of spaces to shift object right (useful to print nested objects)
print_header	if false, do not print object header (to print attributes of base classes)
s	output stream

Reimplemented from dunedaq::confmodel::ExcludableEntitySetAND.

Definition at line 43 of file FakeDataApplication.cpp.

    {
      check_init();
 
      try {
        const std::string str(indent+2, ' ');
 
        if (print_header)
          p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
 
 
          // print direct super-classes
 
        dunedaq::confmodel::ExcludableEntitySetAND::print(indent, false, s);
        dunedaq::appmodel::SmartDaqApplication::print(indent, false, s);
 
 
          // print direct attributes
 
        dunedaq::conffwk::p_sv_attr(s, str, s_application_name, m_application_name);
 
 
          // print direct relationships
 
        dunedaq::conffwk::p_mv_rel(s, str, indent, s_producers, m_producers);
        dunedaq::conffwk::p_sv_rel(s, str, s_fragment_aggregator, m_fragment_aggregator);
      }
      catch (dunedaq::conffwk::Exception & ex) {
        dunedaq::conffwk::DalObject::p_error(s, ex);
      }
    }

◆ print() [2/2]

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

virtual

Print details of the FakeDataApplication object.

Parameters are:

Parameters

offset	number of spaces to shift object right (useful to print nested objects)
print_header	if false, do not print object header (to print attributes of base classes)
s	output stream

Reimplemented from dunedaq::confmodel::ExcludableEntitySetAND.

◆ set_application_name() [1/2]

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

inline

Set "application_name" attribute value.

Parameters

value new attribute value

Exceptions

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

Definition at line 125 of file FakeDataApplication.hpp.

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

◆ set_application_name() [2/2]

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

inline

Set "application_name" attribute value.

Parameters

value new attribute value

Exceptions

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

Definition at line 125 of file FakeDataApplication.hpp.

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

◆ set_fragment_aggregator() [1/2]

void dunedaq::appmodel::FakeDataApplication::set_fragment_aggregator ( const dunedaq::appmodel::FragmentAggregatorConf * value )

Set "fragment_aggregator" relationship value.

Parameters

value new relationship value

Exceptions

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

Definition at line 134 of file FakeDataApplication.cpp.

    {
      _set_object(s_fragment_aggregator, value);
    }

◆ set_fragment_aggregator() [2/2]

void dunedaq::appmodel::FakeDataApplication::set_fragment_aggregator ( const dunedaq::appmodel::FragmentAggregatorConf * value )

Set "fragment_aggregator" relationship value.

Parameters

value new relationship value

Exceptions

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

◆ set_producers() [1/2]

void dunedaq::appmodel::FakeDataApplication::set_producers ( const std::vector< const dunedaq::appmodel::FakeDataProdConf * > & value )

Set "producers" relationship value. List of configurations of fake data producer modules to be used by this application.

Parameters

value new relationship value

Exceptions

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

Definition at line 129 of file FakeDataApplication.cpp.

    {
      _set_objects(s_producers, value);
    }

◆ set_producers() [2/2]

void dunedaq::appmodel::FakeDataApplication::set_producers ( const std::vector< const dunedaq::appmodel::FakeDataProdConf * > & value )

Set "producers" relationship value. List of configurations of fake data producer modules to be used by this application.

Parameters

value new relationship value

Exceptions

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

◆ conffwk::Configuration

conffwk::Configuration

friend

Definition at line 40 of file FakeDataApplication.hpp.

◆ conffwk::DalFactory

conffwk::DalFactory

friend

Definition at line 42 of file FakeDataApplication.hpp.

◆ conffwk::DalObject

conffwk::DalObject

friend

Definition at line 41 of file FakeDataApplication.hpp.

◆ conffwk::DalRegistry

conffwk::DalRegistry

friend

Definition at line 43 of file FakeDataApplication.hpp.

Member Data Documentation

◆ m_application_name

std::string dunedaq::appmodel::FakeDataApplication::m_application_name

private

Definition at line 89 of file FakeDataApplication.hpp.

◆ m_fragment_aggregator

const dunedaq::appmodel::FragmentAggregatorConf * dunedaq::appmodel::FakeDataApplication::m_fragment_aggregator

private

Definition at line 91 of file FakeDataApplication.hpp.

◆ m_producers

std::vector< const dunedaq::appmodel::FakeDataProdConf * > dunedaq::appmodel::FakeDataApplication::m_producers

private

Definition at line 90 of file FakeDataApplication.hpp.

◆ s_application_name

const std::string dunedaq::appmodel::FakeDataApplication::s_application_name = "application_name"

inlinestatic

Definition at line 98 of file FakeDataApplication.hpp.

◆ s_class_name

const std::string & dunedaq::appmodel::FakeDataApplication::s_class_name

static

The name of the configuration class.

Definition at line 55 of file FakeDataApplication.hpp.

◆ s_fragment_aggregator

const std::string dunedaq::appmodel::FakeDataApplication::s_fragment_aggregator = "fragment_aggregator"

inlinestatic

Definition at line 137 of file FakeDataApplication.hpp.

◆ s_producers

const std::string dunedaq::appmodel::FakeDataApplication::s_producers = "producers"

inlinestatic

Definition at line 136 of file FakeDataApplication.hpp.

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

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

Public Member Functions

Static Public Member Functions

Static Public Attributes

Protected Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ FakeDataApplication() [1/2]

◆ ~FakeDataApplication() [1/2]

◆ FakeDataApplication() [2/2]

◆ ~FakeDataApplication() [2/2]

Member Function Documentation

◆ __get_application_name_str() [1/2]

◆ __get_application_name_str() [2/2]

◆ __get_fragment_aggregator_str() [1/2]

◆ __get_fragment_aggregator_str() [2/2]

◆ __get_producers_str() [1/2]

◆ __get_producers_str() [2/2]

◆ contained_excludable_entities() [1/2]

◆ contained_excludable_entities() [2/2]

◆ generate_modules() [1/2]

◆ generate_modules() [2/2]

◆ get() [1/4]

◆ get() [2/4]

◆ get() [3/4]

◆ get() [4/4]

◆ get_application_name() [1/2]

◆ get_application_name() [2/2]

◆ get_fragment_aggregator() [1/2]

◆ get_fragment_aggregator() [2/2]

◆ get_producers() [1/2]

◆ get_producers() [2/2]

◆ init() [1/2]

◆ init() [2/2]

◆ print() [1/2]

◆ print() [2/2]

◆ set_application_name() [1/2]

◆ set_application_name() [2/2]

◆ set_fragment_aggregator() [1/2]

◆ set_fragment_aggregator() [2/2]

◆ set_producers() [1/2]

◆ set_producers() [2/2]

Friends And Related Symbol Documentation

◆ conffwk::Configuration

◆ conffwk::DalFactory

◆ conffwk::DalObject

◆ conffwk::DalRegistry

Member Data Documentation

◆ m_application_name

◆ m_fragment_aggregator

◆ m_producers

◆ s_application_name

◆ s_class_name

◆ s_fragment_aggregator

◆ s_producers