Class PipelineEventDispatcher

• Defined in File PipelineEventDispatcher.hpp

Nested Relationships

Nested Types

• Struct PipelineEventDispatcher::EventStatus

Inheritance Relationships

Base Type

• public dai::utility::PipelineEventDispatcherInterface (Class PipelineEventDispatcherInterface)

Class Documentation

class PipelineEventDispatcher : public dai::utility::PipelineEventDispatcherInterface

Public Functions

PipelineEventDispatcher() = delete

inline PipelineEventDispatcher(int64_t &nodeId, Node::Output *output)

virtual void startEvent(PipelineEvent::Type type, const std::string &source, std::optional<uint32_t> queueSize = std::nullopt) override

virtual void startInputEvent(const std::string &source, std::optional<uint32_t> queueSize = std::nullopt) override

virtual void startOutputEvent(const std::string &source) override

virtual void startCustomEvent(const std::string &source) override

virtual void endEvent(PipelineEvent::Type type, const std::string &source, std::optional<uint32_t> queueSize = std::nullopt) override

virtual void endInputEvent(const std::string &source, std::optional<uint32_t> queueSize = std::nullopt) override

virtual void endOutputEvent(const std::string &source) override

virtual void endCustomEvent(const std::string &source) override

virtual void startTrackedEvent(PipelineEvent event, std::optional<std::chrono::time_point<std::chrono::steady_clock>> ts = std::nullopt) override

virtual void startTrackedEvent(PipelineEvent::Type type, const std::string &source, int64_t sequenceNum, std::optional<std::chrono::time_point<std::chrono::steady_clock>> ts = std::nullopt) override

virtual void endTrackedEvent(PipelineEvent event, std::optional<std::chrono::time_point<std::chrono::steady_clock>> ts = std::nullopt) override

virtual void endTrackedEvent(PipelineEvent::Type type, const std::string &source, int64_t sequenceNum, std::optional<std::chrono::time_point<std::chrono::steady_clock>> ts = std::nullopt) override

virtual void pingEvent(PipelineEvent::Type type, const std::string &source) override

virtual void pingMainLoopEvent() override

virtual void pingCustomEvent(const std::string &source) override

virtual void pingInputEvent(const std::string &source, PipelineEvent::Status status, std::optional<uint32_t> queueSize = std::nullopt) override

virtual BlockPipelineEvent blockEvent(PipelineEvent::Type type, const std::string &source, std::optional<std::chrono::time_point<std::chrono::steady_clock>> ts = std::nullopt, bool startNow = true) override

virtual BlockPipelineEvent inputBlockEvent(bool startNow = true) override

virtual BlockPipelineEvent outputBlockEvent(bool startNow = true) override

virtual BlockPipelineEvent customBlockEvent(const std::string &source, bool startNow = true) override