Struct RecordingSink 

pub struct RecordingSink { /* private fields */ }

Unix-socket fan-out that broadcasts every encoded H.264 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) -> 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, signalling 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_height: i32)

Delivery-layer tap for one encoded frame. The socket carries a single H.264 elementary stream, so only a lone full-height stripe (data_type == 2) 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 10-byte wire header (0x04 tag) is skipped via the queued offset so consumers receive plain Annex-B.

Never blocks and never copies: the Arc payload 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.