pq/libfreemkv
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: remove stale sweep_pipeline.rs cross-references in patch.rs comments

Browse Source
This commit is contained in:
Matthew Jackson
2026-06-24 04:52:04 -07:00
parent 95b9762c51
commit 06ee748689
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/disc/patch.rs
+2 -4
View File
@@ -213,9 +213,8 @@ impl PatchSink {
// writes; contention is single-acquire so the lock is never // writes; contention is single-acquire so the lock is never
// poisoned in practice. If it ever did get poisoned we'd want // poisoned in practice. If it ever did get poisoned we'd want
// the underlying error surfaced rather than silently swallowed, // the underlying error surfaced rather than silently swallowed,
// so we propagate the poison panic. (Same posture as // so we propagate the poison panic rather than silently
// `sweep_pipeline.rs` — it never recovers from a poisoned // continuing with stale shared state.
// mutex either.)
let mut guard = self let mut guard = self
.shared .shared
.lock() .lock()
@@ -370,7 +369,6 @@ pub(super) fn skip_sectors_for_probe(idx: usize) -> u64 {
/// Send a `PatchItem` and translate a `SendError` (consumer thread died /// Send a `PatchItem` and translate a `SendError` (consumer thread died
/// / panicked) into a library error so the caller propagates cleanly. /// / panicked) into a library error so the caller propagates cleanly.
/// Mirrors `sweep_pipeline.rs`'s `send_or_abort`.
pub(super) fn send_or_abort( pub(super) fn send_or_abort(
pipe: &Pipeline<PatchItem, PatchSummary>, pipe: &Pipeline<PatchItem, PatchSummary>,
item: PatchItem, item: PatchItem,