DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType > Member List

This is the complete list of members for dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >, including all inherited members.

check_waiting_requests()dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
cleanup()dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protectedvirtual
cleanup_check() overridedunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >virtual
collect() noexceptdunedaq::opmonlib::MonitorableObjectprivate
conf(const dunedaq::appmodel::DataHandlerModule *)dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >virtual
const_metric_counter_t typedefdunedaq::opmonlib::MonitorableObjectprivate
const_time_counter_t typedefdunedaq::opmonlib::MonitorableObjectprivate
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) overridedunedaq::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 typedefdunedaq::opmonlib::MonitorableObject
facility_ptr_t typedefdunedaq::opmonlib::MonitorableObjectprivate
generate_opmon_data() overridedunedaq::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 noexceptdunedaq::opmonlib::MonitorableObjectinline
get_opmon_level() const noexceptdunedaq::opmonlib::MonitorableObjectinline
inherit_parent_properties(const MonitorableObject &parent)dunedaq::opmonlib::MonitorableObjectprivate
issue_request(dfmessages::DataRequest datarequest, bool is_retry=false) overridedunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >virtual
kCleanup enum valuedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
kFound enum valuedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
kNotFound enum valuedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
kNotYet enum valuedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
kPartial enum valuedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
kPartiallyOld enum valuedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
kTooOld enum valuedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
kUnknown enum valuedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
LBT typedefdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >
m_buffer_capacitydunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_buffered_writerdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_bytes_writtendunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_cleanup_requesteddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_cleanup_threaddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_configureddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_cpu_us_counterdunedaq::opmonlib::MonitorableObjectmutableprivate
m_cvdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_cv_mutexdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_detiddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_error_counterdunedaq::opmonlib::MonitorableObjectmutableprivate
m_error_registrydunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_facilitydunedaq::opmonlib::MonitorableObjectprivate
m_frag_out_conn_idsdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_fragment_send_timeout_msdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_handled_requestsdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_ignored_counterdunedaq::opmonlib::MonitorableObjectmutableprivate
m_latency_bufferdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_max_requested_elementsdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_next_timestamp_to_recorddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_node_mutexdunedaq::opmonlib::MonitorableObjectprivate
m_nodesdunedaq::opmonlib::MonitorableObjectprivate
m_num_buffer_cleanupsdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_periodic_send_faileddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_periodic_sentdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_request_handling_threadsdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_requests_baddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_requests_delayeddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_requests_founddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_requests_old_windowdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_requests_timed_outdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_num_requests_uncategorizeddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_occupancydunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_opmon_leveldunedaq::opmonlib::MonitorableObjectprivate
m_opmon_namedunedaq::opmonlib::MonitorableObjectprivate
m_output_filedunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_parent_iddunedaq::opmonlib::MonitorableObjectprivate
m_payloads_writtendunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_periodic_data_transmission_msdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_periodic_transmission_threaddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_pop_counterdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_pop_limit_pctdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_pop_limit_sizedunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_pop_reqsdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_pop_size_pctdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_pops_countdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_published_counterdunedaq::opmonlib::MonitorableObjectmutableprivate
m_recordingdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_recording_configureddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_recording_threaddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_request_counterdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_request_handler_thread_pooldunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_request_timeout_msdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >private
m_requests_runningdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_response_time_accdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_response_time_maxdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_response_time_mindunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_run_markerdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_sourceiddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_stream_buffer_sizedunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_t0dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_waiting_queue_threaddunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_waiting_requestsdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_waiting_requests_lockdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_warn_about_empty_bufferdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
m_warn_on_timeoutdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
metric_counter_t typedefdunedaq::opmonlib::MonitorableObjectprivate
MonitorableObject(const MonitorableObject &)=deletedunedaq::opmonlib::MonitorableObject
MonitorableObject(MonitorableObject &&)=deletedunedaq::opmonlib::MonitorableObject
MonitorableObject()=defaultdunedaq::opmonlib::MonitorableObjectprotected
MonitorableObject(ElementId name, ElementId parent_id="")dunedaq::opmonlib::MonitorableObjectinlineprivate
NewNodePtr typedefdunedaq::opmonlib::MonitorableObject
NodePtr typedefdunedaq::opmonlib::MonitorableObject
operator=(const RequestHandlerConcept &)=deletedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >
operator=(RequestHandlerConcept &&)=deletedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >
dunedaq::opmonlib::MonitorableObject::operator=(const MonitorableObject &)=deletedunedaq::opmonlib::MonitorableObject
dunedaq::opmonlib::MonitorableObject::operator=(MonitorableObject &&)=deletedunedaq::opmonlib::MonitorableObject
periodic_cleanups()dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >protected
periodic_data_transmission() overridedunedaq::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 noexceptdunedaq::opmonlib::MonitorableObjectprotected
publishable_metric(OpMonLevel entry, OpMonLevel system) noexceptdunedaq::opmonlib::MonitorableObjectinlinestatic
RDT typedefdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >
record(const nlohmann::json &args) overridedunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >virtual
register_node(ElementId name, NewNodePtr)dunedaq::opmonlib::MonitorableObjectprotected
RequestHandlerConcept()dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >inline
RequestHandlerConcept(const RequestHandlerConcept &)=deletedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >
RequestHandlerConcept(RequestHandlerConcept &&)=deletedunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >
RequestResult typedefdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >
ResultCode typedefdunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >
resultCodeAsString(ResultCode rc)dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >inlineprotected
ResultCodeStringsdunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >protected
s_default_facilitydunedaq::opmonlib::MonitorableObjectprivatestatic
scrap(const nlohmann::json &) overridedunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >virtual
set_opmon_level(OpMonLevel) noexceptdunedaq::opmonlib::MonitorableObjectprivate
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 typedefdunedaq::opmonlib::MonitorableObjectprivate
~MonitorableObject()=defaultdunedaq::opmonlib::MonitorableObjectvirtual
~RequestHandlerConcept()dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >inlinevirtual