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::TCDataProcessor Class Reference

#include <TCDataProcessor.hpp>

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

Public Member Functions

virtual void print (unsigned int offset, bool print_header, std::ostream &s) const
 Print details of the TCDataProcessor 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_merge_overlapping_tcs () const
 Get "merge_overlapping_tcs" attribute value. Option to turn off merging of overlapping TCs when forming TDs in MLT.
 
void set_merge_overlapping_tcs (bool value)
 Set "merge_overlapping_tcs" attribute value. Option to turn off merging of overlapping TCs when forming TDs in MLT.
 
bool get_ignore_overlapping_tcs () const
 Get "ignore_overlapping_tcs" attribute value. Option to ignore consecutive overlapping TCs/pileup events. Cannot run with mlt_merge_overlapping_tcs.
 
void set_ignore_overlapping_tcs (bool value)
 Set "ignore_overlapping_tcs" attribute value. Option to ignore consecutive overlapping TCs/pileup events. Cannot run with mlt_merge_overlapping_tcs.
 
bool get_td_out_of_timeout () const
 Get "td_out_of_timeout" attribute value. Option to drop TD if TC comes out of timeout window.
 
void set_td_out_of_timeout (bool value)
 Set "td_out_of_timeout" attribute value. Option to drop TD if TC comes out of timeout window.
 
uint32_t get_buffer_timeout () const
 Get "buffer_timeout" attribute value. Timeout (buffer) to wait for new overlapping TCs before sending TD, in ms.
 
void set_buffer_timeout (uint32_t value)
 Set "buffer_timeout" attribute value. Timeout (buffer) to wait for new overlapping TCs before sending TD, in ms.
 
uint32_t get_td_readout_limit () const
 Get "td_readout_limit" attribute value. Maximum allowed time length (in ticks) for a readout window of a single TD.
 
void set_td_readout_limit (uint32_t value)
 Set "td_readout_limit" attribute value. Maximum allowed time length (in ticks) for a readout window of a single TD.
 
const std::vector< uint32_t > & get_ignore_tc () const
 Get "ignore_tc" attribute value. Optional list of TC types to be ignored in MLT.
 
void set_ignore_tc (const std::vector< uint32_t > &value)
 Set "ignore_tc" attribute value. Optional list of TC types to be ignored in MLT.
 
const std::vector< const dunedaq::appmodel::TriggerBitword * > & get_trigger_bitwords () const
 Get "trigger_bitwords" relationship value. Optional dictionary of bitwords to use when forming trigger decisions in MLT.
 
void set_trigger_bitwords (const std::vector< const dunedaq::appmodel::TriggerBitword * > &value)
 Set "trigger_bitwords" relationship value. Optional dictionary of bitwords to use when forming trigger decisions in MLT.
 
const std::vector< const dunedaq::appmodel::ROIGroupConf * > & get_roi_group_conf () const
 Get "roi_group_conf" relationship value. The configuration (table) for ROI readout (currently not used)
 
void set_roi_group_conf (const std::vector< const dunedaq::appmodel::ROIGroupConf * > &value)
 Set "roi_group_conf" relationship value. The configuration (table) for ROI readout (currently not used)
 
const std::vector< const dunedaq::appmodel::TCReadoutMap * > & get_tc_readout_map () const
 Get "tc_readout_map" relationship value. The readout windows assigned to TDs in MLT, based on TC type.
 
void set_tc_readout_map (const std::vector< const dunedaq::appmodel::TCReadoutMap * > &value)
 Set "tc_readout_map" relationship value. The readout windows assigned to TDs in MLT, based on TC type.
 
const std::vector< const dunedaq::appmodel::SourceIDConf * > & get_mandatory_links () const
 Get "mandatory_links" relationship value. Source Ids that will always be included in a trigger decision.
 
void set_mandatory_links (const std::vector< const dunedaq::appmodel::SourceIDConf * > &value)
 Set "mandatory_links" relationship value. Source Ids that will always be included in a trigger decision.
 
virtual void print (unsigned int offset, bool print_header, std::ostream &s) const
 Print details of the TCDataProcessor 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_merge_overlapping_tcs () const
 Get "merge_overlapping_tcs" attribute value. Option to turn off merging of overlapping TCs when forming TDs in MLT.
 
void set_merge_overlapping_tcs (bool value)
 Set "merge_overlapping_tcs" attribute value. Option to turn off merging of overlapping TCs when forming TDs in MLT.
 
bool get_ignore_overlapping_tcs () const
 Get "ignore_overlapping_tcs" attribute value. Option to ignore consecutive overlapping TCs/pileup events. Cannot run with mlt_merge_overlapping_tcs.
 
void set_ignore_overlapping_tcs (bool value)
 Set "ignore_overlapping_tcs" attribute value. Option to ignore consecutive overlapping TCs/pileup events. Cannot run with mlt_merge_overlapping_tcs.
 
bool get_td_out_of_timeout () const
 Get "td_out_of_timeout" attribute value. Option to drop TD if TC comes out of timeout window.
 
void set_td_out_of_timeout (bool value)
 Set "td_out_of_timeout" attribute value. Option to drop TD if TC comes out of timeout window.
 
uint32_t get_buffer_timeout () const
 Get "buffer_timeout" attribute value. Timeout (buffer) to wait for new overlapping TCs before sending TD, in ms.
 
void set_buffer_timeout (uint32_t value)
 Set "buffer_timeout" attribute value. Timeout (buffer) to wait for new overlapping TCs before sending TD, in ms.
 
uint32_t get_td_readout_limit () const
 Get "td_readout_limit" attribute value. Maximum allowed time length (in ticks) for a readout window of a single TD.
 
void set_td_readout_limit (uint32_t value)
 Set "td_readout_limit" attribute value. Maximum allowed time length (in ticks) for a readout window of a single TD.
 
const std::vector< uint32_t > & get_ignore_tc () const
 Get "ignore_tc" attribute value. Optional list of TC types to be ignored in MLT.
 
void set_ignore_tc (const std::vector< uint32_t > &value)
 Set "ignore_tc" attribute value. Optional list of TC types to be ignored in MLT.
 
const std::vector< const dunedaq::appmodel::TriggerBitword * > & get_trigger_bitwords () const
 Get "trigger_bitwords" relationship value. Optional dictionary of bitwords to use when forming trigger decisions in MLT.
 
void set_trigger_bitwords (const std::vector< const dunedaq::appmodel::TriggerBitword * > &value)
 Set "trigger_bitwords" relationship value. Optional dictionary of bitwords to use when forming trigger decisions in MLT.
 
const std::vector< const dunedaq::appmodel::ROIGroupConf * > & get_roi_group_conf () const
 Get "roi_group_conf" relationship value. The configuration (table) for ROI readout (currently not used)
 
void set_roi_group_conf (const std::vector< const dunedaq::appmodel::ROIGroupConf * > &value)
 Set "roi_group_conf" relationship value. The configuration (table) for ROI readout (currently not used)
 
const std::vector< const dunedaq::appmodel::TCReadoutMap * > & get_tc_readout_map () const
 Get "tc_readout_map" relationship value. The readout windows assigned to TDs in MLT, based on TC type.
 
void set_tc_readout_map (const std::vector< const dunedaq::appmodel::TCReadoutMap * > &value)
 Set "tc_readout_map" relationship value. The readout windows assigned to TDs in MLT, based on TC type.
 
const std::vector< const dunedaq::appmodel::SourceIDConf * > & get_mandatory_links () const
 Get "mandatory_links" relationship value. Source Ids that will always be included in a trigger decision.
 
void set_mandatory_links (const std::vector< const dunedaq::appmodel::SourceIDConf * > &value)
 Set "mandatory_links" relationship value. Source Ids that will always be included in a trigger decision.
 
- Public Member Functions inherited from dunedaq::appmodel::DataProcessor
uint32_t get_queue_sizes () const
 Get "queue_sizes" attribute value.
 
void set_queue_sizes (uint32_t value)
 Set "queue_sizes" attribute value.
 
const std::string & get_thread_names_prefix () const
 Get "thread_names_prefix" attribute value.
 
void set_thread_names_prefix (const std::string &value)
 Set "thread_names_prefix" attribute value.
 
bool get_latency_monitoring () const
 Get "latency_monitoring" attribute value.
 
void set_latency_monitoring (bool value)
 Set "latency_monitoring" attribute value.
 
uint32_t get_queue_sizes () const
 Get "queue_sizes" attribute value.
 
void set_queue_sizes (uint32_t value)
 Set "queue_sizes" attribute value.
 
const std::string & get_thread_names_prefix () const
 Get "thread_names_prefix" attribute value.
 
void set_thread_names_prefix (const std::string &value)
 Set "thread_names_prefix" attribute value.
 
bool get_latency_monitoring () const
 Get "latency_monitoring" attribute value.
 
void set_latency_monitoring (bool value)
 Set "latency_monitoring" attribute value.
 
- 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_merge_overlapping_tcs_str () noexcept
 
static const std::string & __get_ignore_overlapping_tcs_str () noexcept
 
static const std::string & __get_td_out_of_timeout_str () noexcept
 
static const std::string & __get_buffer_timeout_str () noexcept
 
static const std::string & __get_td_readout_limit_str () noexcept
 
static const std::string & __get_ignore_tc_str () noexcept
 
static const std::string & __get_trigger_bitwords_str () noexcept
 
static const std::string & __get_roi_group_conf_str () noexcept
 
static const std::string & __get_tc_readout_map_str () noexcept
 
static const std::string & __get_mandatory_links_str () noexcept
 
static const std::string & __get_merge_overlapping_tcs_str () noexcept
 
static const std::string & __get_ignore_overlapping_tcs_str () noexcept
 
static const std::string & __get_td_out_of_timeout_str () noexcept
 
static const std::string & __get_buffer_timeout_str () noexcept
 
static const std::string & __get_td_readout_limit_str () noexcept
 
static const std::string & __get_ignore_tc_str () noexcept
 
static const std::string & __get_trigger_bitwords_str () noexcept
 
static const std::string & __get_roi_group_conf_str () noexcept
 
static const std::string & __get_tc_readout_map_str () noexcept
 
static const std::string & __get_mandatory_links_str () noexcept
 
- Static Public Member Functions inherited from dunedaq::appmodel::DataProcessor
static const std::string & __get_queue_sizes_str () noexcept
 
static const std::string & __get_thread_names_prefix_str () noexcept
 
static const std::string & __get_latency_monitoring_str () noexcept
 
static const std::string & __get_queue_sizes_str () noexcept
 
static const std::string & __get_thread_names_prefix_str () noexcept
 
static const std::string & __get_latency_monitoring_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_merge_overlapping_tcs = "merge_overlapping_tcs"
 
static const std::string s_ignore_overlapping_tcs = "ignore_overlapping_tcs"
 
static const std::string s_td_out_of_timeout = "td_out_of_timeout"
 
static const std::string s_buffer_timeout = "buffer_timeout"
 
static const std::string s_td_readout_limit = "td_readout_limit"
 
static const std::string s_ignore_tc = "ignore_tc"
 
static const std::string s_trigger_bitwords = "trigger_bitwords"
 
static const std::string s_roi_group_conf = "roi_group_conf"
 
static const std::string s_tc_readout_map = "tc_readout_map"
 
static const std::string s_mandatory_links = "mandatory_links"
 
- Static Public Attributes inherited from dunedaq::appmodel::DataProcessor
static const std::string & s_class_name
 
static const std::string s_queue_sizes = "queue_sizes"
 
static const std::string s_thread_names_prefix = "thread_names_prefix"
 
static const std::string s_latency_monitoring = "latency_monitoring"
 

Protected Member Functions

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

Private Attributes

bool m_merge_overlapping_tcs
 
bool m_ignore_overlapping_tcs
 
bool m_td_out_of_timeout
 
uint32_t m_buffer_timeout
 
uint32_t m_td_readout_limit
 
std::vector< uint32_t > m_ignore_tc
 
std::vector< const dunedaq::appmodel::TriggerBitword * > m_trigger_bitwords
 
std::vector< const dunedaq::appmodel::ROIGroupConf * > m_roi_group_conf
 
std::vector< const dunedaq::appmodel::TCReadoutMap * > m_tc_readout_map
 
std::vector< const dunedaq::appmodel::SourceIDConf * > m_mandatory_links
 

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

Post-processor for TCs generating the trigger decisions

Definition at line 39 of file TCDataProcessor.hpp.

Constructor & Destructor Documentation

◆ TCDataProcessor() [1/2]

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

Definition at line 34 of file TCDataProcessor.cpp.

34 :
35 dunedaq::conffwk::DalObject(db, o),
36 DataProcessor(db, o)
37
38 {
39 ;
40 }
dunedaq::appmodel::DataProcessor::DataProcessor
DataProcessor(conffwk::DalRegistry &db, const conffwk::ConfigObject &obj) noexcept
Definition DataProcessor.cpp:26
dunedaq::conffwk::DalObject
The base class for any generated DAL object.
Definition DalObject.hpp:45

◆ ~TCDataProcessor() [1/2]

dunedaq::appmodel::TCDataProcessor::~TCDataProcessor ( )
protectedvirtualnoexcept

Definition at line 105 of file TCDataProcessor.cpp.

106 {
107 }

◆ TCDataProcessor() [2/2]

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

◆ ~TCDataProcessor() [2/2]

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

Member Function Documentation

◆ __get_buffer_timeout_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_buffer_timeout_str ( )
inlinestaticnoexcept

Definition at line 116 of file TCDataProcessor.hpp.

116{ return s_buffer_timeout; }
dunedaq::appmodel::TCDataProcessor::s_buffer_timeout
static const std::string s_buffer_timeout
Definition TCDataProcessor.hpp:109

◆ __get_buffer_timeout_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_buffer_timeout_str ( )
inlinestaticnoexcept

Definition at line 116 of file TCDataProcessor.hpp.

116{ return s_buffer_timeout; }

◆ __get_ignore_overlapping_tcs_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_ignore_overlapping_tcs_str ( )
inlinestaticnoexcept

Definition at line 114 of file TCDataProcessor.hpp.

114{ return s_ignore_overlapping_tcs; }
dunedaq::appmodel::TCDataProcessor::s_ignore_overlapping_tcs
static const std::string s_ignore_overlapping_tcs
Definition TCDataProcessor.hpp:107

◆ __get_ignore_overlapping_tcs_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_ignore_overlapping_tcs_str ( )
inlinestaticnoexcept

Definition at line 114 of file TCDataProcessor.hpp.

114{ return s_ignore_overlapping_tcs; }

◆ __get_ignore_tc_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_ignore_tc_str ( )
inlinestaticnoexcept

Definition at line 118 of file TCDataProcessor.hpp.

118{ return s_ignore_tc; }
dunedaq::appmodel::TCDataProcessor::s_ignore_tc
static const std::string s_ignore_tc
Definition TCDataProcessor.hpp:111

◆ __get_ignore_tc_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_ignore_tc_str ( )
inlinestaticnoexcept

Definition at line 118 of file TCDataProcessor.hpp.

118{ return s_ignore_tc; }

◆ __get_mandatory_links_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_mandatory_links_str ( )
inlinestaticnoexcept

Definition at line 329 of file TCDataProcessor.hpp.

329{ return s_mandatory_links; }
dunedaq::appmodel::TCDataProcessor::s_mandatory_links
static const std::string s_mandatory_links
Definition TCDataProcessor.hpp:324

◆ __get_mandatory_links_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_mandatory_links_str ( )
inlinestaticnoexcept

Definition at line 329 of file TCDataProcessor.hpp.

329{ return s_mandatory_links; }

◆ __get_merge_overlapping_tcs_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_merge_overlapping_tcs_str ( )
inlinestaticnoexcept

Definition at line 113 of file TCDataProcessor.hpp.

113{ return s_merge_overlapping_tcs; }
dunedaq::appmodel::TCDataProcessor::s_merge_overlapping_tcs
static const std::string s_merge_overlapping_tcs
Definition TCDataProcessor.hpp:106

◆ __get_merge_overlapping_tcs_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_merge_overlapping_tcs_str ( )
inlinestaticnoexcept

Definition at line 113 of file TCDataProcessor.hpp.

113{ return s_merge_overlapping_tcs; }

◆ __get_roi_group_conf_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_roi_group_conf_str ( )
inlinestaticnoexcept

Definition at line 327 of file TCDataProcessor.hpp.

327{ return s_roi_group_conf; }
dunedaq::appmodel::TCDataProcessor::s_roi_group_conf
static const std::string s_roi_group_conf
Definition TCDataProcessor.hpp:322

◆ __get_roi_group_conf_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_roi_group_conf_str ( )
inlinestaticnoexcept

Definition at line 327 of file TCDataProcessor.hpp.

327{ return s_roi_group_conf; }

◆ __get_tc_readout_map_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_tc_readout_map_str ( )
inlinestaticnoexcept

Definition at line 328 of file TCDataProcessor.hpp.

328{ return s_tc_readout_map; }
dunedaq::appmodel::TCDataProcessor::s_tc_readout_map
static const std::string s_tc_readout_map
Definition TCDataProcessor.hpp:323

◆ __get_tc_readout_map_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_tc_readout_map_str ( )
inlinestaticnoexcept

Definition at line 328 of file TCDataProcessor.hpp.

328{ return s_tc_readout_map; }

◆ __get_td_out_of_timeout_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_td_out_of_timeout_str ( )
inlinestaticnoexcept

Definition at line 115 of file TCDataProcessor.hpp.

115{ return s_td_out_of_timeout; }
dunedaq::appmodel::TCDataProcessor::s_td_out_of_timeout
static const std::string s_td_out_of_timeout
Definition TCDataProcessor.hpp:108

◆ __get_td_out_of_timeout_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_td_out_of_timeout_str ( )
inlinestaticnoexcept

Definition at line 115 of file TCDataProcessor.hpp.

115{ return s_td_out_of_timeout; }

◆ __get_td_readout_limit_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_td_readout_limit_str ( )
inlinestaticnoexcept

Definition at line 117 of file TCDataProcessor.hpp.

117{ return s_td_readout_limit; }
dunedaq::appmodel::TCDataProcessor::s_td_readout_limit
static const std::string s_td_readout_limit
Definition TCDataProcessor.hpp:110

◆ __get_td_readout_limit_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_td_readout_limit_str ( )
inlinestaticnoexcept

Definition at line 117 of file TCDataProcessor.hpp.

117{ return s_td_readout_limit; }

◆ __get_trigger_bitwords_str() [1/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_trigger_bitwords_str ( )
inlinestaticnoexcept

Definition at line 326 of file TCDataProcessor.hpp.

326{ return s_trigger_bitwords; }
dunedaq::appmodel::TCDataProcessor::s_trigger_bitwords
static const std::string s_trigger_bitwords
Definition TCDataProcessor.hpp:321

◆ __get_trigger_bitwords_str() [2/2]

static const std::string & dunedaq::appmodel::TCDataProcessor::__get_trigger_bitwords_str ( )
inlinestaticnoexcept

Definition at line 326 of file TCDataProcessor.hpp.

326{ return s_trigger_bitwords; }

◆ get() [1/4]

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

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

Parameters are:

Parameters
namename of the relationship or algorithm
Returns
value of relationship or result of algorithm
Exceptions
std::exceptionif there is no relationship or algorithm with such name in this and base classes

Reimplemented from dunedaq::appmodel::DataProcessor.

Definition at line 109 of file TCDataProcessor.cpp.

110 {
111 std::vector<const dunedaq::conffwk::DalObject *> vec;
112
113 if (!get(name, vec, upcast_unregistered, true))
114 throw_get_ex(name, s_class_name, this);
115
116 return vec;
117 }
dunedaq::appmodel::TCDataProcessor::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 TCDataProcessor.cpp:109
dunedaq::appmodel::TCDataProcessor::s_class_name
static const std::string & s_class_name
Definition TCDataProcessor.hpp:56
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::TCDataProcessor::get ( const std::string & name,
bool upcast_unregistered = true ) const
virtual

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

Parameters are:

Parameters
namename of the relationship or algorithm
Returns
value of relationship or result of algorithm
Exceptions
std::exceptionif there is no relationship or algorithm with such name in this and base classes

Reimplemented from dunedaq::appmodel::DataProcessor.

◆ get() [3/4]

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

Definition at line 119 of file TCDataProcessor.cpp.

120 {
121 if (first_call)
122 {
123 std::lock_guard scoped_lock(m_mutex);
124
125 check();
126 check_init();
127
128 if (get_rel_objects(name, upcast_unregistered, vec))
129 return true;
130 }
131
132 if (DataProcessor::get(name, vec, upcast_unregistered, false)) return true;
133
134 if (first_call)
135 return get_algo_objects(name, vec);
136
137 return false;
138 }
dunedaq::appmodel::DataProcessor::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 DataProcessor.cpp:76
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::TCDataProcessor::get ( const std::string & name,
std::vector< const dunedaq::conffwk::DalObject * > & vec,
bool upcast_unregistered,
bool first_call ) const
protected

◆ get_buffer_timeout() [1/2]

uint32_t dunedaq::appmodel::TCDataProcessor::get_buffer_timeout ( ) const
inline

Get "buffer_timeout" attribute value. Timeout (buffer) to wait for new overlapping TCs before sending TD, in ms.

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

Definition at line 228 of file TCDataProcessor.hpp.

229 {
230 std::lock_guard scoped_lock(m_mutex);
231 check();
232 check_init();
233 return m_buffer_timeout;
234 }

◆ get_buffer_timeout() [2/2]

uint32_t dunedaq::appmodel::TCDataProcessor::get_buffer_timeout ( ) const
inline

Get "buffer_timeout" attribute value. Timeout (buffer) to wait for new overlapping TCs before sending TD, in ms.

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

Definition at line 228 of file TCDataProcessor.hpp.

229 {
230 std::lock_guard scoped_lock(m_mutex);
231 check();
232 check_init();
233 return m_buffer_timeout;
234 }

◆ get_ignore_overlapping_tcs() [1/2]

bool dunedaq::appmodel::TCDataProcessor::get_ignore_overlapping_tcs ( ) const
inline

Get "ignore_overlapping_tcs" attribute value. Option to ignore consecutive overlapping TCs/pileup events. Cannot run with mlt_merge_overlapping_tcs.

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

Definition at line 162 of file TCDataProcessor.hpp.

163 {
164 std::lock_guard scoped_lock(m_mutex);
165 check();
166 check_init();
167 return m_ignore_overlapping_tcs;
168 }

◆ get_ignore_overlapping_tcs() [2/2]

bool dunedaq::appmodel::TCDataProcessor::get_ignore_overlapping_tcs ( ) const
inline

Get "ignore_overlapping_tcs" attribute value. Option to ignore consecutive overlapping TCs/pileup events. Cannot run with mlt_merge_overlapping_tcs.

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

Definition at line 162 of file TCDataProcessor.hpp.

163 {
164 std::lock_guard scoped_lock(m_mutex);
165 check();
166 check_init();
167 return m_ignore_overlapping_tcs;
168 }

◆ get_ignore_tc() [1/2]

const std::vector< uint32_t > & dunedaq::appmodel::TCDataProcessor::get_ignore_tc ( ) const
inline

Get "ignore_tc" attribute value. Optional list of TC types to be ignored in MLT.

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

Definition at line 294 of file TCDataProcessor.hpp.

295 {
296 std::lock_guard scoped_lock(m_mutex);
297 check();
298 check_init();
299 return m_ignore_tc;
300 }
dunedaq::appmodel::TCDataProcessor::m_ignore_tc
std::vector< uint32_t > m_ignore_tc
Definition TCDataProcessor.hpp:95

◆ get_ignore_tc() [2/2]

const std::vector< uint32_t > & dunedaq::appmodel::TCDataProcessor::get_ignore_tc ( ) const
inline

Get "ignore_tc" attribute value. Optional list of TC types to be ignored in MLT.

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

Definition at line 294 of file TCDataProcessor.hpp.

295 {
296 std::lock_guard scoped_lock(m_mutex);
297 check();
298 check_init();
299 return m_ignore_tc;
300 }

◆ get_mandatory_links() [1/2]

const std::vector< const dunedaq::appmodel::SourceIDConf * > & dunedaq::appmodel::TCDataProcessor::get_mandatory_links ( ) const
inline

Get "mandatory_links" relationship value. Source Ids that will always be included in a trigger decision.

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

Definition at line 421 of file TCDataProcessor.hpp.

422 {
423 std::lock_guard scoped_lock(m_mutex);
424 check();
425 check_init();
426 return m_mandatory_links;
427 }
dunedaq::appmodel::TCDataProcessor::m_mandatory_links
std::vector< const dunedaq::appmodel::SourceIDConf * > m_mandatory_links
Definition TCDataProcessor.hpp:99

◆ get_mandatory_links() [2/2]

const std::vector< const dunedaq::appmodel::SourceIDConf * > & dunedaq::appmodel::TCDataProcessor::get_mandatory_links ( ) const
inline

Get "mandatory_links" relationship value. Source Ids that will always be included in a trigger decision.

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

Definition at line 421 of file TCDataProcessor.hpp.

422 {
423 std::lock_guard scoped_lock(m_mutex);
424 check();
425 check_init();
426 return m_mandatory_links;
427 }

◆ get_merge_overlapping_tcs() [1/2]

bool dunedaq::appmodel::TCDataProcessor::get_merge_overlapping_tcs ( ) const
inline

Get "merge_overlapping_tcs" attribute value. Option to turn off merging of overlapping TCs when forming TDs in MLT.

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

Definition at line 129 of file TCDataProcessor.hpp.

130 {
131 std::lock_guard scoped_lock(m_mutex);
132 check();
133 check_init();
134 return m_merge_overlapping_tcs;
135 }

◆ get_merge_overlapping_tcs() [2/2]

bool dunedaq::appmodel::TCDataProcessor::get_merge_overlapping_tcs ( ) const
inline

Get "merge_overlapping_tcs" attribute value. Option to turn off merging of overlapping TCs when forming TDs in MLT.

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

Definition at line 129 of file TCDataProcessor.hpp.

130 {
131 std::lock_guard scoped_lock(m_mutex);
132 check();
133 check_init();
134 return m_merge_overlapping_tcs;
135 }

◆ get_roi_group_conf() [1/2]

const std::vector< const dunedaq::appmodel::ROIGroupConf * > & dunedaq::appmodel::TCDataProcessor::get_roi_group_conf ( ) const
inline

Get "roi_group_conf" relationship value. The configuration (table) for ROI readout (currently not used)

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

Definition at line 367 of file TCDataProcessor.hpp.

368 {
369 std::lock_guard scoped_lock(m_mutex);
370 check();
371 check_init();
372 return m_roi_group_conf;
373 }
dunedaq::appmodel::TCDataProcessor::m_roi_group_conf
std::vector< const dunedaq::appmodel::ROIGroupConf * > m_roi_group_conf
Definition TCDataProcessor.hpp:97

◆ get_roi_group_conf() [2/2]

const std::vector< const dunedaq::appmodel::ROIGroupConf * > & dunedaq::appmodel::TCDataProcessor::get_roi_group_conf ( ) const
inline

Get "roi_group_conf" relationship value. The configuration (table) for ROI readout (currently not used)

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

Definition at line 367 of file TCDataProcessor.hpp.

368 {
369 std::lock_guard scoped_lock(m_mutex);
370 check();
371 check_init();
372 return m_roi_group_conf;
373 }

◆ get_tc_readout_map() [1/2]

const std::vector< const dunedaq::appmodel::TCReadoutMap * > & dunedaq::appmodel::TCDataProcessor::get_tc_readout_map ( ) const
inline

Get "tc_readout_map" relationship value. The readout windows assigned to TDs in MLT, based on TC type.

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

Definition at line 394 of file TCDataProcessor.hpp.

395 {
396 std::lock_guard scoped_lock(m_mutex);
397 check();
398 check_init();
399 return m_tc_readout_map;
400 }
dunedaq::appmodel::TCDataProcessor::m_tc_readout_map
std::vector< const dunedaq::appmodel::TCReadoutMap * > m_tc_readout_map
Definition TCDataProcessor.hpp:98

◆ get_tc_readout_map() [2/2]

const std::vector< const dunedaq::appmodel::TCReadoutMap * > & dunedaq::appmodel::TCDataProcessor::get_tc_readout_map ( ) const
inline

Get "tc_readout_map" relationship value. The readout windows assigned to TDs in MLT, based on TC type.

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

Definition at line 394 of file TCDataProcessor.hpp.

395 {
396 std::lock_guard scoped_lock(m_mutex);
397 check();
398 check_init();
399 return m_tc_readout_map;
400 }

◆ get_td_out_of_timeout() [1/2]

bool dunedaq::appmodel::TCDataProcessor::get_td_out_of_timeout ( ) const
inline

Get "td_out_of_timeout" attribute value. Option to drop TD if TC comes out of timeout window.

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

Definition at line 195 of file TCDataProcessor.hpp.

196 {
197 std::lock_guard scoped_lock(m_mutex);
198 check();
199 check_init();
200 return m_td_out_of_timeout;
201 }

◆ get_td_out_of_timeout() [2/2]

bool dunedaq::appmodel::TCDataProcessor::get_td_out_of_timeout ( ) const
inline

Get "td_out_of_timeout" attribute value. Option to drop TD if TC comes out of timeout window.

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

Definition at line 195 of file TCDataProcessor.hpp.

196 {
197 std::lock_guard scoped_lock(m_mutex);
198 check();
199 check_init();
200 return m_td_out_of_timeout;
201 }

◆ get_td_readout_limit() [1/2]

uint32_t dunedaq::appmodel::TCDataProcessor::get_td_readout_limit ( ) const
inline

Get "td_readout_limit" attribute value. Maximum allowed time length (in ticks) for a readout window of a single TD.

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

Definition at line 261 of file TCDataProcessor.hpp.

262 {
263 std::lock_guard scoped_lock(m_mutex);
264 check();
265 check_init();
266 return m_td_readout_limit;
267 }

◆ get_td_readout_limit() [2/2]

uint32_t dunedaq::appmodel::TCDataProcessor::get_td_readout_limit ( ) const
inline

Get "td_readout_limit" attribute value. Maximum allowed time length (in ticks) for a readout window of a single TD.

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

Definition at line 261 of file TCDataProcessor.hpp.

262 {
263 std::lock_guard scoped_lock(m_mutex);
264 check();
265 check_init();
266 return m_td_readout_limit;
267 }

◆ get_trigger_bitwords() [1/2]

const std::vector< const dunedaq::appmodel::TriggerBitword * > & dunedaq::appmodel::TCDataProcessor::get_trigger_bitwords ( ) const
inline

Get "trigger_bitwords" relationship value. Optional dictionary of bitwords to use when forming trigger decisions in MLT.

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

Definition at line 340 of file TCDataProcessor.hpp.

341 {
342 std::lock_guard scoped_lock(m_mutex);
343 check();
344 check_init();
345 return m_trigger_bitwords;
346 }
dunedaq::appmodel::TCDataProcessor::m_trigger_bitwords
std::vector< const dunedaq::appmodel::TriggerBitword * > m_trigger_bitwords
Definition TCDataProcessor.hpp:96

◆ get_trigger_bitwords() [2/2]

const std::vector< const dunedaq::appmodel::TriggerBitword * > & dunedaq::appmodel::TCDataProcessor::get_trigger_bitwords ( ) const
inline

Get "trigger_bitwords" relationship value. Optional dictionary of bitwords to use when forming trigger decisions in MLT.

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

Definition at line 340 of file TCDataProcessor.hpp.

341 {
342 std::lock_guard scoped_lock(m_mutex);
343 check();
344 check_init();
345 return m_trigger_bitwords;
346 }

◆ init() [1/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Reimplemented from dunedaq::appmodel::DataProcessor.

Definition at line 82 of file TCDataProcessor.cpp.

83 {
84 DataProcessor::init(init_children);
85
86 TLOG_DEBUG(5) << "read object " << this << " (class " << s_class_name << ')';
87
88 try {
89 p_obj.get(s_merge_overlapping_tcs, m_merge_overlapping_tcs);
90 p_obj.get(s_ignore_overlapping_tcs, m_ignore_overlapping_tcs);
91 p_obj.get(s_td_out_of_timeout, m_td_out_of_timeout);
92 p_obj.get(s_buffer_timeout, m_buffer_timeout);
93 p_obj.get(s_td_readout_limit, m_td_readout_limit);
94 p_obj.get(s_ignore_tc, m_ignore_tc);
95 p_registry._ref<dunedaq::appmodel::TriggerBitword>(p_obj, s_trigger_bitwords, m_trigger_bitwords, init_children);
96 p_registry._ref<dunedaq::appmodel::ROIGroupConf>(p_obj, s_roi_group_conf, m_roi_group_conf, init_children);
97 p_registry._ref<dunedaq::appmodel::TCReadoutMap>(p_obj, s_tc_readout_map, m_tc_readout_map, init_children);
98 p_registry._ref<dunedaq::appmodel::SourceIDConf>(p_obj, s_mandatory_links, m_mandatory_links, init_children);
99 }
100 catch (dunedaq::conffwk::Exception & ex) {
101 throw_init_ex(ex);
102 }
103 }
dunedaq::appmodel::DataProcessor::init
virtual void init(bool init_children)
Definition DataProcessor.cpp:56
dunedaq::conffwk::ConfigObject::get
void get(const std::string &name, T &value)
Get value of object's attribute or relationship.
Definition ConfigObject.hpp:278
dunedaq::conffwk::DalObject::throw_init_ex
void throw_init_ex(dunedaq::conffwk::Exception &ex)
throw object initialisation exception (i.e.
Definition DalObject.cpp:74
dunedaq::conffwk::DalObject::p_registry
DalRegistry & p_registry
Configuration object.
Definition DalObject.hpp:114
dunedaq::conffwk::DalObject::p_obj
ConfigObject p_obj
Config object used by given template object.
Definition DalObject.hpp:117
dunedaq::conffwk::DalRegistry::_ref
const T * _ref(ConfigObject &obj, const std::string &name, bool read_children)
Get signle value of object's relation and instantiate result with it (multi-thread safe).
Definition DalRegistry.hxx:164
TLOG_DEBUG
#define TLOG_DEBUG(lvl,...)
Definition Logging.hpp:112

◆ init() [2/2]

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

Initialize object (method generated by genconffwk)

Parameters
init_childrenif true, initialize referenced objects

Reimplemented from dunedaq::appmodel::DataProcessor.

◆ print() [1/2]

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

Print details of the TCDataProcessor object.

Parameters are:

Parameters
offsetnumber of spaces to shift object right (useful to print nested objects)
print_headerif false, do not print object header (to print attributes of base classes)
soutput stream

Reimplemented from dunedaq::appmodel::DataProcessor.

Definition at line 43 of file TCDataProcessor.cpp.

44 {
45 check_init();
46
47 try {
48 const std::string str(indent+2, ' ');
49
50 if (print_header)
51 p_hdr(s, indent, s_class_name, "dunedaq::appmodel");
52
53
54 // print direct super-classes
55
56 dunedaq::appmodel::DataProcessor::print(indent, false, s);
57
58
59 // print direct attributes
60
61 dunedaq::conffwk::p_sv_attr(s, str, s_merge_overlapping_tcs, m_merge_overlapping_tcs);
62 dunedaq::conffwk::p_sv_attr(s, str, s_ignore_overlapping_tcs, m_ignore_overlapping_tcs);
63 dunedaq::conffwk::p_sv_attr(s, str, s_td_out_of_timeout, m_td_out_of_timeout);
64 dunedaq::conffwk::p_sv_attr(s, str, s_buffer_timeout, m_buffer_timeout);
65 dunedaq::conffwk::p_sv_attr(s, str, s_td_readout_limit, m_td_readout_limit);
66 dunedaq::conffwk::p_mv_attr(s, str, s_ignore_tc, m_ignore_tc);
67
68
69 // print direct relationships
70
71 dunedaq::conffwk::p_mv_rel(s, str, s_trigger_bitwords, m_trigger_bitwords);
72 dunedaq::conffwk::p_mv_rel(s, str, s_roi_group_conf, m_roi_group_conf);
73 dunedaq::conffwk::p_mv_rel(s, str, s_tc_readout_map, m_tc_readout_map);
74 dunedaq::conffwk::p_mv_rel(s, str, s_mandatory_links, m_mandatory_links);
75 }
76 catch (dunedaq::conffwk::Exception & ex) {
77 dunedaq::conffwk::DalObject::p_error(s, ex);
78 }
79 }
dunedaq::appmodel::DataProcessor::print
virtual void print(unsigned int offset, bool print_header, std::ostream &s) const
Print details of the DataProcessor object.
Definition DataProcessor.cpp:33
dunedaq::conffwk::DalObject::p_hdr
void p_hdr(std::ostream &s, unsigned int indent, const std::string &cl, const char *nm=nullptr) const
print object headers
Definition DalObject.cpp:65
dunedaq::conffwk::DalObject::p_error
static void p_error(std::ostream &s, dunedaq::conffwk::Exception &ex)
print error text
Definition DalObject.cpp:59
dunedaq::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_mv_attr
void p_mv_attr(std::ostream &s, const std::string &str, const std::string &name, const T &val) noexcept
print multi-value attribute
Definition DalObjectPrint.hpp:73
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::TCDataProcessor::print ( unsigned int offset,
bool print_header,
std::ostream & s ) const
virtual

Print details of the TCDataProcessor object.

Parameters are:

Parameters
offsetnumber of spaces to shift object right (useful to print nested objects)
print_headerif false, do not print object header (to print attributes of base classes)
soutput stream

Reimplemented from dunedaq::appmodel::DataProcessor.

◆ set_buffer_timeout() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_buffer_timeout ( uint32_t value)
inline

Set "buffer_timeout" attribute value. Timeout (buffer) to wait for new overlapping TCs before sending TD, in ms.

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

Definition at line 244 of file TCDataProcessor.hpp.

245 {
246 std::lock_guard scoped_lock(m_mutex);
247 check();
248 clear();
249 p_obj.set_by_val(s_buffer_timeout, value);
250 }
dunedaq::conffwk::ConfigObject::set_by_val
void set_by_val(const std::string &name, T value)
Set attribute value.
Definition ConfigObject.hpp:391

◆ set_buffer_timeout() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_buffer_timeout ( uint32_t value)
inline

Set "buffer_timeout" attribute value. Timeout (buffer) to wait for new overlapping TCs before sending TD, in ms.

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

Definition at line 244 of file TCDataProcessor.hpp.

245 {
246 std::lock_guard scoped_lock(m_mutex);
247 check();
248 clear();
249 p_obj.set_by_val(s_buffer_timeout, value);
250 }

◆ set_ignore_overlapping_tcs() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_ignore_overlapping_tcs ( bool value)
inline

Set "ignore_overlapping_tcs" attribute value. Option to ignore consecutive overlapping TCs/pileup events. Cannot run with mlt_merge_overlapping_tcs.

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

Definition at line 178 of file TCDataProcessor.hpp.

179 {
180 std::lock_guard scoped_lock(m_mutex);
181 check();
182 clear();
183 p_obj.set_by_val(s_ignore_overlapping_tcs, value);
184 }

◆ set_ignore_overlapping_tcs() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_ignore_overlapping_tcs ( bool value)
inline

Set "ignore_overlapping_tcs" attribute value. Option to ignore consecutive overlapping TCs/pileup events. Cannot run with mlt_merge_overlapping_tcs.

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

Definition at line 178 of file TCDataProcessor.hpp.

179 {
180 std::lock_guard scoped_lock(m_mutex);
181 check();
182 clear();
183 p_obj.set_by_val(s_ignore_overlapping_tcs, value);
184 }

◆ set_ignore_tc() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_ignore_tc ( const std::vector< uint32_t > & value)
inline

Set "ignore_tc" attribute value. Optional list of TC types to be ignored in MLT.

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

Definition at line 310 of file TCDataProcessor.hpp.

311 {
312 std::lock_guard scoped_lock(m_mutex);
313 check();
314 clear();
315 p_obj.set_by_val(s_ignore_tc, value);
316 }

◆ set_ignore_tc() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_ignore_tc ( const std::vector< uint32_t > & value)
inline

Set "ignore_tc" attribute value. Optional list of TC types to be ignored in MLT.

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

Definition at line 310 of file TCDataProcessor.hpp.

311 {
312 std::lock_guard scoped_lock(m_mutex);
313 check();
314 clear();
315 p_obj.set_by_val(s_ignore_tc, value);
316 }

◆ set_mandatory_links() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_mandatory_links ( const std::vector< const dunedaq::appmodel::SourceIDConf * > & value)

Set "mandatory_links" relationship value. Source Ids that will always be included in a trigger decision.

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

Definition at line 155 of file TCDataProcessor.cpp.

156 {
157 _set_objects(s_mandatory_links, value);
158 }
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_mandatory_links() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_mandatory_links ( const std::vector< const dunedaq::appmodel::SourceIDConf * > & value)

Set "mandatory_links" relationship value. Source Ids that will always be included in a trigger decision.

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

◆ set_merge_overlapping_tcs() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_merge_overlapping_tcs ( bool value)
inline

Set "merge_overlapping_tcs" attribute value. Option to turn off merging of overlapping TCs when forming TDs in MLT.

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

Definition at line 145 of file TCDataProcessor.hpp.

146 {
147 std::lock_guard scoped_lock(m_mutex);
148 check();
149 clear();
150 p_obj.set_by_val(s_merge_overlapping_tcs, value);
151 }

◆ set_merge_overlapping_tcs() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_merge_overlapping_tcs ( bool value)
inline

Set "merge_overlapping_tcs" attribute value. Option to turn off merging of overlapping TCs when forming TDs in MLT.

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

Definition at line 145 of file TCDataProcessor.hpp.

146 {
147 std::lock_guard scoped_lock(m_mutex);
148 check();
149 clear();
150 p_obj.set_by_val(s_merge_overlapping_tcs, value);
151 }

◆ set_roi_group_conf() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_roi_group_conf ( const std::vector< const dunedaq::appmodel::ROIGroupConf * > & value)

Set "roi_group_conf" relationship value. The configuration (table) for ROI readout (currently not used)

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

Definition at line 145 of file TCDataProcessor.cpp.

146 {
147 _set_objects(s_roi_group_conf, value);
148 }

◆ set_roi_group_conf() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_roi_group_conf ( const std::vector< const dunedaq::appmodel::ROIGroupConf * > & value)

Set "roi_group_conf" relationship value. The configuration (table) for ROI readout (currently not used)

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

◆ set_tc_readout_map() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_tc_readout_map ( const std::vector< const dunedaq::appmodel::TCReadoutMap * > & value)

Set "tc_readout_map" relationship value. The readout windows assigned to TDs in MLT, based on TC type.

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

Definition at line 150 of file TCDataProcessor.cpp.

151 {
152 _set_objects(s_tc_readout_map, value);
153 }

◆ set_tc_readout_map() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_tc_readout_map ( const std::vector< const dunedaq::appmodel::TCReadoutMap * > & value)

Set "tc_readout_map" relationship value. The readout windows assigned to TDs in MLT, based on TC type.

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

◆ set_td_out_of_timeout() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_td_out_of_timeout ( bool value)
inline

Set "td_out_of_timeout" attribute value. Option to drop TD if TC comes out of timeout window.

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

Definition at line 211 of file TCDataProcessor.hpp.

212 {
213 std::lock_guard scoped_lock(m_mutex);
214 check();
215 clear();
216 p_obj.set_by_val(s_td_out_of_timeout, value);
217 }

◆ set_td_out_of_timeout() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_td_out_of_timeout ( bool value)
inline

Set "td_out_of_timeout" attribute value. Option to drop TD if TC comes out of timeout window.

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

Definition at line 211 of file TCDataProcessor.hpp.

212 {
213 std::lock_guard scoped_lock(m_mutex);
214 check();
215 clear();
216 p_obj.set_by_val(s_td_out_of_timeout, value);
217 }

◆ set_td_readout_limit() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_td_readout_limit ( uint32_t value)
inline

Set "td_readout_limit" attribute value. Maximum allowed time length (in ticks) for a readout window of a single TD.

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

Definition at line 277 of file TCDataProcessor.hpp.

278 {
279 std::lock_guard scoped_lock(m_mutex);
280 check();
281 clear();
282 p_obj.set_by_val(s_td_readout_limit, value);
283 }

◆ set_td_readout_limit() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_td_readout_limit ( uint32_t value)
inline

Set "td_readout_limit" attribute value. Maximum allowed time length (in ticks) for a readout window of a single TD.

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

Definition at line 277 of file TCDataProcessor.hpp.

278 {
279 std::lock_guard scoped_lock(m_mutex);
280 check();
281 clear();
282 p_obj.set_by_val(s_td_readout_limit, value);
283 }

◆ set_trigger_bitwords() [1/2]

void dunedaq::appmodel::TCDataProcessor::set_trigger_bitwords ( const std::vector< const dunedaq::appmodel::TriggerBitword * > & value)

Set "trigger_bitwords" relationship value. Optional dictionary of bitwords to use when forming trigger decisions in MLT.

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

Definition at line 140 of file TCDataProcessor.cpp.

141 {
142 _set_objects(s_trigger_bitwords, value);
143 }

◆ set_trigger_bitwords() [2/2]

void dunedaq::appmodel::TCDataProcessor::set_trigger_bitwords ( const std::vector< const dunedaq::appmodel::TriggerBitword * > & value)

Set "trigger_bitwords" relationship value. Optional dictionary of bitwords to use when forming trigger decisions in MLT.

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

Friends And Related Symbol Documentation

◆ conffwk::Configuration

conffwk::Configuration
friend

Definition at line 41 of file TCDataProcessor.hpp.

◆ conffwk::DalFactory

conffwk::DalFactory
friend

Definition at line 43 of file TCDataProcessor.hpp.

◆ conffwk::DalObject

conffwk::DalObject
friend

Definition at line 42 of file TCDataProcessor.hpp.

◆ conffwk::DalRegistry

conffwk::DalRegistry
friend

Definition at line 44 of file TCDataProcessor.hpp.

Member Data Documentation

◆ m_buffer_timeout

uint32_t dunedaq::appmodel::TCDataProcessor::m_buffer_timeout
private

Definition at line 93 of file TCDataProcessor.hpp.

◆ m_ignore_overlapping_tcs

bool dunedaq::appmodel::TCDataProcessor::m_ignore_overlapping_tcs
private

Definition at line 91 of file TCDataProcessor.hpp.

◆ m_ignore_tc

std::vector< uint32_t > dunedaq::appmodel::TCDataProcessor::m_ignore_tc
private

Definition at line 95 of file TCDataProcessor.hpp.

◆ m_mandatory_links

std::vector< const dunedaq::appmodel::SourceIDConf * > dunedaq::appmodel::TCDataProcessor::m_mandatory_links
private

Definition at line 99 of file TCDataProcessor.hpp.

◆ m_merge_overlapping_tcs

bool dunedaq::appmodel::TCDataProcessor::m_merge_overlapping_tcs
private

Definition at line 90 of file TCDataProcessor.hpp.

◆ m_roi_group_conf

std::vector< const dunedaq::appmodel::ROIGroupConf * > dunedaq::appmodel::TCDataProcessor::m_roi_group_conf
private

Definition at line 97 of file TCDataProcessor.hpp.

◆ m_tc_readout_map

std::vector< const dunedaq::appmodel::TCReadoutMap * > dunedaq::appmodel::TCDataProcessor::m_tc_readout_map
private

Definition at line 98 of file TCDataProcessor.hpp.

◆ m_td_out_of_timeout

bool dunedaq::appmodel::TCDataProcessor::m_td_out_of_timeout
private

Definition at line 92 of file TCDataProcessor.hpp.

◆ m_td_readout_limit

uint32_t dunedaq::appmodel::TCDataProcessor::m_td_readout_limit
private

Definition at line 94 of file TCDataProcessor.hpp.

◆ m_trigger_bitwords

std::vector< const dunedaq::appmodel::TriggerBitword * > dunedaq::appmodel::TCDataProcessor::m_trigger_bitwords
private

Definition at line 96 of file TCDataProcessor.hpp.

◆ s_buffer_timeout

static const std::string dunedaq::appmodel::TCDataProcessor::s_buffer_timeout = "buffer_timeout"
inlinestatic

Definition at line 109 of file TCDataProcessor.hpp.

◆ s_class_name

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

The name of the configuration class.

Definition at line 56 of file TCDataProcessor.hpp.

◆ s_ignore_overlapping_tcs

static const std::string dunedaq::appmodel::TCDataProcessor::s_ignore_overlapping_tcs = "ignore_overlapping_tcs"
inlinestatic

Definition at line 107 of file TCDataProcessor.hpp.

◆ s_ignore_tc

static const std::string dunedaq::appmodel::TCDataProcessor::s_ignore_tc = "ignore_tc"
inlinestatic

Definition at line 111 of file TCDataProcessor.hpp.

◆ s_mandatory_links

static const std::string dunedaq::appmodel::TCDataProcessor::s_mandatory_links = "mandatory_links"
inlinestatic

Definition at line 324 of file TCDataProcessor.hpp.

◆ s_merge_overlapping_tcs

static const std::string dunedaq::appmodel::TCDataProcessor::s_merge_overlapping_tcs = "merge_overlapping_tcs"
inlinestatic

Definition at line 106 of file TCDataProcessor.hpp.

◆ s_roi_group_conf

static const std::string dunedaq::appmodel::TCDataProcessor::s_roi_group_conf = "roi_group_conf"
inlinestatic

Definition at line 322 of file TCDataProcessor.hpp.

◆ s_tc_readout_map

static const std::string dunedaq::appmodel::TCDataProcessor::s_tc_readout_map = "tc_readout_map"
inlinestatic

Definition at line 323 of file TCDataProcessor.hpp.

◆ s_td_out_of_timeout

static const std::string dunedaq::appmodel::TCDataProcessor::s_td_out_of_timeout = "td_out_of_timeout"
inlinestatic

Definition at line 108 of file TCDataProcessor.hpp.

◆ s_td_readout_limit

static const std::string dunedaq::appmodel::TCDataProcessor::s_td_readout_limit = "td_readout_limit"
inlinestatic

Definition at line 110 of file TCDataProcessor.hpp.

◆ s_trigger_bitwords

static const std::string dunedaq::appmodel::TCDataProcessor::s_trigger_bitwords = "trigger_bitwords"
inlinestatic

Definition at line 321 of file TCDataProcessor.hpp.

The documentation for this class was generated from the following files:
Generated on Thu Dec 25 2025 for DUNE-DAQ by doxygen 1.12.0