diff --git a/crates/oxide_test262/src/config.rs b/crates/oxide_test262/src/config.rs index 5ff63819..7ac9490b 100644 --- a/crates/oxide_test262/src/config.rs +++ b/crates/oxide_test262/src/config.rs @@ -158,7 +158,8 @@ mod tests { assert!(cfg.worker, "worker 旗标应置位"); assert!(!cfg.supervise, "supervise 旗标不应置位"); - let err = RunConfig::parse(&args(&["--worker", "--supervise"])).expect_err("worker+supervise must be exclusive"); + let err = + RunConfig::parse(&args(&["--worker", "--supervise"])).expect_err("worker+supervise must be exclusive"); assert!(err.contains("mutually exclusive"), "应提示互斥:{err}"); } diff --git a/crates/oxide_test262/src/main.rs b/crates/oxide_test262/src/main.rs index 335bee61..a638de0a 100644 --- a/crates/oxide_test262/src/main.rs +++ b/crates/oxide_test262/src/main.rs @@ -93,9 +93,7 @@ struct WorkerParams { /// kernel 重建与批内 sweep 时机与并行模式逐位一致(每 `kernel_batch` 测试重建, /// 批内每 500 测试 sweep)。 fn run_worker_window( - start: usize, - end: usize, - params: &WorkerParams, + start: usize, end: usize, params: &WorkerParams, on_heartbeat: &mut impl FnMut(usize, &TestResult, &RunStats) -> usize, ) -> RunStats { let mut engine = build_runner_engine(); @@ -380,7 +378,8 @@ fn run_tests() -> bool { if let TestOutcome::Fail(msg) = &result.outcome { // 旁路行携带真 subkey,父进程并入 fail_records 后直接生效 subkey 分组。 let (cat, subkey) = categorize_fail(msg); - if let Err(e) = append_fail_log(&hb.with_extension("fails"), i, &cat, &subkey, msg) { + if let Err(e) = append_fail_log(&hb.with_extension("fails"), i, &cat, &subkey, msg) + { errors += 1; eprintln!(" [warn] fail log append failed at #{i}: {e}"); } diff --git a/crates/oxide_test262/src/worker.rs b/crates/oxide_test262/src/worker.rs index 409959cc..94d79571 100644 --- a/crates/oxide_test262/src/worker.rs +++ b/crates/oxide_test262/src/worker.rs @@ -71,7 +71,12 @@ pub(crate) fn run_worker(config: &RunConfig) -> bool { loop { match reader.read_frame() { Ok(Some(frame)) => match parse_command(&frame) { - Ok(ShardCommand::Assign { wstart, wend: _, paths, timeout_secs: _ }) => { + Ok(ShardCommand::Assign { + wstart, + wend: _, + paths, + timeout_secs: _, + }) => { let _ = watchdog_tx.send(ChannelMsg::Assign(AssignWindow { wstart, paths })); } Ok(ShardCommand::Kill) => { @@ -222,7 +227,10 @@ fn send_scene_frame(conn: &mut Conn) { if last.is_empty() { return; } - let event = ShardEvent::Scene { line: last.to_string(), log_tail: None }; + let event = ShardEvent::Scene { + line: last.to_string(), + log_tail: None, + }; if let Err(e) = send_event_frame(conn, &event) { eprintln!("worker: failed to send scene frame: {e}"); }