Struct InnerQDriver 

pub struct InnerQDriver {
    pub target_tokens: i32,
    pub strength: f32,
    pub calibrating: AtomicBool,
    pub finalized: AtomicBool,
    /* private fields */
}

Fields

target_tokens: i32

strength: f32

calibrating: AtomicBool

finalized: AtomicBool

Implementations

impl InnerQDriver

pub fn from_env(registry: Arc<MetraleRegistry>) -> Option<Self>

2026-09-25: Reads TURBO_INNERQ and TURBO_INNERQ_STRENGTH. Returns None if TURBO_INNERQ is unset, not an i32, or <= 0. A strength outside (0, 1] or unparsable is 0.5.

pub fn start(&self) -> Result<()>

2026-09-25: Enters calibration: zeroes d_innerq_sq_accum, d_innerq_count and d_innerq_active, sets d_innerq_calibrating = 1, and resets the host flags. Calling it again gives the same state.

pub fn maybe_finalize(&self, group_size: i32) -> Result<bool>

2026-09-25: Polls d_innerq_count. Once it reaches target_tokens, reads d_innerq_sq_accum, computes per-channel scale/scale_inv, uploads them and sets d_innerq_active = 1. Returns Ok(true) on the call that activates and Ok(false) otherwise, including when the channels are already balanced and nothing is uploaded. Errors when group_size is outside 1..=MAX_CHANNELS or larger than a symbol.