Compare commits

..

8 Commits

Author SHA1 Message Date
overtrue c2ce237d5a fix(ecstore): restore decommission test imports 2026-08-22 19:19:08 +08:00
overtrue 241271c256 fix(ecstore): satisfy decommission clippy checks 2026-08-22 18:55:44 +08:00
overtrue 3be1511214 style(ecstore): format decommission test imports 2026-08-22 18:44:46 +08:00
overtrue bc1caf0dc7 fix(ecstore): drop stale decommission test import 2026-08-22 18:44:46 +08:00
overtrue ce4a72869d style(ecstore): format decommission supervision tests 2026-08-22 18:44:14 +08:00
overtrue 255943fa43 test(ecstore): cover terminal save retry fencing 2026-08-22 18:43:56 +08:00
overtrue 5583e8373c fix(ecstore): supervise decommission worker exits 2026-08-22 18:43:56 +08:00
overtrue e1c657652f fix(ecstore): fence decommission canceler cleanup 2026-08-22 18:43:47 +08:00
2 changed files with 842 additions and 254 deletions
File diff suppressed because it is too large Load Diff
+2 -2
View File
@@ -33,7 +33,7 @@ use crate::bucket::utils::check_put_object_part_args;
use crate::bucket::utils::{check_valid_bucket_name, check_valid_bucket_name_strict, is_meta_bucketname};
use crate::cluster::rpc::{RemoteClient, S3PeerSys};
use crate::config::storageclass;
use crate::core::pools::PoolMeta;
use crate::core::pools::{DecommissionCanceler, PoolMeta};
use crate::disk::endpoint::{Endpoint, EndpointType};
use crate::disk::{DiskAPI, DiskInfo, DiskInfoOptions};
use crate::error::{Error, Result};
@@ -176,7 +176,7 @@ pub struct ECStore {
// pub local_disks: Vec<DiskStore>,
pub pool_meta: RwLock<PoolMeta>,
pub rebalance_meta: RwLock<Option<RebalanceMeta>>,
pub decommission_cancelers: RwLock<Vec<Option<CancellationToken>>>,
pub decommission_cancelers: RwLock<Vec<Option<DecommissionCanceler>>>,
/// Serializes rebalance/decommission start transitions.
///
/// Lock order: acquire `start_gate` before `pool_meta`, `rebalance_meta`,