Struct PipelineStats 

pub struct PipelineStats {

    pub decode: PhaseTimer,
    pub demosaic: PhaseTimer,
    pub normalize: PhaseTimer,
    pub wb_hl_ccm: PhaseTimer,
    pub oetf: PhaseTimer,
    pub pack: PhaseTimer,
    pub gpu: PhaseTimer,
    pub encode_push: PhaseTimer,
    pub setup: PhaseTimer,
    pub finalize: PhaseTimer,
    pub frames_total: AtomicU64,
    pub gpu_frames: AtomicU64,
    pub encode_push_per_frame: Mutex<Vec<(u32, Duration)>>,
}

All phase timers for one pipeline run. Arc<PipelineStats> is shared across the loader / processor / writer threads.

Fields

decode: PhaseTimer

demosaic: PhaseTimer

normalize: PhaseTimer

wb_hl_ccm: PhaseTimer

oetf: PhaseTimer

pack: PhaseTimer

gpu: PhaseTimer

encode_push: PhaseTimer

setup: PhaseTimer

finalize: PhaseTimer

frames_total: AtomicU64

gpu_frames: AtomicU64

encode_push_per_frame: Mutex<Vec<(u32, Duration)>>

C5: per-frame encode_push timing ring. Lets us post-mortem any frame that took longer than the histogram resolution would capture (e.g. the 776ms / 1.5s spikes that ffmpeg’s B-frame lookahead produces on VBR). Writer is single-threaded, so the Mutex is uncontended.

Implementations

impl PipelineStats

pub fn new() -> Self

pub fn record_encode_push_frame(&self, frame_id: u32, d: Duration)

C5: record an encode_push duration tagged with the frame id. Updates the histogram-style encode_push PhaseTimer (so the existing summary line still has its avg/min/max/stddev) and appends (frame_id, duration) to the per-frame ring.

pub fn report(&self) -> StatsReport

Build a serializable report. Cheap to call (8 atomic loads).

Trait Implementations

impl Debug for PipelineStats

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PipelineStats

fn default() -> Self

Returns the “default value” for a type.