| add_postprocess_task(Task &&task) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | |
| add_preprocess_task(Task &&task) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | |
| calculate_all_metric_summaries_across_planes(const std::unordered_map< dunedaq::trgdataformats::channel_t, std::vector< std::pair< std::string, int16_t > > > &metrics) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| collect() noexcept | dunedaq::opmonlib::MonitorableObject | private |
| conf(const appmodel::DataHandlerModule *conf) override | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | virtual |
| configure_channel_plane_numbers(const appmodel::TPCRawDataProcessor *proc_conf) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| configure_find_tps(const appmodel::DataHandlerModule *conf, const appmodel::TPCRawDataProcessor *proc_conf) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| configure_postprocessing(const appmodel::DataHandlerModule *conf) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| configure_preprocessing(const appmodel::DataHandlerModule *conf) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| configure_source_and_geo_ids(const appmodel::DataHandlerModule *conf) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| const_metric_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| const_time_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| constframeptr typedef | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | |
| ElementId typedef | dunedaq::opmonlib::MonitorableObject | |
| facility_ptr_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| find_tps(constframeptr fp) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| frameptr typedef | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | |
| generate_opmon_data() override | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protectedvirtual |
| get_last_daq_time() override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | inlinevirtual |
| get_opmon_id() const noexcept | dunedaq::opmonlib::MonitorableObject | inline |
| get_opmon_level() const noexcept | dunedaq::opmonlib::MonitorableObject | inline |
| inherit_parent_properties(const MonitorableObject &parent) | dunedaq::opmonlib::MonitorableObject | private |
| inherited typedef | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | |
| invoke_all_preprocess_functions(types::TDEEthTypeAdapter *item) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | |
| invoke_postprocess_schedule_timeout_policy(std::uint64_t accumilated_timeout_ticks) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | inlinevirtual |
| launch_all_preprocess_functions(types::TDEEthTypeAdapter *item) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | |
| m_channel_mask_set | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_channel_plane_map | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_channel_plane_numbers | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_cpu_us_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
| m_crate_id | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_current_seq_id | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_current_tp_count | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_current_ts | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_det_id | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_emulator_mode | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_error_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
| m_error_registry | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_facility | dunedaq::opmonlib::MonitorableObject | private |
| m_first_frame | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_first_seq_id_mismatch | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_first_ts_missmatch | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_frame_count_at_last_send | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_frame_count_limit | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_frame_counter | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_frame_limit_enabled | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_ignored_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
| m_items_to_postprocess_queues | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_last_processed_daq_ts | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_metric_collect_opmon_period | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_node_mutex | dunedaq::opmonlib::MonitorableObject | private |
| m_nodes | dunedaq::opmonlib::MonitorableObject | private |
| m_num_new_tps | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_opmon_level | dunedaq::opmonlib::MonitorableObject | private |
| m_opmon_name | dunedaq::opmonlib::MonitorableObject | private |
| m_parent_id | dunedaq::opmonlib::MonitorableObject | private |
| m_pattern_generator_current_ts | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_pattern_generator_previous_ts | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_plane_numbers_set | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_plane_to_tp_sink_map | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_plane_to_tpa_vector_map | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_post_process_functions | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_post_process_threads | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_post_processing_enabled | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_postprocess_queue_sizes | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_preprocess_functions | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_previous_seq_id | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_previous_ts | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_published_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
| m_run_marker | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| m_seq_id_error_ctr | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_seq_id_error_state | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_seq_id_max_jump | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_seq_id_min_jump | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_seq_id_problem_reported | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_slot_id | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_sourceid | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_state_harvester | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_stream_id | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_t0 | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_tp_channel_rate_map | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_tp_count_limit | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_tp_generator | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_tp_limit_enabled | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_tpg_configs | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_tpg_metric_collect_enabled | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_tps_send_failed | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_tps_suppressed_too_long | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_ts_error_ctr | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_ts_error_state | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| m_ts_problem_reported | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| metric_counter_t typedef | dunedaq::opmonlib::MonitorableObject | 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< types::TDEEthTypeAdapter > | |
| operator=(RawDataProcessorConcept &&)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::TDEEthTypeAdapter > | |
| dunedaq::opmonlib::MonitorableObject::operator=(const MonitorableObject &)=delete | dunedaq::opmonlib::MonitorableObject | |
| dunedaq::opmonlib::MonitorableObject::operator=(MonitorableObject &&)=delete | dunedaq::opmonlib::MonitorableObject | |
| postprocess_item(const types::TDEEthTypeAdapter *item) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | virtual |
| preprocess_item(types::TDEEthTypeAdapter *item) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | inlinevirtual |
| publish(google::protobuf::Message &&, CustomOrigin &&co={}, OpMonLevel l=to_level(EntryOpMonLevel::kDefault)) const noexcept | dunedaq::opmonlib::MonitorableObject | protected |
| publish_processor_metric_to_opmon() | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| publish_processor_metric_to_opmon_with_aggregation() | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| publishable_metric(OpMonLevel entry, OpMonLevel system) noexcept | dunedaq::opmonlib::MonitorableObject | inlinestatic |
| RawDataProcessorConcept() | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::TDEEthTypeAdapter > | inline |
| RawDataProcessorConcept(const RawDataProcessorConcept &)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::TDEEthTypeAdapter > | |
| RawDataProcessorConcept(RawDataProcessorConcept &&)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::TDEEthTypeAdapter > | |
| register_node(ElementId name, NewNodePtr) | dunedaq::opmonlib::MonitorableObject | protected |
| reset_last_daq_time() | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | inline |
| run_post_processing_thread(std::function< void(const types::TDEEthTypeAdapter *)> &function, folly::ProducerConsumerQueue< const types::TDEEthTypeAdapter * > &queue) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | protected |
| s_default_facility | dunedaq::opmonlib::MonitorableObject | privatestatic |
| scrap(const appfwk::DAQModule::CommandData_t &cfg) override | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | virtual |
| scrap_channel_plane_numbers() | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| scrap_find_tps() | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| scrap_postprocessing() | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| scrap_preprocessing() | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| scrap_source_and_geo_ids() | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| sequence_check(frameptr fp) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| set_opmon_level(OpMonLevel) noexcept | dunedaq::opmonlib::MonitorableObject | private |
| start(const appfwk::DAQModule::CommandData_t &args) override | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | virtual |
| stop(const appfwk::DAQModule::CommandData_t &args) override | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | virtual |
| TaskRawDataProcessorModel(std::unique_ptr< FrameErrorRegistry > &error_registry, bool post_processing_enabled) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | inlineexplicit |
| time_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
| timestamp_check(frameptr fp) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | protected |
| TPCEthFrameProcessor(std::unique_ptr< datahandlinglibs::FrameErrorRegistry > &error_registry, bool processing_enabled) | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | explicit |
| tpcframeptr typedef | dunedaq::fdreadoutlibs::TPCEthFrameProcessor< types::TDEEthTypeAdapter > | |
| ~MonitorableObject()=default | dunedaq::opmonlib::MonitorableObject | virtual |
| ~RawDataProcessorConcept() | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::TDEEthTypeAdapter > | inlinevirtual |
| ~TaskRawDataProcessorModel() | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > | inline |
1.12.0