Method next_frame

rustcv-backend-msmf/src/stream.rs:495–518

Waits for and returns the next available frame. This method uses a semaphore to efficiently wait for new frames without busy-waiting.

(&mut self)

    /// This method uses a semaphore to efficiently wait for new frames
    /// without busy-waiting.
    async fn next_frame(&mut self) -> Result<Frame<'_>> {
        let sample = self.wait_for_sample().await?;
        let ts_raw = self.shared.timestamp.load(Ordering::Acquire);

        self.copy_sample_to_linear_buffer(&sample.0)?;

        self.sequence += 1;
        let hw_ns = (ts_raw as u64) * 100;

        Ok(Frame {
            data: &self.linear_buffer,
            width: self.width,
            height: self.height,
            stride: self.line_width_bytes,
            format: self.format,
            sequence: self.sequence,
            timestamp: Timestamp {
                hw_raw_ns: hw_ns,
                system_synced: self.clock_sync.correct(hw_ns, Instant::now()),
            },
            metadata: FrameMetadata::default(),
            backend_handle: &MSMF_HANDLE_INSTANCE,
        })
    }
}

impl MsmfStream {