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

test(ecstore): drain expiry workers before restart (#7923)

Browse Source
This commit is contained in:
cxymds
2026-09-16 07:59:01 +08:00
committed by GitHub
parent a708820cda
commit 3d3debf938
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/store/init.rs
+9 -2
View File
@@ -2981,8 +2981,15 @@ mod tests {
assert!(backend.contains(&remote).await, "commit must not delete remote bytes before cleanup");
let removed_before = backend.remove_count().await;
// Restart before queue delivery. The new runtime must
// reconstruct ownership solely from the committed xl.meta.
// Later matrix cases reuse this restarted store. If its
// expiry worker has already dequeued this failed cleanup,
// drain it before cancelling the context so the next
// store cannot inherit object locks that block recovery.
wait_for_expiry_workers_idle(&store).await;
// Restart after the failed cleanup attempt. The new
// runtime must reconstruct ownership from committed
// xl.meta regardless of whether the old queue delivered it.
let tier_config = ctx
.tier_config_mgr()
.read()