check_waiting_requests() | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
cleanup() | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protectedvirtual |
cleanup_check() override | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | virtual |
collect() noexcept | dunedaq::opmonlib::MonitorableObject | private |
conf(const appmodel::DataHandlerModule *conf) override | dunedaq::datahandlinglibs::ZeroCopyRecordingRequestHandlerModel< ReadoutType, LatencyBufferType > | virtual |
const_metric_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
const_time_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
create_empty_fragment(const dfmessages::DataRequest &dr) | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
create_fragment_header(const dfmessages::DataRequest &dr) | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | inlineprotected |
data_request(dfmessages::DataRequest dr) override | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protectedvirtual |
DefaultRequestHandlerModel(std::shared_ptr< LatencyBufferType > &latency_buffer, std::unique_ptr< FrameErrorRegistry > &error_registry) | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | inlineexplicit |
dump_to_buffer(const void *data, std::size_t size, void *buffer, uint32_t buffer_pos, const std::size_t &buffer_size) | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | inlineprotected |
ElementId typedef | dunedaq::opmonlib::MonitorableObject | |
facility_ptr_t typedef | dunedaq::opmonlib::MonitorableObject | private |
generate_opmon_data() override | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protectedvirtual |
get_cutoff_timestamp() | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | inlinevirtual |
get_fragment_pieces(uint64_t start_win_ts, uint64_t end_win_ts, RequestResult &rres) | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
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::datahandlinglibs::ZeroCopyRecordingRequestHandlerModel< ReadoutType, LatencyBufferType > | |
issue_request(dfmessages::DataRequest datarequest, bool is_retry=false) override | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | virtual |
kCleanup enum value | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
kFound enum value | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
kNotFound enum value | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
kNotYet enum value | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
kPartial enum value | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
kPartiallyOld enum value | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
kTooOld enum value | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
kUnknown enum value | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
LBT typedef | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | |
m_buffer_capacity | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_buffered_writer | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_bytes_written | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_cleanup_requested | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_cleanup_thread | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_configured | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_cpu_us_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
m_cv | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_cv_mutex | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_detid | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_error_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
m_error_registry | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_facility | dunedaq::opmonlib::MonitorableObject | private |
m_fd | dunedaq::datahandlinglibs::ZeroCopyRecordingRequestHandlerModel< ReadoutType, LatencyBufferType > | private |
m_frag_out_conn_ids | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_fragment_send_timeout_ms | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_handled_requests | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_ignored_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
m_latency_buffer | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_max_requested_elements | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_next_timestamp_to_record | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_node_mutex | dunedaq::opmonlib::MonitorableObject | private |
m_nodes | dunedaq::opmonlib::MonitorableObject | private |
m_num_buffer_cleanups | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_periodic_send_failed | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_periodic_sent | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_request_handling_threads | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_requests_bad | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_requests_delayed | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_requests_found | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_requests_old_window | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_requests_timed_out | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_num_requests_uncategorized | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_occupancy | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_oflag | dunedaq::datahandlinglibs::ZeroCopyRecordingRequestHandlerModel< ReadoutType, LatencyBufferType > | private |
m_opmon_level | dunedaq::opmonlib::MonitorableObject | private |
m_opmon_name | dunedaq::opmonlib::MonitorableObject | private |
m_output_file | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_parent_id | dunedaq::opmonlib::MonitorableObject | private |
m_payloads_written | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_periodic_data_transmission_ms | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_periodic_transmission_thread | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_pop_counter | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_pop_limit_pct | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_pop_limit_size | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_pop_reqs | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_pop_size_pct | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_pops_count | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_published_counter | dunedaq::opmonlib::MonitorableObject | mutableprivate |
m_recording | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_recording_configured | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_recording_thread | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_request_counter | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_request_handler_thread_pool | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_request_timeout_ms | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | private |
m_requests_running | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_response_time_acc | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_response_time_max | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_response_time_min | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_run_marker | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_sourceid | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_stream_buffer_size | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_t0 | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_waiting_queue_thread | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_waiting_requests | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_waiting_requests_lock | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_warn_about_empty_buffer | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
m_warn_on_timeout | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | 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 RequestHandlerConcept &)=delete | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | |
operator=(RequestHandlerConcept &&)=delete | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | |
dunedaq::opmonlib::MonitorableObject::operator=(const MonitorableObject &)=delete | dunedaq::opmonlib::MonitorableObject | |
dunedaq::opmonlib::MonitorableObject::operator=(MonitorableObject &&)=delete | dunedaq::opmonlib::MonitorableObject | |
periodic_cleanups() | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
periodic_data_transmission() override | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | virtual |
periodic_data_transmissions() | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | protected |
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 |
RDT typedef | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | |
record(const nlohmann::json &args) override | dunedaq::datahandlinglibs::ZeroCopyRecordingRequestHandlerModel< ReadoutType, LatencyBufferType > | virtual |
register_node(ElementId name, NewNodePtr) | dunedaq::opmonlib::MonitorableObject | protected |
RequestHandlerConcept() | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | inline |
RequestHandlerConcept(const RequestHandlerConcept &)=delete | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | |
RequestHandlerConcept(RequestHandlerConcept &&)=delete | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | |
RequestResult typedef | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | |
ResultCode typedef | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | |
resultCodeAsString(ResultCode rc) | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | inlineprotected |
ResultCodeStrings | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | protected |
s_default_facility | dunedaq::opmonlib::MonitorableObject | privatestatic |
scrap(const nlohmann::json &) override | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | virtual |
set_opmon_level(OpMonLevel) noexcept | dunedaq::opmonlib::MonitorableObject | private |
start(const nlohmann::json &) | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | virtual |
stop(const nlohmann::json &) | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | virtual |
supports_cutoff_timestamp() | dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > | inlinevirtual |
time_counter_t typedef | dunedaq::opmonlib::MonitorableObject | private |
ZeroCopyRecordingRequestHandlerModel(std::shared_ptr< LatencyBufferType > &latency_buffer, std::unique_ptr< FrameErrorRegistry > &error_registry) | dunedaq::datahandlinglibs::ZeroCopyRecordingRequestHandlerModel< ReadoutType, LatencyBufferType > | inlineexplicit |
~MonitorableObject()=default | dunedaq::opmonlib::MonitorableObject | virtual |
~RequestHandlerConcept() | dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType > | inlinevirtual |