JoinEncodedWithMeta Class

Stage executor that bundles an encoded payload (e.g., H.264) with associated metadata. More...

Declaration

class simaai::neat::graph::nodes::JoinEncodedWithMeta { ... }

Included Headers

#include <JoinEncodedWithMeta.h>

Base class

class	StageExecutor
	Actor-style executor base class — implement to add a new runtime-graph stage. More...

Public Constructors Index

	JoinEncodedWithMeta (JoinEncodedWithMetaOptions opt)
	Construct a JoinEncodedWithMeta from the given options. More...

Public Member Functions Index

void	set_ports (const StagePorts &ports) override
	Bind the executor to its runtime ports. More...
void	on_input (StageMsg &&msg, std::vector< StageOutMsg > &out) override
	Match the incoming sample against pending entries and emit a bundle when ready. More...
void	on_tick (std::int64_t now_ns, std::vector< StageOutMsg > &out) override
	Periodic tick used to evict stale pending entries. More...

Private Member Functions Index

std::string	make_key_ (const Sample &sample) const
bool	is_encoded_ (PortId port, const Sample &sample) const
std::string	field_name_ (PortId port, const Sample &sample, bool encoded) const
void	evict_if_needed_ ()

Private Member Attributes Index

JoinEncodedWithMetaOptions	opt_
std::unordered_map< std::string, std::unordered_map< PortId, Sample > >	pending_
std::deque< std::string >	order_
PortId	out_port_ = kInvalidPort

Description

Stage executor that bundles an encoded payload (e.g., H.264) with associated metadata.

Specialised join used by detection pipelines that overlay model results onto an encoded stream: pairs each encoded buffer with the matching metadata sample (e.g., GstSimaMeta detection results) keyed by stream/frame and emits a bundle.

See Also

JoinEncodedWithMetaNode

See Also

StageExecutor

Definition at line 54 of file JoinEncodedWithMeta.h.

Public Constructors

JoinEncodedWithMeta()

simaai::neat::graph::nodes::JoinEncodedWithMeta::JoinEncodedWithMeta (JoinEncodedWithMetaOptions opt)

explicit

Construct a JoinEncodedWithMeta from the given options.

Definition at line 57 of file JoinEncodedWithMeta.h.

Public Member Functions

on_input()

void simaai::neat::graph::nodes::JoinEncodedWithMeta::on_input (StageMsg && msg, std::vector< StageOutMsg > & out)

virtual

Match the incoming sample against pending entries and emit a bundle when ready.

Definition at line 62 of file JoinEncodedWithMeta.h.

on_tick()

void simaai::neat::graph::nodes::JoinEncodedWithMeta::on_tick (std::int64_t now_ns, std::vector< StageOutMsg > & out)

virtual

Periodic tick used to evict stale pending entries.

Definition at line 64 of file JoinEncodedWithMeta.h.

set_ports()

void simaai::neat::graph::nodes::JoinEncodedWithMeta::set_ports (const StagePorts & ports)

virtual

Bind the executor to its runtime ports.

Definition at line 60 of file JoinEncodedWithMeta.h.

Private Member Functions

evict_if_needed_()

void simaai::neat::graph::nodes::JoinEncodedWithMeta::evict_if_needed_ ()

Definition at line 70 of file JoinEncodedWithMeta.h.

field_name_()

std::string simaai::neat::graph::nodes::JoinEncodedWithMeta::field_name_ (PortId port, const Sample & sample, bool encoded)

Definition at line 69 of file JoinEncodedWithMeta.h.

is_encoded_()

bool simaai::neat::graph::nodes::JoinEncodedWithMeta::is_encoded_ (PortId port, const Sample & sample)

Definition at line 68 of file JoinEncodedWithMeta.h.

make_key_()

std::string simaai::neat::graph::nodes::JoinEncodedWithMeta::make_key_ (const Sample & sample)

Definition at line 67 of file JoinEncodedWithMeta.h.

Private Member Attributes

opt_

JoinEncodedWithMetaOptions simaai::neat::graph::nodes::JoinEncodedWithMeta::opt_

Definition at line 72 of file JoinEncodedWithMeta.h.

72 JoinEncodedWithMetaOptions opt_;

order_

std::deque<std::string> simaai::neat::graph::nodes::JoinEncodedWithMeta::order_

Definition at line 74 of file JoinEncodedWithMeta.h.

74 std::deque<std::string> order_;

out_port_

PortId simaai::neat::graph::nodes::JoinEncodedWithMeta::out_port_ = kInvalidPort

Definition at line 75 of file JoinEncodedWithMeta.h.

75 PortId out_port_ = kInvalidPort;

pending_

std::unordered_map<std::string, std::unordered_map<PortId, Sample> > simaai::neat::graph::nodes::JoinEncodedWithMeta::pending_

Definition at line 73 of file JoinEncodedWithMeta.h.

73 std::unordered_map<std::string, std::unordered_map<PortId, Sample>> pending_;

---

The documentation for this class was generated from the following file:

• JoinEncodedWithMeta.h

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.