|
| using | inherited |
| |
| using | frameptr |
| |
| using | constframeptr |
| |
| using | tpcframeptr |
| |
| using | NodePtr = std::weak_ptr<MonitorableObject> |
| |
| using | NewNodePtr = std::shared_ptr<MonitorableObject> |
| |
| using | ElementId = std::string |
| |
| | TPCEthFrameProcessor (std::unique_ptr< datahandlinglibs::FrameErrorRegistry > &error_registry, bool processing_enabled) |
| |
| void | start (const appfwk::DAQModule::CommandData_t &args) override |
| | Start operation.
|
| |
| void | stop (const appfwk::DAQModule::CommandData_t &args) override |
| | Stop operation.
|
| |
| void | conf (const appmodel::DataHandlerModule *conf) override |
| | Set the emulator mode, if active, timestamps of processed packets are overwritten with new ones.
|
| |
| void | scrap (const appfwk::DAQModule::CommandData_t &cfg) override |
| | Unconfigure.
|
| |
 Public Member Functions inherited from dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > |
| | TaskRawDataProcessorModel (std::unique_ptr< FrameErrorRegistry > &error_registry, bool post_processing_enabled) |
| |
| | ~TaskRawDataProcessorModel () |
| |
| void | reset_last_daq_time () |
| |
| std::uint64_t | get_last_daq_time () override |
| | Get newest timestamp of last seen packet.
|
| |
| void | preprocess_item (types::TDEEthTypeAdapter *item) override |
| | Preprocess one element.
|
| |
| void | postprocess_item (const types::TDEEthTypeAdapter *item) override |
| | Postprocess one element.
|
| |
| void | invoke_postprocess_schedule_timeout_policy (std::uint64_t accumilated_timeout_ticks) override |
| | Handle postprocess timeout event.
|
| |
| void | add_preprocess_task (Task &&task) |
| |
| void | add_postprocess_task (Task &&task) |
| |
| void | invoke_all_preprocess_functions (types::TDEEthTypeAdapter *item) |
| |
| void | launch_all_preprocess_functions (types::TDEEthTypeAdapter *item) |
| |
| Public Member Functions inherited from dunedaq::datahandlinglibs::RawDataProcessorConcept< types::TDEEthTypeAdapter > |
| | RawDataProcessorConcept () |
| |
| | RawDataProcessorConcept (const RawDataProcessorConcept &)=delete |
| | RawDataProcessorConcept is not copy-constructible.
|
| |
| | RawDataProcessorConcept (RawDataProcessorConcept &&)=delete |
| | RawDataProcessorConcept is not move-constructible.
|
| |
| virtual | ~RawDataProcessorConcept () |
| |
| RawDataProcessorConcept & | operator= (const RawDataProcessorConcept &)=delete |
| | RawDataProcessorConcept is not copy-assginable.
|
| |
| RawDataProcessorConcept & | operator= (RawDataProcessorConcept &&)=delete |
| | RawDataProcessorConcept is not move-assignable.
|
| |
| | MonitorableObject (const MonitorableObject &)=delete |
| |
| MonitorableObject & | operator= (const MonitorableObject &)=delete |
| |
| | MonitorableObject (MonitorableObject &&)=delete |
| |
| MonitorableObject & | operator= (MonitorableObject &&)=delete |
| |
| virtual | ~MonitorableObject ()=default |
| |
| auto | get_opmon_id () const noexcept |
| |
| auto | get_opmon_level () const noexcept |
| |
| static bool | publishable_metric (OpMonLevel entry, OpMonLevel system) noexcept |
| |
| void | generate_opmon_data () override |
| |
| void | configure_source_and_geo_ids (const appmodel::DataHandlerModule *conf) |
| |
| void | configure_preprocessing (const appmodel::DataHandlerModule *conf) |
| |
| void | configure_postprocessing (const appmodel::DataHandlerModule *conf) |
| |
| void | configure_channel_plane_numbers (const appmodel::TPCRawDataProcessor *proc_conf) |
| |
| void | configure_find_tps (const appmodel::DataHandlerModule *conf, const appmodel::TPCRawDataProcessor *proc_conf) |
| |
| void | scrap_source_and_geo_ids () |
| |
| void | scrap_preprocessing () |
| |
| void | scrap_postprocessing () |
| |
| void | scrap_channel_plane_numbers () |
| |
| void | scrap_find_tps () |
| |
| void | publish_processor_metric_to_opmon () |
| |
| void | publish_processor_metric_to_opmon_with_aggregation () |
| |
| std::map< int16_t, std::map< std::string, std::tuple< float, int16_t, int16_t, float, dunedaq::trgdataformats::channel_t, dunedaq::trgdataformats::channel_t > > > | calculate_all_metric_summaries_across_planes (const std::unordered_map< dunedaq::trgdataformats::channel_t, std::vector< std::pair< std::string, int16_t > > > &metrics) |
| |
| void | sequence_check (frameptr fp) |
| |
| void | timestamp_check (frameptr fp) |
| |
| void | find_tps (constframeptr fp) |
| |
| Protected Member Functions inherited from dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > |
| void | run_post_processing_thread (std::function< void(const types::TDEEthTypeAdapter *)> &function, folly::ProducerConsumerQueue< const types::TDEEthTypeAdapter * > &queue) |
| |
| | MonitorableObject ()=default |
| |
| void | register_node (ElementId name, NewNodePtr) |
| |
| void | publish (google::protobuf::Message &&, CustomOrigin &&co={}, OpMonLevel l=to_level(EntryOpMonLevel::kDefault)) const noexcept |
| |
| bool | m_emulator_mode |
| |
| bool | m_first_frame |
| |
| dunedaq::daqdataformats::timestamp_t | m_previous_ts |
| |
| dunedaq::daqdataformats::timestamp_t | m_current_ts |
| |
| dunedaq::daqdataformats::timestamp_t | m_pattern_generator_previous_ts |
| |
| dunedaq::daqdataformats::timestamp_t | m_pattern_generator_current_ts |
| |
| bool | m_first_ts_missmatch |
| |
| bool | m_ts_problem_reported |
| |
| bool | m_ts_error_state |
| |
| std::atomic< uint64_t > | m_ts_error_ctr |
| |
| uint16_t | m_previous_seq_id |
| |
| uint16_t | m_current_seq_id |
| |
| bool | m_first_seq_id_mismatch |
| |
| bool | m_seq_id_problem_reported |
| |
| bool | m_seq_id_error_state |
| |
| std::atomic< uint64_t > | m_seq_id_error_ctr |
| |
| std::atomic< int16_t > | m_seq_id_min_jump |
| |
| std::atomic< int16_t > | m_seq_id_max_jump |
| |
| std::unique_ptr< tpglibs::TPGenerator > | m_tp_generator |
| |
| std::unique_ptr< fdreadoutlibs::TPGInternalStateHarvester > | m_state_harvester |
| |
| std::vector< std::pair< std::string, nlohmann::json > > | m_tpg_configs |
| |
| std::unordered_map< unsigned int, std::vector< trigger::TriggerPrimitiveTypeAdapter > > | m_plane_to_tpa_vector_map |
| |
| std::unordered_map< unsigned int, std::shared_ptr< iomanager::SenderConcept< std::vector< trigger::TriggerPrimitiveTypeAdapter > > > > | m_plane_to_tp_sink_map |
| |
| uint32_t | m_tp_count_limit |
| |
| uint32_t | m_frame_count_limit |
| |
| uint32_t | m_current_tp_count |
| |
| uint32_t | m_frame_count_at_last_send |
| |
| bool | m_tp_limit_enabled |
| |
| bool | m_frame_limit_enabled |
| |
| std::set< unsigned int > | m_channel_mask_set |
| |
| std::set< unsigned int > | m_plane_numbers_set |
| |
| std::vector< std::pair< trgdataformats::channel_t, int16_t > > | m_channel_plane_numbers |
| |
| std::unordered_map< trgdataformats::channel_t, unsigned int > | m_channel_plane_map |
| |
| bool | m_tpg_metric_collect_enabled |
| |
| uint32_t | m_metric_collect_opmon_period |
| |
| std::map< uint, std::atomic< int > > | m_tp_channel_rate_map |
| |
| std::atomic< uint64_t > | m_num_new_tps |
| |
| std::atomic< uint64_t > | m_tps_suppressed_too_long |
| |
| std::atomic< uint64_t > | m_tps_send_failed |
| |
| std::chrono::time_point< std::chrono::high_resolution_clock > | m_t0 |
| |
| std::atomic< uint64_t > | m_frame_counter |
| |
| uint32_t | m_det_id |
| |
| uint32_t | m_crate_id |
| |
| uint32_t | m_slot_id |
| |
| uint32_t | m_stream_id |
| |
| daqdataformats::SourceID | m_sourceid |
| |
| Protected Attributes inherited from dunedaq::datahandlinglibs::TaskRawDataProcessorModel< types::TDEEthTypeAdapter > |
| std::vector< std::function< void(types::TDEEthTypeAdapter *)> > | m_preprocess_functions |
| |
| std::unique_ptr< FrameErrorRegistry > & | m_error_registry |
| |
| bool | m_post_processing_enabled |
| |
| std::atomic< bool > | m_run_marker |
| |
| std::vector< std::function< void(const types::TDEEthTypeAdapter *)> > | m_post_process_functions |
| |
| std::vector< std::unique_ptr< folly::ProducerConsumerQueue< const types::TDEEthTypeAdapter * > > > | m_items_to_postprocess_queues |
| |
| std::vector< std::unique_ptr< utilities::ReusableThread > > | m_post_process_threads |
| |
| size_t | m_postprocess_queue_sizes |
| |
| daqdataformats::SourceID | m_sourceid |
| |
| std::atomic< uint64_t > | m_last_processed_daq_ts |
| |
Definition at line 17 of file TDEEthFrameProcessor.hpp.
1.12.0