Function validate_prepared_update_gate

xtask/src/main.rs:2699–2737

(report: &PreparedUpdateReport)

}

fn validate_prepared_update_gate(report: &PreparedUpdateReport) -> Result<()> {
    let scale = report.rows as f64 / 25_000_f64;
    for run in &report.runs {
        let Some(base_limit_micros) = prepared_update_limit_micros(run.mode) else {
            continue;
        };
        let limit = (base_limit_micros as f64 * scale).ceil() as u128;
        for test in &run.tests {
            ensure!(
                test.elapsed_micros <= limit,
                "prepared-update gate failed for {} {}: {:.3}ms > {:.3}ms",
                run.mode,
                test.id,
                test.elapsed_micros as f64 / 1_000.0,
                limit as f64 / 1_000.0
            );
        }
        if let Some(stats) = run.protocol_stats.as_ref() {
            ensure!(
                stats.streaming_copy_handoffs == 0,
                "prepared-update gate failed for {}: non-COPY traffic used streaming handoff",
                run.mode
            );
        }
        if run.mode.contains("pipelined") {
            let stats = run
                .protocol_stats
                .as_ref()
                .context("missing protocol stats for pipelined prepared-update run")?;
            ensure!(
                stats.protocol_batches < 1_000,
                "prepared-update gate failed for {}: pipelined traffic was not batched ({} protocol batches)",
                run.mode,
                stats.protocol_batches
            );
        }
    }
    Ok(())
}

fn prepared_update_limit_micros(mode: &str) -> Option<u128> {
    if mode.starts_with("native_") {