gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-09-20 01:25:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: keep top locks within its capture window (#7888)

Browse Source
This commit is contained in:
Chris
2026-09-15 03:11:22 +08:00
committed by GitHub
parent a8302b511c
commit 7a37271bc0
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/src/connect/diagnostics/top_locks.rs
+4 -2
View File
@@ -47,12 +47,14 @@ pub async fn capture_top_locks(
let Some(_permit) = request.acquire(cancel).await? else {
return request.cancelled(TOOL_ID);
};
let started = tokio::time::Instant::now();
if !request.wait_window(TOOL_ID, cancel).await? {
return request.cancelled(TOOL_ID);
}
let (held_count, waiting_count) = manager.current_lock_counts();
let duration_millis = u64::try_from(started.elapsed().as_millis()).unwrap_or(u64::MAX).max(1);
// Report the admitted capture window. Scheduler wake-up jitter is not part
// of the measurement and must not turn an exactly bounded job into a
// LIMIT_EXCEEDED result.
let duration_millis = u64::try_from(request.window.as_millis()).unwrap_or(u64::MAX).max(1);
evaluate_lock_snapshot(request, held_count, waiting_count, duration_millis)
}