dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType > Member List

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

collect() noexcept	dunedaq::opmonlib::MonitorableObject	private
conf(const nlohmann::json &args)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	virtual
const_metric_counter_t typedef	dunedaq::opmonlib::MonitorableObject	private
const_time_counter_t typedef	dunedaq::opmonlib::MonitorableObject	private
consume_payload(RDT &&payload)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >
DataHandlingConcept()	dunedaq::datahandlinglibs::DataHandlingConcept	inline
DataHandlingConcept(const DataHandlingConcept &)=delete	dunedaq::datahandlinglibs::DataHandlingConcept
DataHandlingConcept(DataHandlingConcept &&)=delete	dunedaq::datahandlinglibs::DataHandlingConcept
DataHandlingModel(std::atomic< bool > &run_marker)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	inlineexplicit
dispatch_requests(dfmessages::DataRequest &data_request)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
ElementId typedef	dunedaq::opmonlib::MonitorableObject
facility_ptr_t typedef	dunedaq::opmonlib::MonitorableObject	private
generate_opmon_data() override	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protectedvirtual
get_opmon_id() const noexcept	dunedaq::opmonlib::MonitorableObject	inline
get_opmon_level() const noexcept	dunedaq::opmonlib::MonitorableObject	inline
IDT typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >
inherit_parent_properties(const MonitorableObject &parent)	dunedaq::opmonlib::MonitorableObject	private
init(const appmodel::DataHandlerModule *modconf)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	virtual
LBT typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >
m_callback_mode	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_consume_callback	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >
m_consumer_thread	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_cpu_us_counter	dunedaq::opmonlib::MonitorableObject	mutableprivate
m_current_fake_trigger_id	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_data_request_receiver	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_error_counter	dunedaq::opmonlib::MonitorableObject	mutableprivate
m_error_registry	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_facility	dunedaq::opmonlib::MonitorableObject	private
m_fake_trigger	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_generate_timesync	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_ignored_counter	dunedaq::opmonlib::MonitorableObject	mutableprivate
m_latency_buffer_impl	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_node_mutex	dunedaq::opmonlib::MonitorableObject	private
m_nodes	dunedaq::opmonlib::MonitorableObject	private
m_num_lb_insert_failures	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_num_payloads	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_num_requests	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_opmon_level	dunedaq::opmonlib::MonitorableObject	private
m_opmon_name	dunedaq::opmonlib::MonitorableObject	private
m_parent_id	dunedaq::opmonlib::MonitorableObject	private
m_pid_of_current_process	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_processing_delay_ticks	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_published_counter	dunedaq::opmonlib::MonitorableObject	mutableprivate
m_raw_data_receiver	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_raw_data_receiver_connection_name	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_raw_processor_impl	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_raw_receiver_sleep_us	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_raw_receiver_timeout_ms	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_rawq_timeout_count	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_request_handler_impl	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_request_handler_supports_cutoff_timestamp	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_run_marker	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_run_number	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_sourceid	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_stats_packet_count	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_sum_payloads	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_sum_requests	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_t0	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_timesync_connection_name	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_timesync_sender	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
m_timesync_thread	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
metric_counter_t typedef	dunedaq::opmonlib::MonitorableObject	private
metric_t typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
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
ms	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	inlinestatic
NewNodePtr typedef	dunedaq::opmonlib::MonitorableObject
NodePtr typedef	dunedaq::opmonlib::MonitorableObject
ns	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	inlinestatic
num_lb_insert_failures_t typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
num_payload_t typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
num_request_t typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
operator=(const DataHandlingConcept &)=delete	dunedaq::datahandlinglibs::DataHandlingConcept
operator=(DataHandlingConcept &&)=delete	dunedaq::datahandlinglibs::DataHandlingConcept
dunedaq::opmonlib::MonitorableObject::operator=(const MonitorableObject &)=delete	dunedaq::opmonlib::MonitorableObject
dunedaq::opmonlib::MonitorableObject::operator=(MonitorableObject &&)=delete	dunedaq::opmonlib::MonitorableObject
process_item(RDT &payload)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	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
raw_receiver_ct typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
rawq_timeout_count_t typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
RDT typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >
record(const nlohmann::json &args) override	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	inlinevirtual
register_node(ElementId name, NewNodePtr)	dunedaq::opmonlib::MonitorableObject	protected
request_receiver_ct typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
RHT typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >
RPT typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >
run_consume()	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protectedvirtual
run_timesync()	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protectedvirtual
s	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	inlinestatic
s_default_facility	dunedaq::opmonlib::MonitorableObject	privatestatic
scrap(const nlohmann::json &args)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	inlinevirtual
set_opmon_level(OpMonLevel) noexcept	dunedaq::opmonlib::MonitorableObject	private
start(const nlohmann::json &args)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	virtual
stop(const nlohmann::json &args)	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	virtual
sum_payload_t typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
sum_request_t typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
time_counter_t typedef	dunedaq::opmonlib::MonitorableObject	private
timestamp_t typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >
timesync_sender_ct typedef	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	protected
transform_payload(IDT &original) const	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	inlineprotectedvirtual
us	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	inlinestatic
~DataHandlingConcept()	dunedaq::datahandlinglibs::DataHandlingConcept	inlinevirtual
~DataHandlingModel()=default	dunedaq::datahandlinglibs::DataHandlingModel< ReadoutType, RequestHandlerType, LatencyBufferType, RawDataProcessorType, InputDataType >	virtual
~MonitorableObject()=default	dunedaq::opmonlib::MonitorableObject	virtual