State Struct

Per-stream internal state: queue, worker thread, and live counters. More...

Declaration

struct simaai::neat::graph::strict_sync::ReleasePacer::State { ... }

Public Member Attributes Index

std::mutex	mu
	Guards the per-stream state. More...
std::condition_variable	cv
	Condition variable used to signal queue state changes. More...
std::deque< simaai::neat::Sample >	queue
	Pending samples awaiting paced release. More...
std::thread	worker
	Per-stream pacing worker thread. More...
bool	stop = false
	Worker stop flag. More...
int64_t	next_release_ms = -1
	Wall-clock deadline (ms) for the next release. More...
int64_t	enqueued = 0
	Total samples enqueued. More...
int64_t	sent = 0
	Total samples successfully sent downstream. More...
int64_t	dropped = 0
	Total samples dropped due to overflow. More...
int64_t	send_fail = 0
	Total send attempts that failed. More...
int64_t	max_queue_depth = 0
	High-watermark of queue depth. More...

Description

Per-stream internal state: queue, worker thread, and live counters.

Definition at line 200 of file StrictSync.h.

Public Member Attributes

cv

std::condition_variable simaai::neat::graph::strict_sync::ReleasePacer::State::cv

Condition variable used to signal queue state changes.

Definition at line 202 of file StrictSync.h.

202 std::condition_variable cv;

dropped

int64_t simaai::neat::graph::strict_sync::ReleasePacer::State::dropped = 0

Total samples dropped due to overflow.

Definition at line 210 of file StrictSync.h.

210 int64_t dropped = 0;

enqueued

int64_t simaai::neat::graph::strict_sync::ReleasePacer::State::enqueued = 0

Total samples enqueued.

Definition at line 208 of file StrictSync.h.

208 int64_t enqueued = 0;

max_queue_depth

int64_t simaai::neat::graph::strict_sync::ReleasePacer::State::max_queue_depth = 0

High-watermark of queue depth.

Definition at line 212 of file StrictSync.h.

212 int64_t max_queue_depth = 0;

mu

std::mutex simaai::neat::graph::strict_sync::ReleasePacer::State::mu

mutable

Guards the per-stream state.

Definition at line 201 of file StrictSync.h.

201 mutable std::mutex mu;

next_release_ms

int64_t simaai::neat::graph::strict_sync::ReleasePacer::State::next_release_ms = -1

Wall-clock deadline (ms) for the next release.

Definition at line 207 of file StrictSync.h.

207 int64_t next_release_ms = -1;

queue

std::deque<simaai::neat::Sample> simaai::neat::graph::strict_sync::ReleasePacer::State::queue

Pending samples awaiting paced release.

Definition at line 203 of file StrictSync.h.

203 std::deque<simaai::neat::Sample> queue;

send_fail

int64_t simaai::neat::graph::strict_sync::ReleasePacer::State::send_fail = 0

Total send attempts that failed.

Definition at line 211 of file StrictSync.h.

211 int64_t send_fail = 0;

sent

int64_t simaai::neat::graph::strict_sync::ReleasePacer::State::sent = 0

Total samples successfully sent downstream.

Definition at line 209 of file StrictSync.h.

209 int64_t sent = 0;

stop

bool simaai::neat::graph::strict_sync::ReleasePacer::State::stop = false

Worker stop flag.

Definition at line 205 of file StrictSync.h.

205 bool stop = false;

worker

std::thread simaai::neat::graph::strict_sync::ReleasePacer::State::worker

Per-stream pacing worker thread.

Definition at line 204 of file StrictSync.h.

204 std::thread worker;

---

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

• StrictSync.h

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.