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

#include <DPDKPortConfiguration.hpp>

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

Public Member Functions

virtual void print (unsigned int offset, bool print_header, std::ostream &s) const
 Print details of the DPDKPortConfiguration 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.
 
bool get_flow_control () const
 Get "flow_control" attribute value.
 
void set_flow_control (bool value)
 Set "flow_control" attribute value.
 
bool get_promiscuous_mode () const
 Get "promiscuous_mode" attribute value.
 
void set_promiscuous_mode (bool value)
 Set "promiscuous_mode" attribute value.
 
uint32_t get_mtu () const
 Get "mtu" attribute value.
 
void set_mtu (uint32_t value)
 Set "mtu" attribute value.
 
uint32_t get_rx_ring_size () const
 Get "rx_ring_size" attribute value.
 
void set_rx_ring_size (uint32_t value)
 Set "rx_ring_size" attribute value.
 
uint32_t get_tx_ring_size () const
 Get "tx_ring_size" attribute value.
 
void set_tx_ring_size (uint32_t value)
 Set "tx_ring_size" attribute value.
 
uint32_t get_num_bufs () const
 Get "num_bufs" attribute value.
 
void set_num_bufs (uint32_t value)
 Set "num_bufs" attribute value.
 
uint32_t get_mbuf_cache_size () const
 Get "mbuf_cache_size" attribute value.
 
void set_mbuf_cache_size (uint32_t value)
 Set "mbuf_cache_size" attribute value.
 
uint32_t get_burst_size () const
 Get "burst_size" attribute value.
 
void set_burst_size (uint32_t value)
 Set "burst_size" attribute value.
 
uint32_t get_lcore_sleep_us () const
 Get "lcore_sleep_us" attribute value.
 
void set_lcore_sleep_us (uint32_t value)
 Set "lcore_sleep_us" attribute value.
 
int16_t get_source_to_rx_queue_multiplexing () const
 Get "source_to_rx_queue_multiplexing" attribute value. Indicates how many source streams are put onto one rx queue.
 
void set_source_to_rx_queue_multiplexing (int16_t value)
 Set "source_to_rx_queue_multiplexing" attribute value. Indicates how many source streams are put onto one rx queue.
 
const std::vector< const dunedaq::confmodel::ProcessingResource * > & get_used_lcores () const
 Get "used_lcores" relationship value. associates CPUs to the data reception workload.
 
void set_used_lcores (const std::vector< const dunedaq::confmodel::ProcessingResource * > &value)
 Set "used_lcores" relationship value. associates CPUs to the data reception workload.
 
virtual void print (unsigned int offset, bool print_header, std::ostream &s) const
 Print details of the DPDKPortConfiguration 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.
 
bool get_flow_control () const
 Get "flow_control" attribute value.
 
void set_flow_control (bool value)
 Set "flow_control" attribute value.
 
bool get_promiscuous_mode () const
 Get "promiscuous_mode" attribute value.
 
void set_promiscuous_mode (bool value)
 Set "promiscuous_mode" attribute value.
 
uint32_t get_mtu () const
 Get "mtu" attribute value.
 
void set_mtu (uint32_t value)
 Set "mtu" attribute value.
 
uint32_t get_rx_ring_size () const
 Get "rx_ring_size" attribute value.
 
void set_rx_ring_size (uint32_t value)
 Set "rx_ring_size" attribute value.
 
uint32_t get_tx_ring_size () const
 Get "tx_ring_size" attribute value.
 
void set_tx_ring_size (uint32_t value)
 Set "tx_ring_size" attribute value.
 
uint32_t get_num_bufs () const
 Get "num_bufs" attribute value.
 
void set_num_bufs (uint32_t value)
 Set "num_bufs" attribute value.
 
uint32_t get_mbuf_cache_size () const
 Get "mbuf_cache_size" attribute value.
 
void set_mbuf_cache_size (uint32_t value)
 Set "mbuf_cache_size" attribute value.
 
uint32_t get_burst_size () const
 Get "burst_size" attribute value.
 
void set_burst_size (uint32_t value)
 Set "burst_size" attribute value.
 
uint32_t get_lcore_sleep_us () const
 Get "lcore_sleep_us" attribute value.
 
void set_lcore_sleep_us (uint32_t value)
 Set "lcore_sleep_us" attribute value.
 
int16_t get_source_to_rx_queue_multiplexing () const
 Get "source_to_rx_queue_multiplexing" attribute value. Indicates how many source streams are put onto one rx queue.
 
void set_source_to_rx_queue_multiplexing (int16_t value)
 Set "source_to_rx_queue_multiplexing" attribute value. Indicates how many source streams are put onto one rx queue.
 
const std::vector< const dunedaq::confmodel::ProcessingResource * > & get_used_lcores () const
 Get "used_lcores" relationship value. associates CPUs to the data reception workload.
 
void set_used_lcores (const std::vector< const dunedaq::confmodel::ProcessingResource * > &value)
 Set "used_lcores" relationship value. associates CPUs to the data reception workload.
 
- 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.
 

Static Public Member Functions

static const std::string & __get_flow_control_str () noexcept
 
static const std::string & __get_promiscuous_mode_str () noexcept
 
static const std::string & __get_mtu_str () noexcept
 
static const std::string & __get_rx_ring_size_str () noexcept
 
static const std::string & __get_tx_ring_size_str () noexcept
 
static const std::string & __get_num_bufs_str () noexcept
 
static const std::string & __get_mbuf_cache_size_str () noexcept
 
static const std::string & __get_burst_size_str () noexcept
 
static const std::string & __get_lcore_sleep_us_str () noexcept
 
static const std::string & __get_source_to_rx_queue_multiplexing_str () noexcept
 
static const std::string & __get_used_lcores_str () noexcept
 
static const std::string & __get_flow_control_str () noexcept
 
static const std::string & __get_promiscuous_mode_str () noexcept
 
static const std::string & __get_mtu_str () noexcept
 
static const std::string & __get_rx_ring_size_str () noexcept
 
static const std::string & __get_tx_ring_size_str () noexcept
 
static const std::string & __get_num_bufs_str () noexcept
 
static const std::string & __get_mbuf_cache_size_str () noexcept
 
static const std::string & __get_burst_size_str () noexcept
 
static const std::string & __get_lcore_sleep_us_str () noexcept
 
static const std::string & __get_source_to_rx_queue_multiplexing_str () noexcept
 
static const std::string & __get_used_lcores_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_flow_control = "flow_control"
 
static const std::string s_promiscuous_mode = "promiscuous_mode"
 
static const std::string s_mtu = "mtu"
 
static const std::string s_rx_ring_size = "rx_ring_size"
 
static const std::string s_tx_ring_size = "tx_ring_size"
 
static const std::string s_num_bufs = "num_bufs"
 
static const std::string s_mbuf_cache_size = "mbuf_cache_size"
 
static const std::string s_burst_size = "burst_size"
 
static const std::string s_lcore_sleep_us = "lcore_sleep_us"
 
static const std::string s_source_to_rx_queue_multiplexing = "source_to_rx_queue_multiplexing"
 
static const std::string s_used_lcores = "used_lcores"
 

Protected Member Functions

 DPDKPortConfiguration (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~DPDKPortConfiguration () 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
 
 DPDKPortConfiguration (conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
 
virtual ~DPDKPortConfiguration () 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::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.
 

Private Attributes

bool m_flow_control
 
bool m_promiscuous_mode
 
uint32_t m_mtu
 
uint32_t m_rx_ring_size
 
uint32_t m_tx_ring_size
 
uint32_t m_num_bufs
 
uint32_t m_mbuf_cache_size
 
uint32_t m_burst_size
 
uint32_t m_lcore_sleep_us
 
int16_t m_source_to_rx_queue_multiplexing
 
std::vector< const dunedaq::confmodel::ProcessingResource * > m_used_lcores
 

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 29 of file DPDKPortConfiguration.hpp.

Constructor & Destructor Documentation

◆ DPDKPortConfiguration() [1/2]

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

Definition at line 31 of file DPDKPortConfiguration.cpp.

31 :
32 dunedaq::conffwk::DalObject(db, o)
33 {
34 ;
35 }
dunedaq::conffwk::DalObject
The base class for any generated DAL object.
Definition DalObject.hpp:45

◆ ~DPDKPortConfiguration() [1/2]

dunedaq::appmodel::DPDKPortConfiguration::~DPDKPortConfiguration ( )
protectedvirtualnoexcept

Definition at line 97 of file DPDKPortConfiguration.cpp.

98 {
99 }

◆ DPDKPortConfiguration() [2/2]

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

◆ ~DPDKPortConfiguration() [2/2]

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

Member Function Documentation

◆ __get_burst_size_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_burst_size_str ( )
inlinestaticnoexcept

Definition at line 115 of file DPDKPortConfiguration.hpp.

115{ return s_burst_size; }

◆ __get_burst_size_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_burst_size_str ( )
inlinestaticnoexcept

Definition at line 115 of file DPDKPortConfiguration.hpp.

115{ return s_burst_size; }

◆ __get_flow_control_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_flow_control_str ( )
inlinestaticnoexcept

Definition at line 108 of file DPDKPortConfiguration.hpp.

108{ return s_flow_control; }

◆ __get_flow_control_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_flow_control_str ( )
inlinestaticnoexcept

Definition at line 108 of file DPDKPortConfiguration.hpp.

108{ return s_flow_control; }

◆ __get_lcore_sleep_us_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_lcore_sleep_us_str ( )
inlinestaticnoexcept

Definition at line 116 of file DPDKPortConfiguration.hpp.

116{ return s_lcore_sleep_us; }

◆ __get_lcore_sleep_us_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_lcore_sleep_us_str ( )
inlinestaticnoexcept

Definition at line 116 of file DPDKPortConfiguration.hpp.

116{ return s_lcore_sleep_us; }

◆ __get_mbuf_cache_size_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_mbuf_cache_size_str ( )
inlinestaticnoexcept

Definition at line 114 of file DPDKPortConfiguration.hpp.

114{ return s_mbuf_cache_size; }

◆ __get_mbuf_cache_size_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_mbuf_cache_size_str ( )
inlinestaticnoexcept

Definition at line 114 of file DPDKPortConfiguration.hpp.

114{ return s_mbuf_cache_size; }

◆ __get_mtu_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_mtu_str ( )
inlinestaticnoexcept

Definition at line 110 of file DPDKPortConfiguration.hpp.

110{ return s_mtu; }

◆ __get_mtu_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_mtu_str ( )
inlinestaticnoexcept

Definition at line 110 of file DPDKPortConfiguration.hpp.

110{ return s_mtu; }

◆ __get_num_bufs_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_num_bufs_str ( )
inlinestaticnoexcept

Definition at line 113 of file DPDKPortConfiguration.hpp.

113{ return s_num_bufs; }

◆ __get_num_bufs_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_num_bufs_str ( )
inlinestaticnoexcept

Definition at line 113 of file DPDKPortConfiguration.hpp.

113{ return s_num_bufs; }

◆ __get_promiscuous_mode_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_promiscuous_mode_str ( )
inlinestaticnoexcept

Definition at line 109 of file DPDKPortConfiguration.hpp.

109{ return s_promiscuous_mode; }

◆ __get_promiscuous_mode_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_promiscuous_mode_str ( )
inlinestaticnoexcept

Definition at line 109 of file DPDKPortConfiguration.hpp.

109{ return s_promiscuous_mode; }

◆ __get_rx_ring_size_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_rx_ring_size_str ( )
inlinestaticnoexcept

Definition at line 111 of file DPDKPortConfiguration.hpp.

111{ return s_rx_ring_size; }

◆ __get_rx_ring_size_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_rx_ring_size_str ( )
inlinestaticnoexcept

Definition at line 111 of file DPDKPortConfiguration.hpp.

111{ return s_rx_ring_size; }

◆ __get_source_to_rx_queue_multiplexing_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_source_to_rx_queue_multiplexing_str ( )
inlinestaticnoexcept

Definition at line 117 of file DPDKPortConfiguration.hpp.

117{ return s_source_to_rx_queue_multiplexing; }

◆ __get_source_to_rx_queue_multiplexing_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_source_to_rx_queue_multiplexing_str ( )
inlinestaticnoexcept

Definition at line 117 of file DPDKPortConfiguration.hpp.

117{ return s_source_to_rx_queue_multiplexing; }

◆ __get_tx_ring_size_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_tx_ring_size_str ( )
inlinestaticnoexcept

Definition at line 112 of file DPDKPortConfiguration.hpp.

112{ return s_tx_ring_size; }

◆ __get_tx_ring_size_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_tx_ring_size_str ( )
inlinestaticnoexcept

Definition at line 112 of file DPDKPortConfiguration.hpp.

112{ return s_tx_ring_size; }

◆ __get_used_lcores_str() [1/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_used_lcores_str ( )
inlinestaticnoexcept

Definition at line 436 of file DPDKPortConfiguration.hpp.

436{ return s_used_lcores; }

◆ __get_used_lcores_str() [2/2]

static const std::string & dunedaq::appmodel::DPDKPortConfiguration::__get_used_lcores_str ( )
inlinestaticnoexcept

Definition at line 436 of file DPDKPortConfiguration.hpp.

436{ return s_used_lcores; }

◆ get() [1/4]

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

Implements dunedaq::conffwk::DalObject.

Definition at line 101 of file DPDKPortConfiguration.cpp.

102 {
103 std::vector<const dunedaq::conffwk::DalObject *> vec;
104
105 if (!get(name, vec, upcast_unregistered, true))
106 throw_get_ex(name, s_class_name, this);
107
108 return vec;
109 }
dunedaq::appmodel::DPDKPortConfiguration::get
virtual std::vector< const dunedaq::conffwk::DalObject * > get(const std::string &name, bool upcast_unregistered=true) const
Get values of relationships and results of some algorithms as a vector of dunedaq::conffwk::DalObject...
Definition DPDKPortConfiguration.cpp:101
dunedaq::conffwk::DalObject::throw_get_ex
static void throw_get_ex(const std::string &what, const std::string &class_name, const DalObject *obj)
throw exception in generated get method (i.e.
Definition DalObject.cpp:82

◆ get() [2/4]

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

Implements dunedaq::conffwk::DalObject.

◆ get() [3/4]

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

Definition at line 111 of file DPDKPortConfiguration.cpp.

112 {
113 if (first_call)
114 {
115 std::lock_guard scoped_lock(m_mutex);
116
117 check();
118 check_init();
119
120 if (get_rel_objects(name, upcast_unregistered, vec))
121 return true;
122 }
123
124 if (first_call)
125 return get_algo_objects(name, vec);
126
127 return false;
128 }
dunedaq::conffwk::DalObject::get_rel_objects
bool get_rel_objects(const std::string &name, bool upcast_unregistered, std::vector< const DalObject * > &objs) const
Read relationship values as DAL objects using DAL factory.
Definition DalObject.cpp:8
dunedaq::conffwk::DalObject::m_mutex
std::mutex m_mutex
Used to protect changes of DAL object.
Definition DalObject.hpp:108
dunedaq::conffwk::DalObject::get_algo_objects
bool get_algo_objects(const std::string &name, std::vector< const DalObject * > &objs) const
Run algorithm and return result as DAL objects using DAL factory.
Definition DalObject.cpp:25
dunedaq::conffwk::DalObject::check_init
void check_init() const
Check and initialize object if necessary.
Definition DalObject.hpp:405

◆ get() [4/4]

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

◆ get_burst_size() [1/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_burst_size ( ) const
inline

Get "burst_size" attribute value.

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

Definition at line 344 of file DPDKPortConfiguration.hpp.

345 {
346 std::lock_guard scoped_lock(m_mutex);
347 check();
348 check_init();
349 return m_burst_size;
350 }

◆ get_burst_size() [2/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_burst_size ( ) const
inline

Get "burst_size" attribute value.

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

Definition at line 344 of file DPDKPortConfiguration.hpp.

345 {
346 std::lock_guard scoped_lock(m_mutex);
347 check();
348 check_init();
349 return m_burst_size;
350 }

◆ get_flow_control() [1/2]

bool dunedaq::appmodel::DPDKPortConfiguration::get_flow_control ( ) const
inline

Get "flow_control" attribute value.

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

Definition at line 127 of file DPDKPortConfiguration.hpp.

128 {
129 std::lock_guard scoped_lock(m_mutex);
130 check();
131 check_init();
132 return m_flow_control;
133 }

◆ get_flow_control() [2/2]

bool dunedaq::appmodel::DPDKPortConfiguration::get_flow_control ( ) const
inline

Get "flow_control" attribute value.

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

Definition at line 127 of file DPDKPortConfiguration.hpp.

128 {
129 std::lock_guard scoped_lock(m_mutex);
130 check();
131 check_init();
132 return m_flow_control;
133 }

◆ get_lcore_sleep_us() [1/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_lcore_sleep_us ( ) const
inline

Get "lcore_sleep_us" attribute value.

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

Definition at line 375 of file DPDKPortConfiguration.hpp.

376 {
377 std::lock_guard scoped_lock(m_mutex);
378 check();
379 check_init();
380 return m_lcore_sleep_us;
381 }

◆ get_lcore_sleep_us() [2/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_lcore_sleep_us ( ) const
inline

Get "lcore_sleep_us" attribute value.

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

Definition at line 375 of file DPDKPortConfiguration.hpp.

376 {
377 std::lock_guard scoped_lock(m_mutex);
378 check();
379 check_init();
380 return m_lcore_sleep_us;
381 }

◆ get_mbuf_cache_size() [1/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_mbuf_cache_size ( ) const
inline

Get "mbuf_cache_size" attribute value.

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

Definition at line 313 of file DPDKPortConfiguration.hpp.

314 {
315 std::lock_guard scoped_lock(m_mutex);
316 check();
317 check_init();
318 return m_mbuf_cache_size;
319 }

◆ get_mbuf_cache_size() [2/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_mbuf_cache_size ( ) const
inline

Get "mbuf_cache_size" attribute value.

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

Definition at line 313 of file DPDKPortConfiguration.hpp.

314 {
315 std::lock_guard scoped_lock(m_mutex);
316 check();
317 check_init();
318 return m_mbuf_cache_size;
319 }

◆ get_mtu() [1/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_mtu ( ) const
inline

Get "mtu" attribute value.

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

Definition at line 189 of file DPDKPortConfiguration.hpp.

190 {
191 std::lock_guard scoped_lock(m_mutex);
192 check();
193 check_init();
194 return m_mtu;
195 }

◆ get_mtu() [2/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_mtu ( ) const
inline

Get "mtu" attribute value.

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

Definition at line 189 of file DPDKPortConfiguration.hpp.

190 {
191 std::lock_guard scoped_lock(m_mutex);
192 check();
193 check_init();
194 return m_mtu;
195 }

◆ get_num_bufs() [1/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_num_bufs ( ) const
inline

Get "num_bufs" attribute value.

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

Definition at line 282 of file DPDKPortConfiguration.hpp.

283 {
284 std::lock_guard scoped_lock(m_mutex);
285 check();
286 check_init();
287 return m_num_bufs;
288 }

◆ get_num_bufs() [2/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_num_bufs ( ) const
inline

Get "num_bufs" attribute value.

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

Definition at line 282 of file DPDKPortConfiguration.hpp.

283 {
284 std::lock_guard scoped_lock(m_mutex);
285 check();
286 check_init();
287 return m_num_bufs;
288 }

◆ get_promiscuous_mode() [1/2]

bool dunedaq::appmodel::DPDKPortConfiguration::get_promiscuous_mode ( ) const
inline

Get "promiscuous_mode" attribute value.

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

Definition at line 158 of file DPDKPortConfiguration.hpp.

159 {
160 std::lock_guard scoped_lock(m_mutex);
161 check();
162 check_init();
163 return m_promiscuous_mode;
164 }

◆ get_promiscuous_mode() [2/2]

bool dunedaq::appmodel::DPDKPortConfiguration::get_promiscuous_mode ( ) const
inline

Get "promiscuous_mode" attribute value.

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

Definition at line 158 of file DPDKPortConfiguration.hpp.

159 {
160 std::lock_guard scoped_lock(m_mutex);
161 check();
162 check_init();
163 return m_promiscuous_mode;
164 }

◆ get_rx_ring_size() [1/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_rx_ring_size ( ) const
inline

Get "rx_ring_size" attribute value.

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

Definition at line 220 of file DPDKPortConfiguration.hpp.

221 {
222 std::lock_guard scoped_lock(m_mutex);
223 check();
224 check_init();
225 return m_rx_ring_size;
226 }

◆ get_rx_ring_size() [2/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_rx_ring_size ( ) const
inline

Get "rx_ring_size" attribute value.

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

Definition at line 220 of file DPDKPortConfiguration.hpp.

221 {
222 std::lock_guard scoped_lock(m_mutex);
223 check();
224 check_init();
225 return m_rx_ring_size;
226 }

◆ get_source_to_rx_queue_multiplexing() [1/2]

int16_t dunedaq::appmodel::DPDKPortConfiguration::get_source_to_rx_queue_multiplexing ( ) const
inline

Get "source_to_rx_queue_multiplexing" attribute value. Indicates how many source streams are put onto one rx queue.

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

Definition at line 407 of file DPDKPortConfiguration.hpp.

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

◆ get_source_to_rx_queue_multiplexing() [2/2]

int16_t dunedaq::appmodel::DPDKPortConfiguration::get_source_to_rx_queue_multiplexing ( ) const
inline

Get "source_to_rx_queue_multiplexing" attribute value. Indicates how many source streams are put onto one rx queue.

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

Definition at line 407 of file DPDKPortConfiguration.hpp.

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

◆ get_tx_ring_size() [1/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_tx_ring_size ( ) const
inline

Get "tx_ring_size" attribute value.

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

Definition at line 251 of file DPDKPortConfiguration.hpp.

252 {
253 std::lock_guard scoped_lock(m_mutex);
254 check();
255 check_init();
256 return m_tx_ring_size;
257 }

◆ get_tx_ring_size() [2/2]

uint32_t dunedaq::appmodel::DPDKPortConfiguration::get_tx_ring_size ( ) const
inline

Get "tx_ring_size" attribute value.

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

Definition at line 251 of file DPDKPortConfiguration.hpp.

252 {
253 std::lock_guard scoped_lock(m_mutex);
254 check();
255 check_init();
256 return m_tx_ring_size;
257 }

◆ get_used_lcores() [1/2]

const std::vector< const dunedaq::confmodel::ProcessingResource * > & dunedaq::appmodel::DPDKPortConfiguration::get_used_lcores ( ) const
inline

Get "used_lcores" relationship value. associates CPUs to the data reception workload.

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

Definition at line 447 of file DPDKPortConfiguration.hpp.

448 {
449 std::lock_guard scoped_lock(m_mutex);
450 check();
451 check_init();
452 return m_used_lcores;
453 }
dunedaq::appmodel::DPDKPortConfiguration::m_used_lcores
std::vector< const dunedaq::confmodel::ProcessingResource * > m_used_lcores
Definition DPDKPortConfiguration.hpp:90

◆ get_used_lcores() [2/2]

const std::vector< const dunedaq::confmodel::ProcessingResource * > & dunedaq::appmodel::DPDKPortConfiguration::get_used_lcores ( ) const
inline

Get "used_lcores" relationship value. associates CPUs to the data reception workload.

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

Definition at line 447 of file DPDKPortConfiguration.hpp.

448 {
449 std::lock_guard scoped_lock(m_mutex);
450 check();
451 check_init();
452 return m_used_lcores;
453 }

◆ init() [1/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Implements dunedaq::conffwk::DalObject.

Definition at line 73 of file DPDKPortConfiguration.cpp.

74 {
75 p_was_read = true;
76 increment_read();
77 TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
78
79 try {
80 p_obj.get(s_flow_control, m_flow_control);
81 p_obj.get(s_promiscuous_mode, m_promiscuous_mode);
82 p_obj.get(s_mtu, m_mtu);
83 p_obj.get(s_rx_ring_size, m_rx_ring_size);
84 p_obj.get(s_tx_ring_size, m_tx_ring_size);
85 p_obj.get(s_num_bufs, m_num_bufs);
86 p_obj.get(s_mbuf_cache_size, m_mbuf_cache_size);
87 p_obj.get(s_burst_size, m_burst_size);
88 p_obj.get(s_lcore_sleep_us, m_lcore_sleep_us);
89 p_obj.get(s_source_to_rx_queue_multiplexing, m_source_to_rx_queue_multiplexing);
90 p_registry._ref<dunedaq::confmodel::ProcessingResource>(p_obj, s_used_lcores, m_used_lcores, init_children);
91 }
92 catch (dunedaq::conffwk::Exception & ex) {
93 throw_init_ex(ex);
94 }
95 }
dunedaq::conffwk::ConfigObject::get
void get(const std::string &name, T &value)
Get value of object's attribute or relationship.
Definition ConfigObject.hpp:278
dunedaq::conffwk::DalObject::throw_init_ex
void throw_init_ex(dunedaq::conffwk::Exception &ex)
throw object initialisation exception (i.e.
Definition DalObject.cpp:74
dunedaq::conffwk::DalObject::increment_read
void increment_read() noexcept
Definition DalObject.hpp:352
dunedaq::conffwk::DalObject::p_registry
DalRegistry & p_registry
Configuration object.
Definition DalObject.hpp:114
dunedaq::conffwk::DalObject::p_was_read
bool p_was_read
is true, if the object was read
Definition DalObject.hpp:111
dunedaq::conffwk::DalObject::p_obj
ConfigObject p_obj
Config object used by given template object.
Definition DalObject.hpp:117
dunedaq::conffwk::DalRegistry::_ref
const T * _ref(ConfigObject &obj, const std::string &name, bool read_children)
Get signle value of object's relation and instantiate result with it (multi-thread safe).
Definition DalRegistry.hxx:164
TLOG_DEBUG
#define TLOG_DEBUG(lvl,...)
Definition Logging.hpp:112

◆ init() [2/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Implements dunedaq::conffwk::DalObject.

◆ print() [1/2]

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

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

Implements dunedaq::conffwk::DalObject.

Definition at line 38 of file DPDKPortConfiguration.cpp.

39 {
40 check_init();
41
42 try {
43 const std::string str(indent+2, ' ');
44
45 if (print_header)
46 p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
47
48
49 // print direct attributes
50
51 dunedaq::conffwk::p_sv_attr(s, str, s_flow_control, m_flow_control);
52 dunedaq::conffwk::p_sv_attr(s, str, s_promiscuous_mode, m_promiscuous_mode);
53 dunedaq::conffwk::p_sv_attr(s, str, s_mtu, m_mtu);
54 dunedaq::conffwk::p_sv_attr(s, str, s_rx_ring_size, m_rx_ring_size);
55 dunedaq::conffwk::p_sv_attr(s, str, s_tx_ring_size, m_tx_ring_size);
56 dunedaq::conffwk::p_sv_attr(s, str, s_num_bufs, m_num_bufs);
57 dunedaq::conffwk::p_sv_attr(s, str, s_mbuf_cache_size, m_mbuf_cache_size);
58 dunedaq::conffwk::p_sv_attr(s, str, s_burst_size, m_burst_size);
59 dunedaq::conffwk::p_sv_attr(s, str, s_lcore_sleep_us, m_lcore_sleep_us);
60 dunedaq::conffwk::p_sv_attr(s, str, s_source_to_rx_queue_multiplexing, m_source_to_rx_queue_multiplexing);
61
62
63 // print direct relationships
64
65 dunedaq::conffwk::p_mv_rel(s, str, s_used_lcores, m_used_lcores);
66 }
67 catch (dunedaq::conffwk::Exception & ex) {
68 dunedaq::conffwk::DalObject::p_error(s, ex);
69 }
70 }
dunedaq::conffwk::DalObject::p_hdr
void p_hdr(std::ostream &s, unsigned int indent, const std::string &cl, const char *nm=nullptr) const
print object headers
Definition DalObject.cpp:65
dunedaq::conffwk::DalObject::p_error
static void p_error(std::ostream &s, dunedaq::conffwk::Exception &ex)
print error text
Definition DalObject.cpp:59
dunedaq::conffwk::p_mv_rel
void p_mv_rel(std::ostream &s, const std::string &str, const std::string &name, const T &objs) noexcept
print weak multi-value relationship
Definition DalObjectPrint.hpp:114
dunedaq::conffwk::p_sv_attr
void p_sv_attr(std::ostream &s, const std::string &str, const std::string &name, const T &val) noexcept
print single-value attribute
Definition DalObjectPrint.hpp:61

◆ print() [2/2]

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

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

Implements dunedaq::conffwk::DalObject.

◆ set_burst_size() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_burst_size ( uint32_t value)
inline

Set "burst_size" attribute value.

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

Definition at line 359 of file DPDKPortConfiguration.hpp.

360 {
361 std::lock_guard scoped_lock(m_mutex);
362 check();
363 clear();
364 p_obj.set_by_val(s_burst_size, value);
365 }
dunedaq::conffwk::ConfigObject::set_by_val
void set_by_val(const std::string &name, T value)
Set attribute value.
Definition ConfigObject.hpp:391

◆ set_burst_size() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_burst_size ( uint32_t value)
inline

Set "burst_size" attribute value.

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

Definition at line 359 of file DPDKPortConfiguration.hpp.

360 {
361 std::lock_guard scoped_lock(m_mutex);
362 check();
363 clear();
364 p_obj.set_by_val(s_burst_size, value);
365 }

◆ set_flow_control() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_flow_control ( bool value)
inline

Set "flow_control" attribute value.

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

Definition at line 142 of file DPDKPortConfiguration.hpp.

143 {
144 std::lock_guard scoped_lock(m_mutex);
145 check();
146 clear();
147 p_obj.set_by_val(s_flow_control, value);
148 }

◆ set_flow_control() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_flow_control ( bool value)
inline

Set "flow_control" attribute value.

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

Definition at line 142 of file DPDKPortConfiguration.hpp.

143 {
144 std::lock_guard scoped_lock(m_mutex);
145 check();
146 clear();
147 p_obj.set_by_val(s_flow_control, value);
148 }

◆ set_lcore_sleep_us() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_lcore_sleep_us ( uint32_t value)
inline

Set "lcore_sleep_us" attribute value.

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

Definition at line 390 of file DPDKPortConfiguration.hpp.

391 {
392 std::lock_guard scoped_lock(m_mutex);
393 check();
394 clear();
395 p_obj.set_by_val(s_lcore_sleep_us, value);
396 }

◆ set_lcore_sleep_us() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_lcore_sleep_us ( uint32_t value)
inline

Set "lcore_sleep_us" attribute value.

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

Definition at line 390 of file DPDKPortConfiguration.hpp.

391 {
392 std::lock_guard scoped_lock(m_mutex);
393 check();
394 clear();
395 p_obj.set_by_val(s_lcore_sleep_us, value);
396 }

◆ set_mbuf_cache_size() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_mbuf_cache_size ( uint32_t value)
inline

Set "mbuf_cache_size" attribute value.

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

Definition at line 328 of file DPDKPortConfiguration.hpp.

329 {
330 std::lock_guard scoped_lock(m_mutex);
331 check();
332 clear();
333 p_obj.set_by_val(s_mbuf_cache_size, value);
334 }

◆ set_mbuf_cache_size() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_mbuf_cache_size ( uint32_t value)
inline

Set "mbuf_cache_size" attribute value.

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

Definition at line 328 of file DPDKPortConfiguration.hpp.

329 {
330 std::lock_guard scoped_lock(m_mutex);
331 check();
332 clear();
333 p_obj.set_by_val(s_mbuf_cache_size, value);
334 }

◆ set_mtu() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_mtu ( uint32_t value)
inline

Set "mtu" attribute value.

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

Definition at line 204 of file DPDKPortConfiguration.hpp.

205 {
206 std::lock_guard scoped_lock(m_mutex);
207 check();
208 clear();
209 p_obj.set_by_val(s_mtu, value);
210 }

◆ set_mtu() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_mtu ( uint32_t value)
inline

Set "mtu" attribute value.

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

Definition at line 204 of file DPDKPortConfiguration.hpp.

205 {
206 std::lock_guard scoped_lock(m_mutex);
207 check();
208 clear();
209 p_obj.set_by_val(s_mtu, value);
210 }

◆ set_num_bufs() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_num_bufs ( uint32_t value)
inline

Set "num_bufs" attribute value.

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

Definition at line 297 of file DPDKPortConfiguration.hpp.

298 {
299 std::lock_guard scoped_lock(m_mutex);
300 check();
301 clear();
302 p_obj.set_by_val(s_num_bufs, value);
303 }

◆ set_num_bufs() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_num_bufs ( uint32_t value)
inline

Set "num_bufs" attribute value.

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

Definition at line 297 of file DPDKPortConfiguration.hpp.

298 {
299 std::lock_guard scoped_lock(m_mutex);
300 check();
301 clear();
302 p_obj.set_by_val(s_num_bufs, value);
303 }

◆ set_promiscuous_mode() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_promiscuous_mode ( bool value)
inline

Set "promiscuous_mode" attribute value.

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

Definition at line 173 of file DPDKPortConfiguration.hpp.

174 {
175 std::lock_guard scoped_lock(m_mutex);
176 check();
177 clear();
178 p_obj.set_by_val(s_promiscuous_mode, value);
179 }

◆ set_promiscuous_mode() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_promiscuous_mode ( bool value)
inline

Set "promiscuous_mode" attribute value.

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

Definition at line 173 of file DPDKPortConfiguration.hpp.

174 {
175 std::lock_guard scoped_lock(m_mutex);
176 check();
177 clear();
178 p_obj.set_by_val(s_promiscuous_mode, value);
179 }

◆ set_rx_ring_size() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_rx_ring_size ( uint32_t value)
inline

Set "rx_ring_size" attribute value.

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

Definition at line 235 of file DPDKPortConfiguration.hpp.

236 {
237 std::lock_guard scoped_lock(m_mutex);
238 check();
239 clear();
240 p_obj.set_by_val(s_rx_ring_size, value);
241 }

◆ set_rx_ring_size() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_rx_ring_size ( uint32_t value)
inline

Set "rx_ring_size" attribute value.

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

Definition at line 235 of file DPDKPortConfiguration.hpp.

236 {
237 std::lock_guard scoped_lock(m_mutex);
238 check();
239 clear();
240 p_obj.set_by_val(s_rx_ring_size, value);
241 }

◆ set_source_to_rx_queue_multiplexing() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_source_to_rx_queue_multiplexing ( int16_t value)
inline

Set "source_to_rx_queue_multiplexing" attribute value. Indicates how many source streams are put onto one rx queue.

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

Definition at line 423 of file DPDKPortConfiguration.hpp.

424 {
425 std::lock_guard scoped_lock(m_mutex);
426 check();
427 clear();
428 p_obj.set_by_val(s_source_to_rx_queue_multiplexing, value);
429 }

◆ set_source_to_rx_queue_multiplexing() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_source_to_rx_queue_multiplexing ( int16_t value)
inline

Set "source_to_rx_queue_multiplexing" attribute value. Indicates how many source streams are put onto one rx queue.

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

Definition at line 423 of file DPDKPortConfiguration.hpp.

424 {
425 std::lock_guard scoped_lock(m_mutex);
426 check();
427 clear();
428 p_obj.set_by_val(s_source_to_rx_queue_multiplexing, value);
429 }

◆ set_tx_ring_size() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_tx_ring_size ( uint32_t value)
inline

Set "tx_ring_size" attribute value.

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

Definition at line 266 of file DPDKPortConfiguration.hpp.

267 {
268 std::lock_guard scoped_lock(m_mutex);
269 check();
270 clear();
271 p_obj.set_by_val(s_tx_ring_size, value);
272 }

◆ set_tx_ring_size() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_tx_ring_size ( uint32_t value)
inline

Set "tx_ring_size" attribute value.

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

Definition at line 266 of file DPDKPortConfiguration.hpp.

267 {
268 std::lock_guard scoped_lock(m_mutex);
269 check();
270 clear();
271 p_obj.set_by_val(s_tx_ring_size, value);
272 }

◆ set_used_lcores() [1/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_used_lcores ( const std::vector< const dunedaq::confmodel::ProcessingResource * > & value)

Set "used_lcores" relationship value. associates CPUs to the data reception workload.

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

Definition at line 130 of file DPDKPortConfiguration.cpp.

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

◆ set_used_lcores() [2/2]

void dunedaq::appmodel::DPDKPortConfiguration::set_used_lcores ( const std::vector< const dunedaq::confmodel::ProcessingResource * > & value)

Set "used_lcores" relationship value. associates CPUs to the data reception workload.

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

Friends And Related Symbol Documentation

◆ conffwk::Configuration

conffwk::Configuration
friend

Definition at line 31 of file DPDKPortConfiguration.hpp.

◆ conffwk::DalFactory

conffwk::DalFactory
friend

Definition at line 33 of file DPDKPortConfiguration.hpp.

◆ conffwk::DalObject

conffwk::DalObject
friend

Definition at line 32 of file DPDKPortConfiguration.hpp.

◆ conffwk::DalRegistry

conffwk::DalRegistry
friend

Definition at line 34 of file DPDKPortConfiguration.hpp.

Member Data Documentation

◆ m_burst_size

uint32_t dunedaq::appmodel::DPDKPortConfiguration::m_burst_size
private

Definition at line 87 of file DPDKPortConfiguration.hpp.

◆ m_flow_control

bool dunedaq::appmodel::DPDKPortConfiguration::m_flow_control
private

Definition at line 80 of file DPDKPortConfiguration.hpp.

◆ m_lcore_sleep_us

uint32_t dunedaq::appmodel::DPDKPortConfiguration::m_lcore_sleep_us
private

Definition at line 88 of file DPDKPortConfiguration.hpp.

◆ m_mbuf_cache_size

uint32_t dunedaq::appmodel::DPDKPortConfiguration::m_mbuf_cache_size
private

Definition at line 86 of file DPDKPortConfiguration.hpp.

◆ m_mtu

uint32_t dunedaq::appmodel::DPDKPortConfiguration::m_mtu
private

Definition at line 82 of file DPDKPortConfiguration.hpp.

◆ m_num_bufs

uint32_t dunedaq::appmodel::DPDKPortConfiguration::m_num_bufs
private

Definition at line 85 of file DPDKPortConfiguration.hpp.

◆ m_promiscuous_mode

bool dunedaq::appmodel::DPDKPortConfiguration::m_promiscuous_mode
private

Definition at line 81 of file DPDKPortConfiguration.hpp.

◆ m_rx_ring_size

uint32_t dunedaq::appmodel::DPDKPortConfiguration::m_rx_ring_size
private

Definition at line 83 of file DPDKPortConfiguration.hpp.

◆ m_source_to_rx_queue_multiplexing

int16_t dunedaq::appmodel::DPDKPortConfiguration::m_source_to_rx_queue_multiplexing
private

Definition at line 89 of file DPDKPortConfiguration.hpp.

◆ m_tx_ring_size

uint32_t dunedaq::appmodel::DPDKPortConfiguration::m_tx_ring_size
private

Definition at line 84 of file DPDKPortConfiguration.hpp.

◆ m_used_lcores

std::vector< const dunedaq::confmodel::ProcessingResource * > dunedaq::appmodel::DPDKPortConfiguration::m_used_lcores
private

Definition at line 90 of file DPDKPortConfiguration.hpp.

◆ s_burst_size

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_burst_size = "burst_size"
inlinestatic

Definition at line 104 of file DPDKPortConfiguration.hpp.

◆ s_class_name

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

The name of the configuration class.

Definition at line 46 of file DPDKPortConfiguration.hpp.

◆ s_flow_control

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_flow_control = "flow_control"
inlinestatic

Definition at line 97 of file DPDKPortConfiguration.hpp.

◆ s_lcore_sleep_us

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_lcore_sleep_us = "lcore_sleep_us"
inlinestatic

Definition at line 105 of file DPDKPortConfiguration.hpp.

◆ s_mbuf_cache_size

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_mbuf_cache_size = "mbuf_cache_size"
inlinestatic

Definition at line 103 of file DPDKPortConfiguration.hpp.

◆ s_mtu

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_mtu = "mtu"
inlinestatic

Definition at line 99 of file DPDKPortConfiguration.hpp.

◆ s_num_bufs

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_num_bufs = "num_bufs"
inlinestatic

Definition at line 102 of file DPDKPortConfiguration.hpp.

◆ s_promiscuous_mode

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_promiscuous_mode = "promiscuous_mode"
inlinestatic

Definition at line 98 of file DPDKPortConfiguration.hpp.

◆ s_rx_ring_size

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_rx_ring_size = "rx_ring_size"
inlinestatic

Definition at line 100 of file DPDKPortConfiguration.hpp.

◆ s_source_to_rx_queue_multiplexing

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_source_to_rx_queue_multiplexing = "source_to_rx_queue_multiplexing"
inlinestatic

Definition at line 106 of file DPDKPortConfiguration.hpp.

◆ s_tx_ring_size

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_tx_ring_size = "tx_ring_size"
inlinestatic

Definition at line 101 of file DPDKPortConfiguration.hpp.

◆ s_used_lcores

static const std::string dunedaq::appmodel::DPDKPortConfiguration::s_used_lcores = "used_lcores"
inlinestatic

Definition at line 434 of file DPDKPortConfiguration.hpp.

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