From 90ab00ed45bb83b3cf6bc4fb4e08918cef98e4fe Mon Sep 17 00:00:00 2001 From: MattJackson <1085847+MattJackson@users.noreply.github.com> Date: Sat, 9 May 2026 10:36:40 -0700 Subject: [PATCH] 0.18 round 2: cargo fmt after sweep+patch+DiscStream merge Auto-fmt nit on the multi-line map.flush() expression that landed when the sweep + patch + DiscStream-FrameSource branches were merged together. No semantic change. --- src/disc/patch.rs | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/src/disc/patch.rs b/src/disc/patch.rs index a1171d6..5a6c3f8 100644 --- a/src/disc/patch.rs +++ b/src/disc/patch.rs @@ -142,7 +142,8 @@ impl PatchSink { map: Mapfile, is_regular: bool, ) -> Result<(Self, Arc>)> { - let file = crate::io::WritebackFile::open(path).map_err(|e| Error::IoError { source: e })?; + let file = + crate::io::WritebackFile::open(path).map_err(|e| Error::IoError { source: e })?; let shared = Arc::new(Mutex::new(SharedPatchState::from_map(&map))); let shared_clone = shared.clone(); Ok(( @@ -164,7 +165,10 @@ impl PatchSink { // so we propagate the poison panic. (Same posture as // `sweep_pipeline.rs` — it never recovers from a poisoned // mutex either.) - let mut guard = self.shared.lock().expect("PatchSink shared state mutex poisoned"); + let mut guard = self + .shared + .lock() + .expect("PatchSink shared state mutex poisoned"); *guard = SharedPatchState::from_map(&self.map); } } @@ -224,9 +228,7 @@ impl Sink for PatchSink { "patch: sync_all failed for non-regular file; ignoring" ); } - self.map - .flush() - .map_err(|e| Error::IoError { source: e })?; + self.map.flush().map_err(|e| Error::IoError { source: e })?; // Final republish so anyone reading the shared snapshot after // `Pipeline::finish` sees the post-flush state. (The producer // already has its own copy of the final `MapStats` in the