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

Fix: clippy && fmt

Browse Source 
Signed-off-by: junxiang Mu <1948535941@qq.com>
This commit is contained in:
junxiang Mu
2025-08-09 21:16:56 +08:00
parent 4811632751
commit b7e56ed92c
2 changed files with 9 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/lock/src/guard.rs
+8 -9
View File
@@ -106,16 +106,15 @@ impl Drop for LockGuard {
tracing::warn!("LockGuard channel send failed ({}), spawning fallback unlock task for {}", err, lock_id); tracing::warn!("LockGuard channel send failed ({}), spawning fallback unlock task for {}", err, lock_id);
// If runtime is not available, this will panic; but in RustFS we are inside Tokio contexts. // If runtime is not available, this will panic; but in RustFS we are inside Tokio contexts.
let _ = tokio::spawn(async move { let handle = tokio::spawn(async move {
let futures = clients let futures_iter = clients.into_iter().map(|client| {
.into_iter() let id = lock_id.clone();
.map(|client| { async move { client.release(&id).await.unwrap_or(false) }
let id = lock_id.clone(); });
async move { client.release(&id).await.unwrap_or(false) } let _ = futures::future::join_all(futures_iter).await;
})
.collect::<Vec<_>>();
let _ = futures::future::join_all(futures).await;
}); });
// Explicitly drop the JoinHandle to acknowledge detaching the task.
std::mem::drop(handle);
} }
} }
} }
crates/lock/src/local.rs
+1 -7
View File
@@ -97,13 +97,7 @@ impl LocalLockMap {
guard.remove(&k); guard.remove(&k);
} }
let wait = if due.is_empty() { let wait = if due.is_empty() {
next_deadline.and_then(|dl| { next_deadline.map(|dl| if dl > now { dl - now } else { Duration::from_millis(0) })
if dl > now {
Some(dl - now)
} else {
Some(Duration::from_millis(0))
}
})
} else { } else {
Some(Duration::from_millis(0)) Some(Duration::from_millis(0))
}; };