gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-10-03 20:20:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(ecstore): isolate dispatch shutdown recovery fixtures (#8265)

Browse Source
This commit is contained in:
Chris
2026-09-30 15:56:48 +08:00
committed by GitHub
parent 5c3a2ff277
commit 099a408d8b
1 changed files with 22 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/store/init.rs
+22 -5
View File
@@ -11176,9 +11176,17 @@ mod tests {
const ADMITTED_READS: usize = 32;
let temp_dir = tempfile::tempdir().expect("create validation-read shutdown store dir");
let (ctx, store, shutdown) =
without_storage_class_env(build_isolated_test_store(temp_dir.path(), "dispatch-validation-read-shutdown", &[4]))
.await;
// The manual worker must own the seeded records and shutdown progress.
let mut instance_ctx = crate::runtime::instance::InstanceContext::new();
instance_ctx.suppress_tier_delete_journal_recovery_for_test();
let (ctx, store, shutdown) = without_storage_class_env(build_isolated_test_store_with_layout(
temp_dir.path(),
"dispatch-validation-read-shutdown",
&[(1, 4)],
CancellationToken::new(),
Some(Arc::new(instance_ctx)),
))
.await;
crate::bucket::metadata_sys::init_bucket_metadata_sys(store.clone(), Vec::new()).await;
let bucket = "dispatch-validation-read-shutdown-bucket";
store
@@ -11710,8 +11718,17 @@ mod tests {
const ADMITTED_BATCH: usize = 32;
let temp_dir = tempfile::tempdir().expect("create delete-batch shutdown store dir");
let (ctx, store, shutdown) =
without_storage_class_env(build_isolated_test_store(temp_dir.path(), "dispatch-delete-batch-shutdown", &[4])).await;
// The manual worker must own the seeded records and shutdown progress.
let mut instance_ctx = crate::runtime::instance::InstanceContext::new();
instance_ctx.suppress_tier_delete_journal_recovery_for_test();
let (ctx, store, shutdown) = without_storage_class_env(build_isolated_test_store_with_layout(
temp_dir.path(),
"dispatch-delete-batch-shutdown",
&[(1, 4)],
CancellationToken::new(),
Some(Arc::new(instance_ctx)),
))
.await;
crate::bucket::metadata_sys::init_bucket_metadata_sys(store.clone(), Vec::new()).await;
let bucket = "dispatch-delete-batch-shutdown-bucket";
store