style: 自动格式化

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}");
     }
 

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}");
                                     }

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}");
     }