gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-27 15:37:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(ecstore): satisfy multipart barrier lint

Browse Source
This commit is contained in:
马登山
2026-07-29 13:36:10 +08:00
parent 7ac419fe39
commit 1ae87c5990
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/set_disk/ops/multipart.rs
+13 -13
View File
@@ -137,21 +137,21 @@ async fn pause_multipart_commit(bucket: &str, object: &str, pause: MultipartComm
.as_ref() .as_ref()
.filter(|barrier| barrier.bucket == bucket && barrier.object == object && barrier.pause == pause) .filter(|barrier| barrier.bucket == bucket && barrier.object == object && barrier.pause == pause)
.cloned(); .cloned();
if let Some(barrier) = barrier { if let Some(barrier) = barrier
if let Ok(previous) = barrier.arrivals.fetch_update(Ordering::AcqRel, Ordering::Acquire, |current| { && let Ok(previous) = barrier.arrivals.fetch_update(Ordering::AcqRel, Ordering::Acquire, |current| {
(current < barrier.expected_arrivals).then_some(current + 1) (current < barrier.expected_arrivals).then_some(current + 1)
}) { })
let arrival = previous + 1; {
if arrival == barrier.expected_arrivals { let arrival = previous + 1;
barrier.arrived.notify_one(); if arrival == barrier.expected_arrivals {
} barrier.arrived.notify_one();
barrier
.release
.acquire()
.await
.expect("multipart commit barrier should remain open")
.forget();
} }
barrier
.release
.acquire()
.await
.expect("multipart commit barrier should remain open")
.forget();
} }
} }