Struct RecordingSink 

pub struct RecordingSink { /* private fields */ }

Unix-socket fan-out that broadcasts every encoded video frame to connected consumers.

A listener thread accepts connections and gives each its own bounded queue and writer thread (see [ClientHandle]) so one slow reader cannot stall the others or the encode thread.

Implementations

impl RecordingSink

pub fn try_bind(settings_path: &str, fps: f64) -> Option<Arc<Self>>

Bind a Unix socket at settings_path, or return None when no path is configured or the bind fails. Recording is an optional tap that must never take the pipeline down, so a bind error is logged and swallowed.

pub fn should_force_idr(&self) -> bool

Returns true exactly once after a new client connects, signaling that the next encode should produce an IDR so the consumer starts from a clean reference frame.

pub fn write_frame( &self, stripes: &[EncodedStripe], full_width: i32, full_height: i32, )

Delivery-layer tap for one encoded frame. The socket carries a single elementary stream, so only a lone full-height video stripe is recordable: striped CPU encodes are N independent per-stripe streams, and interleaving them would produce an undecodable file — those are skipped with a one-time notice (live streaming is unaffected). The wire header is skipped via the queued offset, and the container bytes the codec’s stream needs are prefixed per client: an IVF file header on a VP8/VP9 client’s first frame and an IVF frame header on every one, a temporal delimiter ahead of an AV1 unit that lacks one.

Never blocks and never copies the payload: the Arc is cloned into each client’s bounded queue with try_send, and a client whose queue is full or whose writer died is dropped.

Trait Implementations

impl Drop for RecordingSink

fn drop(&mut self)

Stop accepting, release every writer thread (set each stop, then drop its sender so an idle writer parked on rx.iter() wakes), and remove the socket file.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.