Skip to main content

PendingVideoStore Class

Per-stream store of video frames awaiting their matching detection metadata. More...

Declaration​

class simaai::neat::graph::strict_sync::PendingVideoStore { ... }

Included Headers​

#include <StrictSync.h>

Public Constructors Index​

PendingVideoStore (size_t streams)

Create a store sized for streams distinct stream slots. More...

Public Member Functions Index​

boolenqueue (size_t idx, int64_t frame_id, simaai::neat::Sample &&sample, int64_t cap_ms, size_t bytes)

Enqueue a frame under (idx, frame_id). Returns false if the slot is full or duplicate. More...

std::optional< PendingFrame >take (size_t idx, int64_t frame_id)

Take the frame stored under (idx, frame_id) if present. More...

StreamStatsstats (size_t idx) const

Snapshot of the per-stream stats. More...

Private Member Attributes Index​

std::vector< StreamState >states_

Description​

Per-stream store of video frames awaiting their matching detection metadata.

Used by strict-sync detection pipelines: video frames are enqueued by frame_id, then take() pulls the frame back when matching metadata arrives so it can be paired and forwarded together. Tracks per-stream queue depth, byte usage, and hit/miss counts.

See Also

YoloTokenStore

See Also

ReleasePacer

Definition at line 38 of file StrictSync.h.

Public Constructors​

PendingVideoStore()​

simaai::neat::graph::strict_sync::PendingVideoStore::PendingVideoStore (size_t streams)
 explicit

Create a store sized for streams distinct stream slots.

Definition at line 59 of file StrictSync.h.

Public Member Functions​

enqueue()​

bool simaai::neat::graph::strict_sync::PendingVideoStore::enqueue (size_t idx, int64_t frame_id, simaai::neat::Sample && sample, int64_t cap_ms, size_t bytes)

Enqueue a frame under (idx, frame_id). Returns false if the slot is full or duplicate.

Definition at line 62 of file StrictSync.h.

stats()​

StreamStats simaai::neat::graph::strict_sync::PendingVideoStore::stats (size_t idx)

Snapshot of the per-stream stats.

Definition at line 69 of file StrictSync.h.

take()​

std::optional< PendingFrame > simaai::neat::graph::strict_sync::PendingVideoStore::take (size_t idx, int64_t frame_id)

Take the frame stored under (idx, frame_id) if present.

Definition at line 66 of file StrictSync.h.

Private Member Attributes​

states_​

std::vector<StreamState> simaai::neat::graph::strict_sync::PendingVideoStore::states_

Definition at line 81 of file StrictSync.h.

81 std::vector<StreamState> states_;

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

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.