add_postprocess_task(Task &&task) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | |
add_preprocess_task(Task &&task) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | |
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::WIBEthFrameProcessor | protected |
collect() noexcept | dunedaq::opmonlib::MonitorableObject | private |
conf(const appmodel::DataHandlerModule *conf) override | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | virtual |
const_metric_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
const_time_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
constframeptr typedef | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | |
ElementId typedef | dunedaq::opmonlib::MonitorableObject | |
facility_ptr_t typedef | dunedaq::opmonlib::MonitorableObject | private |
find_hits(constframeptr fp) | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
frameptr typedef | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | |
generate_opmon_data() override | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protectedvirtual |
get_last_daq_time() override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | 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::WIBEthFrameProcessor | |
invoke_all_preprocess_functions(types::DUNEWIBEthTypeAdapter *item) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | |
launch_all_preprocess_functions(types::DUNEWIBEthTypeAdapter *item) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | |
m_channel_map | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_channel_mask_set | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_channel_plane_numbers | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_cpu_us_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
m_crate_id | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_current_seq_id | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_current_ts | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_det_id | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_emulator_mode | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_err_frame_sink | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_error_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
m_error_registry | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_facility | dunedaq::opmonlib::MonitorableObject | private |
m_first_hit | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_first_seq_id_mismatch | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_first_ts_missmatch | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_frame_counter | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_ignored_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
m_items_to_postprocess_queues | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_last_processed_daq_ts | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_metric_collect_opmon_period | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_new_hits | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_new_tps | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_node_mutex | dunedaq::opmonlib::MonitorableObject | private |
m_nodes | dunedaq::opmonlib::MonitorableObject | private |
m_num_msg | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_num_push_fail | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
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::WIBEthFrameProcessor | protected |
m_pattern_generator_previous_ts | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_post_process_functions | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_post_process_threads | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_post_processing_enabled | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_postprocess_queue_sizes | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_preprocess_functions | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_previous_seq_id | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_previous_ts | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_published_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
m_run_marker | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
m_seq_id_error_ctr | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_seq_id_error_state | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_seq_id_max_jump | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_seq_id_min_jump | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_seq_id_problem_reported | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_slot_id | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_sourceid | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_stream_id | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_t0 | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tp_channel_rate_map | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tp_generator | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tp_max_width | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tp_sink | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tpa_vectors | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tpg_configs | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tpg_hits_count | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tpg_metric_collect_enabled | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tpg_threshold_selected | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tps_send_failed | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_tps_suppressed_too_long | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | private |
m_ts_error_ctr | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_ts_error_state | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
m_ts_problem_reported | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | 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::DUNEWIBEthTypeAdapter > | |
operator=(RawDataProcessorConcept &&)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::DUNEWIBEthTypeAdapter > | |
dunedaq::opmonlib::MonitorableObject::operator=(const MonitorableObject &)=delete | dunedaq::opmonlib::MonitorableObject | |
dunedaq::opmonlib::MonitorableObject::operator=(MonitorableObject &&)=delete | dunedaq::opmonlib::MonitorableObject | |
postprocess_item(const types::DUNEWIBEthTypeAdapter *item) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | virtual |
preprocess_item(types::DUNEWIBEthTypeAdapter *item) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | 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::WIBEthFrameProcessor | protected |
publish_processor_metric_to_opmon_with_aggregation() | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
publishable_metric(OpMonLevel entry, OpMonLevel system) noexcept | dunedaq::opmonlib::MonitorableObject | inlinestatic |
RawDataProcessorConcept() | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::DUNEWIBEthTypeAdapter > | inline |
RawDataProcessorConcept(const RawDataProcessorConcept &)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::DUNEWIBEthTypeAdapter > | |
RawDataProcessorConcept(RawDataProcessorConcept &&)=delete | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::DUNEWIBEthTypeAdapter > | |
register_node(ElementId name, NewNodePtr) | dunedaq::opmonlib::MonitorableObject | protected |
reset_last_daq_time() | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | inline |
run_post_processing_thread(std::function< void(const types::DUNEWIBEthTypeAdapter *)> &function, folly::ProducerConsumerQueue< const types::DUNEWIBEthTypeAdapter * > &queue) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | protected |
s_default_facility | dunedaq::opmonlib::MonitorableObject | privatestatic |
scrap(const nlohmann::json &) override | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | virtual |
sequence_check(frameptr fp) | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
set_opmon_level(OpMonLevel) noexcept | dunedaq::opmonlib::MonitorableObject | private |
start(const nlohmann::json &args) override | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | virtual |
stop(const nlohmann::json &args) override | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | virtual |
TaskRawDataProcessorModel(std::unique_ptr< FrameErrorRegistry > &error_registry, bool post_processing_enabled) | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | inlineexplicit |
time_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
timestamp_check(frameptr fp) | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
use_pattern_generator(frameptr fp) | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | protected |
WIBEthFrameProcessor(std::unique_ptr< datahandlinglibs::FrameErrorRegistry > &error_registry, bool processing_enabled) | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | explicit |
wibframeptr typedef | dunedaq::fdreadoutlibs::WIBEthFrameProcessor | |
~MonitorableObject()=default | dunedaq::opmonlib::MonitorableObject | virtual |
~RawDataProcessorConcept() | dunedaq::datahandlinglibs::RawDataProcessorConcept< types::DUNEWIBEthTypeAdapter > | inlinevirtual |
~TaskRawDataProcessorModel() | dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::DUNEWIBEthTypeAdapter > | inline |