gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-28 07:57:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(ecstore): observe decommission lock attempt

Browse Source
This commit is contained in:
overtrue
2026-08-22 12:37:47 +08:00
parent d908f00f01
commit 07bac4978e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/core/pools.rs
+2 -2
View File
@@ -2876,6 +2876,8 @@ impl ECStore {
.first() .first()
.cloned() .cloned()
.ok_or_else(|| Error::other("decommission start rebalance metadata load failed: no storage pools available"))?; .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 activation_fence = acquire_pool_rebalance_activation_locks(rebalance_pool.clone()).await?;
let mut rebalance_meta = RebalanceMeta::new(); let mut rebalance_meta = RebalanceMeta::new();
@@ -4418,8 +4420,6 @@ impl ECStore {
let indices = dedup_indices(&indices); let indices = dedup_indices(&indices);
validate_start_decommission_request(&indices, self.single_pool())?; 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?; self.ensure_decommission_rebalance_idle_after_refresh().await?;
#[cfg(test)] #[cfg(test)]
let endpoints = self.instance_endpoints().unwrap_or_else(|| self.endpoints()); let endpoints = self.instance_endpoints().unwrap_or_else(|| self.endpoints());