Skip to main content

StampFrameId Class

Stage executor that assigns a monotonically-increasing frame id per stream. More...

Declaration

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

Included Headers

#include <StampFrameId.h>

Base class

classStageExecutor

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

Public Member Functions Index

voidset_ports (const StagePorts &ports) override

Bind the executor to its runtime ports. More...

voidon_input (StageMsg &&msg, std::vector< StageOutMsg > &out) override

Stamp the next per-stream frame id onto the incoming sample if it doesn't already have one. More...

Private Member Attributes Index

std::unordered_map< std::string, std::int64_t >next_id_
PortIdout_port_ = kInvalidPort

Description

Stage executor that assigns a monotonically-increasing frame id per stream.

For samples lacking a frame id the executor stamps the next id available for that stream. Used for telemetry, debugging, and as a stable key for downstream joins.

See Also

StampFrameIdNode

See Also

StageExecutor

Definition at line 30 of file StampFrameId.h.

Public Member Functions

on_input()

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

Stamp the next per-stream frame id onto the incoming sample if it doesn't already have one.

Definition at line 35 of file StampFrameId.h.

set_ports()

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

Bind the executor to its runtime ports.

Definition at line 33 of file StampFrameId.h.

Private Member Attributes

next_id_

std::unordered_map<std::string, std::int64_t> simaai::neat::graph::nodes::StampFrameId::next_id_

Definition at line 38 of file StampFrameId.h.

38 std::unordered_map<std::string, std::int64_t> next_id_;

out_port_

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

Definition at line 39 of file StampFrameId.h.

39 PortId out_port_ = kInvalidPort;

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


Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.