From 07bac4978ee057183176bb7be9fb8c04b03d411c Mon Sep 17 00:00:00 2001 From: overtrue Date: Sat, 22 Aug 2026 12:37:47 +0800 Subject: [PATCH] test(ecstore): observe decommission lock attempt --- crates/ecstore/src/core/pools.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/crates/ecstore/src/core/pools.rs b/crates/ecstore/src/core/pools.rs index 284e28aa3..e1d37c245 100644 --- a/crates/ecstore/src/core/pools.rs +++ b/crates/ecstore/src/core/pools.rs @@ -2876,6 +2876,8 @@ impl ECStore { .first() .cloned() .ok_or_else(|| Error::other("decommission start rebalance metadata load failed: no storage pools available"))?; + #[cfg(test)] + observe_pool_activation_start_attempt(PoolActivationStartKind::Decommission); let activation_fence = acquire_pool_rebalance_activation_locks(rebalance_pool.clone()).await?; let mut rebalance_meta = RebalanceMeta::new(); @@ -4418,8 +4420,6 @@ impl ECStore { let indices = dedup_indices(&indices); validate_start_decommission_request(&indices, self.single_pool())?; - #[cfg(test)] - observe_pool_activation_start_attempt(PoolActivationStartKind::Decommission); self.ensure_decommission_rebalance_idle_after_refresh().await?; #[cfg(test)] let endpoints = self.instance_endpoints().unwrap_or_else(|| self.endpoints());