dunedaq::trigger::TPProcessor Member List

This is the complete list of members for dunedaq::trigger::TPProcessor, including all inherited members.

add_postprocess_task(Task &&task)	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >
add_preprocess_task(Task &&task)	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >
collect() noexcept	dunedaq::opmonlib::MonitorableObject	private
conf(const appmodel::DataHandlerModule *conf) override	dunedaq::trigger::TPProcessor	virtual
const_metric_counter_t typedef	dunedaq::opmonlib::MonitorableObject	private
const_time_counter_t typedef	dunedaq::opmonlib::MonitorableObject	private
consttpptr typedef	dunedaq::trigger::TPProcessor
ElementId typedef	dunedaq::opmonlib::MonitorableObject
facility_ptr_t typedef	dunedaq::opmonlib::MonitorableObject	private
find_ta(const TriggerPrimitiveTypeAdapter *tp, std::shared_ptr< triggeralgs::TriggerActivityMaker > tam)	dunedaq::trigger::TPProcessor	protected
generate_opmon_data() override	dunedaq::trigger::TPProcessor	virtual
get_last_daq_time() override	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	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::trigger::TPProcessor
invoke_all_preprocess_functions(TriggerPrimitiveTypeAdapter *item)	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >
launch_all_preprocess_functions(TriggerPrimitiveTypeAdapter *item)	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >
m_cpu_us_counter	dunedaq::opmonlib::MonitorableObject	mutableprivate
m_current_ts	dunedaq::trigger::TPProcessor	protected
m_error_counter	dunedaq::opmonlib::MonitorableObject	mutableprivate
m_error_registry	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_facility	dunedaq::opmonlib::MonitorableObject	private
m_ignored_counter	dunedaq::opmonlib::MonitorableObject	mutableprivate
m_items_to_postprocess_queues	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_last_processed_daq_ts	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_latency_in	dunedaq::trigger::TPProcessor	private
m_latency_instance	dunedaq::trigger::TPProcessor	private
m_latency_monitoring	dunedaq::trigger::TPProcessor	private
m_latency_out	dunedaq::trigger::TPProcessor	private
m_node_mutex	dunedaq::opmonlib::MonitorableObject	private
m_nodes	dunedaq::opmonlib::MonitorableObject	private
m_opmon_level	dunedaq::opmonlib::MonitorableObject	private
m_opmon_name	dunedaq::opmonlib::MonitorableObject	private
m_parent_id	dunedaq::opmonlib::MonitorableObject	private
m_post_process_functions	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_post_process_threads	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_post_processing_enabled	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_postprocess_queue_sizes	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_preprocess_functions	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_previous_ts	dunedaq::trigger::TPProcessor	protected
m_published_counter	dunedaq::opmonlib::MonitorableObject	mutableprivate
m_run_marker	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
m_running_flag	dunedaq::trigger::TPProcessor	private
m_sourceid	dunedaq::trigger::TPProcessor	private
m_ta_failed_sent_count	dunedaq::trigger::TPProcessor	private
m_ta_made_count	dunedaq::trigger::TPProcessor	private
m_ta_sent_count	dunedaq::trigger::TPProcessor	private
m_ta_sink	dunedaq::trigger::TPProcessor	private
m_tams	dunedaq::trigger::TPProcessor	private
m_tp_received_count	dunedaq::trigger::TPProcessor	private
metric_counter_t typedef	dunedaq::opmonlib::MonitorableObject	private
metric_counter_type typedef	dunedaq::trigger::TPProcessor	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< TriggerPrimitiveTypeAdapter >
operator=(RawDataProcessorConcept &&)=delete	dunedaq::datahandlinglibs::RawDataProcessorConcept< TriggerPrimitiveTypeAdapter >
dunedaq::opmonlib::MonitorableObject::operator=(const MonitorableObject &)=delete	dunedaq::opmonlib::MonitorableObject
dunedaq::opmonlib::MonitorableObject::operator=(MonitorableObject &&)=delete	dunedaq::opmonlib::MonitorableObject
postprocess_item(const TriggerPrimitiveTypeAdapter *item) override	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	virtual
preprocess_item(TriggerPrimitiveTypeAdapter *item) override	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	inlinevirtual
print_opmon_stats()	dunedaq::trigger::TPProcessor	private
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
RawDataProcessorConcept()	dunedaq::datahandlinglibs::RawDataProcessorConcept< TriggerPrimitiveTypeAdapter >	inline
RawDataProcessorConcept(const RawDataProcessorConcept &)=delete	dunedaq::datahandlinglibs::RawDataProcessorConcept< TriggerPrimitiveTypeAdapter >
RawDataProcessorConcept(RawDataProcessorConcept &&)=delete	dunedaq::datahandlinglibs::RawDataProcessorConcept< TriggerPrimitiveTypeAdapter >
register_node(ElementId name, NewNodePtr)	dunedaq::opmonlib::MonitorableObject	protected
reset_last_daq_time()	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	inline
run_post_processing_thread(std::function< void(const TriggerPrimitiveTypeAdapter *)> &function, folly::ProducerConsumerQueue< const TriggerPrimitiveTypeAdapter * > &queue)	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	protected
s_default_facility	dunedaq::opmonlib::MonitorableObject	privatestatic
scrap(const nlohmann::json &args) override	dunedaq::trigger::TPProcessor	virtual
set_opmon_level(OpMonLevel) noexcept	dunedaq::opmonlib::MonitorableObject	private
start(const nlohmann::json &args) override	dunedaq::trigger::TPProcessor	virtual
stop(const nlohmann::json &args) override	dunedaq::trigger::TPProcessor	virtual
TaskRawDataProcessorModel(std::unique_ptr< FrameErrorRegistry > &error_registry, bool post_processing_enabled)	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	inlineexplicit
time_counter_t typedef	dunedaq::opmonlib::MonitorableObject	private
TPProcessor(std::unique_ptr< datahandlinglibs::FrameErrorRegistry > &error_registry, bool post_processing_enabled)	dunedaq::trigger::TPProcessor	explicit
tpptr typedef	dunedaq::trigger::TPProcessor
~MonitorableObject()=default	dunedaq::opmonlib::MonitorableObject	virtual
~RawDataProcessorConcept()	dunedaq::datahandlinglibs::RawDataProcessorConcept< TriggerPrimitiveTypeAdapter >	inlinevirtual
~TaskRawDataProcessorModel()	dunedaq::datahandlinglibs::TaskRawDataProcessorModel< TriggerPrimitiveTypeAdapter >	inline
~TPProcessor()	dunedaq::trigger::TPProcessor