Struct MtpGate 

pub struct MtpGate { /* private fields */ }

2026-09-25: The gate. The scheduler builds one when MTP is on and the gate is not forced off, and records each gated plain-decode or MTP step in it; steps run under a pin are not recorded.

Implementations

impl MtpGate

pub fn observe(&self) -> (MtpModeSnap, f32)

2026-09-25: For the scheduler snapshot: the mode (Probing during a probe) and the delivered-throughput estimate of the current mode (0.0 until measured).

pub fn new(num_drafts: usize) -> Self

2026-09-25: Starts in Mtp mode. num_drafts is only logged; arbitration does not model the draft count.

pub fn note_depth(&mut self, depth: usize)

pub fn maybe_remeasure(&mut self, current_depth: usize) -> bool

2026-09-25: When the context depth has moved by REMEASURE_DEPTH_FACTOR since the last measurement (both floored at REMEASURE_DEPTH_FLOOR), marks both estimates stale, keeps them as they are, and brings the next probe (one WINDOW_STEPS window) forward. Returns whether it fired.

pub fn take_fresh_decision(&mut self) -> Option<GateDecision>

2026-09-25: The last mode switch, returned once.

pub fn next_step(&self) -> GateStep

2026-09-25: Which step the scheduler should run next.

pub fn record_decode(&mut self, wall: Duration, width: usize)

2026-09-25: Records one plain decode step over width sequences. Each emits one token, so the step is charged width tokens (at least 1).

pub fn record_verify_step( &mut self, wall: Duration, emitted: usize, width: usize, )

2026-09-25: Records one MTP step over width sequences: emitted is the tokens all of them committed (at least 1 is charged). Bootstrap and propose time count against Mtp mode.

impl MtpGate

pub fn mtp_tps_debug(&self) -> Option<f64>

pub fn serial_tps_debug(&self) -> Option<f64>

pub fn in_serial_mode(&self) -> bool

pub fn regime_reprobe_count(&self) -> usize

pub fn is_probing(&self) -> bool