diff --git a/crates/ecstore/src/core/pools.rs b/crates/ecstore/src/core/pools.rs index 371585798..50c882923 100644 --- a/crates/ecstore/src/core/pools.rs +++ b/crates/ecstore/src/core/pools.rs @@ -47,7 +47,6 @@ use crate::storage_api_contracts::{ admin::StorageAdminApi, bucket::{BucketOperations, BucketOptions, MakeBucketOptions}, heal::HealOperations as _, - namespace::NamespaceLocking as _, object::{EcstoreObjectIO, ObjectIO as _, ObjectOperations as _}, }; use crate::{core::sets::Sets, store::ECStore}; diff --git a/crates/ecstore/src/services/rebalance/control.rs b/crates/ecstore/src/services/rebalance/control.rs index 98c950aa5..99d6c1137 100644 --- a/crates/ecstore/src/services/rebalance/control.rs +++ b/crates/ecstore/src/services/rebalance/control.rs @@ -909,7 +909,7 @@ mod tests { use super::*; use crate::disk::{DiskAPI as _, RUSTFS_META_BUCKET}; use crate::object_api::NamespaceLockFence; - use crate::set_disk::ops::object::hermetic_set_disks_support::hermetic_set_disks_isolated; + use crate::set_disk::hermetic_set_disks_isolated; #[test] fn rebalance_activation_rejects_persisted_decommission_despite_idle_local_snapshot() { diff --git a/crates/ecstore/src/services/rebalance/rebalance_unit_tests.rs b/crates/ecstore/src/services/rebalance/rebalance_unit_tests.rs index d9c16ee06..c82eda451 100644 --- a/crates/ecstore/src/services/rebalance/rebalance_unit_tests.rs +++ b/crates/ecstore/src/services/rebalance/rebalance_unit_tests.rs @@ -51,6 +51,7 @@ use super::worker::{ use super::{ DiskStat, GetObjectReader, ObjectInfo, ObjectOptions, RebalSaveOpt, RebalStatus, RebalanceBucketConfigs, RebalanceBucketOutcome, RebalanceCleanupWarnings, RebalanceEntryOutcome, RebalanceInfo, RebalanceMeta, RebalanceStats, + RebalanceStopPropagationRecord, }; use super::{REBALANCE_DEFERRED_ENTRY_ERROR_PREFIX, REBALANCE_SOURCE_CLEANUP_DEFERRED_ERROR_PREFIX}; use crate::bucket::replication::{ReplicationState, ReplicationStatusType, replication_state_to_filemeta}; diff --git a/crates/ecstore/src/set_disk/mod.rs b/crates/ecstore/src/set_disk/mod.rs index cbf050a4b..4d1d56578 100644 --- a/crates/ecstore/src/set_disk/mod.rs +++ b/crates/ecstore/src/set_disk/mod.rs @@ -735,6 +735,9 @@ pub(crate) use core::io_primitives::disk_call_counters; mod ctx; mod metadata; mod ops; + +#[cfg(test)] +pub(crate) use ops::hermetic_set_disks_isolated; #[cfg(any(test, feature = "test-util"))] pub use ops::multipart::{MultipartCommitBarrier, MultipartCommitPause}; #[cfg(feature = "test-util")] diff --git a/crates/ecstore/src/set_disk/ops/mod.rs b/crates/ecstore/src/set_disk/ops/mod.rs index 4321ef3ed..4cea63793 100644 --- a/crates/ecstore/src/set_disk/ops/mod.rs +++ b/crates/ecstore/src/set_disk/ops/mod.rs @@ -25,3 +25,6 @@ pub(crate) mod list; pub(crate) mod locking; pub(crate) mod multipart; pub(crate) mod object; + +#[cfg(test)] +pub(crate) use object::hermetic_set_disks_support::hermetic_set_disks_isolated; diff --git a/crates/ecstore/src/set_disk/ops/object.rs b/crates/ecstore/src/set_disk/ops/object.rs index 92b347c7c..da809eea6 100644 --- a/crates/ecstore/src/set_disk/ops/object.rs +++ b/crates/ecstore/src/set_disk/ops/object.rs @@ -7613,7 +7613,7 @@ mod object_encryption_resolver_wiring_tests { } #[cfg(test)] -pub(crate) mod hermetic_set_disks_support { +pub(in crate::set_disk::ops) mod hermetic_set_disks_support { //! Shared hermetic `SetDisks` construction for the ops tests below: the //! `SetDisks` under test is built directly on formatted local disks (same //! pattern as the `ops/locking.rs` tests) so the tests stay hermetic — no