| add_postprocess_task(Task &&task) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | |
| add_preprocess_task(Task &&task) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | |
| add_requests_to_decision(dfmessages::TriggerDecision &decision, std::vector< dfmessages::ComponentRequest > requests) | dunedaq::trigger::TCProcessor | private |
| add_tc(const triggeralgs::TriggerCandidate tc) | dunedaq::trigger::TCProcessor | private |
| add_tc_ignored(const triggeralgs::TriggerCandidate tc) | dunedaq::trigger::TCProcessor | private |
| call_tc_decision(const PendingTD &pending_td) | dunedaq::trigger::TCProcessor | private |
| check_overlap(const triggeralgs::TriggerCandidate &tc, const PendingTD &pending_td) | dunedaq::trigger::TCProcessor | private |
| check_td_readout_length(const PendingTD &) | dunedaq::trigger::TCProcessor | private |
| check_trigger_bitwords(const TDBitset &td_bitword) const | dunedaq::trigger::TCProcessor | private |
| check_trigger_type_ignore(unsigned int tc_type) | dunedaq::trigger::TCProcessor | private |
| clear_td_vectors() | dunedaq::trigger::TCProcessor | private |
| collect() noexcept | dunedaq::opmonlib::MonitorableObject | private |
| conf(const appmodel::DataHandlerModule *conf) override | dunedaq::trigger::TCProcessor | virtual |
| const_metric_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| const_time_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| consttcptr typedef | dunedaq::trigger::TCProcessor | |
| create_all_decision_requests(std::vector< daqdataformats::SourceID > links, triggeralgs::timestamp_t start, triggeralgs::timestamp_t end) | dunedaq::trigger::TCProcessor | private |
| create_decision(const PendingTD &pending_td) | dunedaq::trigger::TCProcessor | private |
| create_request_for_link(daqdataformats::SourceID link, triggeralgs::timestamp_t start, triggeralgs::timestamp_t end) | dunedaq::trigger::TCProcessor | private |
| ElementId typedef | dunedaq::opmonlib::MonitorableObject | |
| facility_ptr_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| generate_opmon_data() override | dunedaq::trigger::TCProcessor | virtual |
| get_earliest_tc_index(const PendingTD &pending_td) | dunedaq::trigger::TCProcessor | private |
| get_last_daq_time() override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | inlinevirtual |
| get_opmon_id() const noexcept | dunedaq::opmonlib::MonitorableObject | inline |
| get_opmon_level() const noexcept | dunedaq::opmonlib::MonitorableObject | inline |
| get_random_num_float(float limit) | dunedaq::trigger::TCProcessor | private |
| get_random_num_int() | dunedaq::trigger::TCProcessor | private |
| get_ready_tds(std::vector< PendingTD > &pending_tds) | dunedaq::trigger::TCProcessor | private |
| get_TD_bitword(const PendingTD &ready_td) const | dunedaq::trigger::TCProcessor | private |
| inherit_parent_properties(const MonitorableObject &parent) | dunedaq::opmonlib::MonitorableObject | private |
| inherited typedef | dunedaq::trigger::TCProcessor | |
| invoke_all_preprocess_functions(TCWrapper *item) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | |
| invoke_postprocess_schedule_timeout_policy(std::uint64_t accumilated_timeout_ticks) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | inlinevirtual |
| launch_all_preprocess_functions(TCWrapper *item) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | |
| m_buffer_timeout | dunedaq::trigger::TCProcessor | private |
| m_cpu_us_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
| m_cv | dunedaq::trigger::TCProcessor | private |
| m_earliest_tc_index | dunedaq::trigger::TCProcessor | private |
| m_error_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
| m_error_registry | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_facility | dunedaq::opmonlib::MonitorableObject | private |
| m_group_links | dunedaq::trigger::TCProcessor | private |
| m_group_links_data | dunedaq::trigger::TCProcessor | private |
| m_ignore_tc_pileup | dunedaq::trigger::TCProcessor | private |
| m_ignored_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
| m_ignored_tc_types | dunedaq::trigger::TCProcessor | private |
| m_ignoring_tc_types | dunedaq::trigger::TCProcessor | private |
| m_items_to_postprocess_queues | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_last_processed_daq_ts | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_last_trigger_number | dunedaq::trigger::TCProcessor | private |
| m_latency_in | dunedaq::trigger::TCProcessor | private |
| m_latency_instance | dunedaq::trigger::TCProcessor | private |
| m_latency_monitoring | dunedaq::trigger::TCProcessor | private |
| m_latency_out | dunedaq::trigger::TCProcessor | private |
| m_mandatory_links | dunedaq::trigger::TCProcessor | private |
| m_node_mutex | dunedaq::opmonlib::MonitorableObject | private |
| m_nodes | dunedaq::opmonlib::MonitorableObject | private |
| m_opmon_level | dunedaq::opmonlib::MonitorableObject | private |
| m_opmon_name | dunedaq::opmonlib::MonitorableObject | private |
| m_parent_id | dunedaq::opmonlib::MonitorableObject | private |
| m_pending_tds | dunedaq::trigger::TCProcessor | private |
| m_post_process_functions | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_post_process_threads | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_post_processing_enabled | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_postprocess_queue_sizes | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_preprocess_functions | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_published_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
| m_readout_window_map | dunedaq::trigger::TCProcessor | private |
| m_readout_window_map_data | dunedaq::trigger::TCProcessor | private |
| m_repeat_trigger_count | dunedaq::trigger::TCProcessor | private |
| m_roi_conf | dunedaq::trigger::TCProcessor | private |
| m_roi_conf_data | dunedaq::trigger::TCProcessor | private |
| m_roi_conf_ids | dunedaq::trigger::TCProcessor | private |
| m_roi_conf_probs | dunedaq::trigger::TCProcessor | private |
| m_roi_conf_probs_c | dunedaq::trigger::TCProcessor | private |
| m_run_marker | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_run_number | dunedaq::trigger::TCProcessor | private |
| m_running_flag | dunedaq::trigger::TCProcessor | private |
| m_send_timed_out_tds | dunedaq::trigger::TCProcessor | private |
| m_send_trigger_decisions_thread | dunedaq::trigger::TCProcessor | private |
| m_sourceid | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| m_tc_ignored_count | dunedaq::trigger::TCProcessor | private |
| m_tc_merging | dunedaq::trigger::TCProcessor | private |
| m_tc_received_count | dunedaq::trigger::TCProcessor | private |
| m_td_readout_limit | dunedaq::trigger::TCProcessor | private |
| m_td_sink | dunedaq::trigger::TCProcessor | private |
| m_td_vector_mutex | dunedaq::trigger::TCProcessor | private |
| m_tds_cleared_count | dunedaq::trigger::TCProcessor | private |
| m_tds_cleared_tc_count | dunedaq::trigger::TCProcessor | private |
| m_tds_created_count | dunedaq::trigger::TCProcessor | private |
| m_tds_created_tc_count | dunedaq::trigger::TCProcessor | private |
| m_tds_dropped_count | dunedaq::trigger::TCProcessor | private |
| m_tds_dropped_tc_count | dunedaq::trigger::TCProcessor | private |
| m_tds_failed_bitword_count | dunedaq::trigger::TCProcessor | private |
| m_tds_failed_bitword_tc_count | dunedaq::trigger::TCProcessor | private |
| m_tds_sent_count | dunedaq::trigger::TCProcessor | private |
| m_tds_sent_tc_count | dunedaq::trigger::TCProcessor | private |
| m_total_group_links | dunedaq::trigger::TCProcessor | private |
| m_trigger_bitwords | dunedaq::trigger::TCProcessor | private |
| m_trigger_type_shifted | dunedaq::trigger::TCProcessor | private |
| m_use_bitwords | dunedaq::trigger::TCProcessor | private |
| m_use_readout_map | dunedaq::trigger::TCProcessor | private |
| m_use_roi_readout | dunedaq::trigger::TCProcessor | private |
| make_td(const TCWrapper *tc) | dunedaq::trigger::TCProcessor | protected |
| metric_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| metric_counter_type typedef | dunedaq::trigger::TCProcessor | private |
| MonitorableObject(const MonitorableObject &)=delete | dunedaq::opmonlib::MonitorableObject | |
| MonitorableObject(MonitorableObject &&)=delete | dunedaq::opmonlib::MonitorableObject | |
| MonitorableObject()=default | dunedaq::opmonlib::MonitorableObject | protected |
| MonitorableObject(ElementId name, ElementId parent_id="") | dunedaq::opmonlib::MonitorableObject | inlineprivate |
| NewNodePtr typedef | dunedaq::opmonlib::MonitorableObject | |
| NodePtr typedef | dunedaq::opmonlib::MonitorableObject | |
| operator=(const RawDataProcessorConcept &)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< TCWrapper > | |
| operator=(RawDataProcessorConcept &&)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< TCWrapper > | |
| dunedaq::opmonlib::MonitorableObject::operator=(const MonitorableObject &)=delete | dunedaq::opmonlib::MonitorableObject | |
| dunedaq::opmonlib::MonitorableObject::operator=(MonitorableObject &&)=delete | dunedaq::opmonlib::MonitorableObject | |
| parse_group_links(const nlohmann::json &data) | dunedaq::trigger::TCProcessor | private |
| parse_readout_map(const std::vector< const appmodel::TCReadoutMap * > &data) | dunedaq::trigger::TCProcessor | private |
| parse_roi_conf(const std::vector< const appmodel::ROIGroupConf * > &data) | dunedaq::trigger::TCProcessor | private |
| pick_roi_group_conf() | dunedaq::trigger::TCProcessor | private |
| postprocess_item(const TCWrapper *item) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | virtual |
| preprocess_item(TCWrapper *item) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | inlinevirtual |
| print_group_links() | dunedaq::trigger::TCProcessor | private |
| print_opmon_stats() | dunedaq::trigger::TCProcessor | private |
| print_readout_map(std::map< TCType, std::pair< triggeralgs::timestamp_t, triggeralgs::timestamp_t > > map) | dunedaq::trigger::TCProcessor | private |
| print_roi_conf(std::map< int, roi_group > roi_conf) | dunedaq::trigger::TCProcessor | private |
| print_trigger_bitwords() | dunedaq::trigger::TCProcessor | private |
| publish(google::protobuf::Message &&, CustomOrigin &&co={}, OpMonLevel l=to_level(EntryOpMonLevel::kDefault)) const noexcept | dunedaq::opmonlib::MonitorableObject | protected |
| publishable_metric(OpMonLevel entry, OpMonLevel system) noexcept | dunedaq::opmonlib::MonitorableObject | inlinestatic |
| RawDataProcessorConcept() | dunedaq::datahandlinglibs::RawDataProcessorConcept< TCWrapper > | inline |
| RawDataProcessorConcept(const RawDataProcessorConcept &)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< TCWrapper > | |
| RawDataProcessorConcept(RawDataProcessorConcept &&)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< TCWrapper > | |
| register_node(ElementId name, NewNodePtr) | dunedaq::opmonlib::MonitorableObject | protected |
| reset_last_daq_time() | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | inline |
| roi_readout_make_requests(dfmessages::TriggerDecision &decision) | dunedaq::trigger::TCProcessor | private |
| run_post_processing_thread(std::function< void(const TCWrapper *)> &function, folly::ProducerConsumerQueue< const TCWrapper * > &queue) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | protected |
| s_default_facility | dunedaq::opmonlib::MonitorableObject | privatestatic |
| scrap(const appfwk::DAQModule::CommandData_t &args) override | dunedaq::trigger::TCProcessor | virtual |
| send_trigger_decisions() | dunedaq::trigger::TCProcessor | private |
| set_opmon_level(OpMonLevel) noexcept | dunedaq::opmonlib::MonitorableObject | private |
| set_trigger_bitwords(const std::vector< const appmodel::TriggerBitword * > &_bitwords) | dunedaq::trigger::TCProcessor | private |
| start(const appfwk::DAQModule::CommandData_t &args) override | dunedaq::trigger::TCProcessor | virtual |
| stop(const appfwk::DAQModule::CommandData_t &args) override | dunedaq::trigger::TCProcessor | virtual |
| TaskRawDataProcessorModel(std::unique_ptr< FrameErrorRegistry > &error_registry, bool post_processing_enabled) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | inlineexplicit |
| TCProcessor(std::unique_ptr< datahandlinglibs::FrameErrorRegistry > &error_registry, bool post_processing_enabled) | dunedaq::trigger::TCProcessor | explicit |
| tcptr typedef | dunedaq::trigger::TCProcessor | |
| TCType typedef | dunedaq::trigger::TCProcessor | |
| TDBitset typedef | dunedaq::trigger::TCProcessor | |
| time_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| ~MonitorableObject()=default | dunedaq::opmonlib::MonitorableObject | virtual |
| ~RawDataProcessorConcept() | dunedaq::datahandlinglibs::RawDataProcessorConcept< TCWrapper > | inlinevirtual |
| ~TaskRawDataProcessorModel() | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TCWrapper > | inline |
| ~TCProcessor() | dunedaq::trigger::TCProcessor | |
1.12.0