From 993333faccf9440a93192d7e70ac6fef3b450457 Mon Sep 17 00:00:00 2001 From: Jeroen Schweitzer Date: Fri, 12 Jun 2026 13:48:53 +0200 Subject: [PATCH] =?UTF-8?q?style(engine):=20rustfmt=20=E2=80=94=20wrap=20l?= =?UTF-8?q?ong=20lines=20in=20bridge=5Ftcp=20test=20+=20chunk=5Fcontext=20?= =?UTF-8?q?gate=20(gate=20fixup)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Fable 5 --- server/src/atlas/chunk_context.rs | 8 ++++---- server/tests/bridge_tcp.rs | 4 +++- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/server/src/atlas/chunk_context.rs b/server/src/atlas/chunk_context.rs index 9ba5dedd2..5a1692899 100644 --- a/server/src/atlas/chunk_context.rs +++ b/server/src/atlas/chunk_context.rs @@ -235,10 +235,10 @@ pub fn derive_chunk_context( let wavelength_i = (meander_wavelength_m as i32).max(10); let amplitude_max = (wavelength_i / 4).max(3); let edge_max = (channel_width / 2).max(2) + 3; // half-width + max edge jitter - // Floor: the BraidedDelta belt reaches anchor ±(32 thread-centre + 4 - // thread-half) before warp regardless of wavelength — the band must - // cover it even at the short-wavelength extreme (costs ≤4 m of extra - // gate generosity for the other families). + // Floor: the BraidedDelta belt reaches anchor ±(32 thread-centre + 4 + // thread-half) before warp regardless of wavelength — the band must + // cover it even at the short-wavelength extreme (costs ≤4 m of extra + // gate generosity for the other families). let reach = (amplitude_max + edge_max + LEVEE_BAND_MAX_M).max(32 + 4) + WARP_BOUND_M; let cross_lo = cross_chunk * CHUNK_M; let cross_hi = cross_lo + CHUNK_M - 1; diff --git a/server/tests/bridge_tcp.rs b/server/tests/bridge_tcp.rs index eafa07e01..079e3a565 100644 --- a/server/tests/bridge_tcp.rs +++ b/server/tests/bridge_tcp.rs @@ -222,7 +222,9 @@ fn tcp_bridge_eof_mid_frame_escalates_to_disconnected() { // Client: write 2 of the 4 length-prefix bytes, then die. use std::io::Write; let mut stream = TcpStream::connect(server_addr).expect("failed to connect"); - stream.write_all(&[0x00, 0x00]).expect("partial write failed"); + stream + .write_all(&[0x00, 0x00]) + .expect("partial write failed"); stream.flush().expect("flush failed"); thread::sleep(std::time::Duration::from_millis(50)); drop(stream);