mirror of
https://github.com/rustfs/rustfs.git
synced 2026-08-23 12:49:04 +00:00
fix(ecstore): satisfy rebalance activation clippy checks
This commit is contained in:
@@ -41,7 +41,7 @@ fn ensure_rebalance_activation_pool_meta_allowed(meta: &PoolMeta) -> Result<()>
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub(super) enum RebalanceWorkerActivationFence {
|
pub(super) enum RebalanceWorkerActivationFence {
|
||||||
Ready(PoolRebalanceActivationFence),
|
Ready(Box<PoolRebalanceActivationFence>),
|
||||||
NotStartedTerminal,
|
NotStartedTerminal,
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -324,7 +324,7 @@ impl ECStore {
|
|||||||
return Ok(RebalanceWorkerActivationFence::NotStartedTerminal);
|
return Ok(RebalanceWorkerActivationFence::NotStartedTerminal);
|
||||||
}
|
}
|
||||||
|
|
||||||
Ok(RebalanceWorkerActivationFence::Ready(activation_fence))
|
Ok(RebalanceWorkerActivationFence::Ready(Box::new(activation_fence)))
|
||||||
}
|
}
|
||||||
|
|
||||||
#[tracing::instrument(skip_all)]
|
#[tracing::instrument(skip_all)]
|
||||||
|
|||||||
@@ -2752,8 +2752,10 @@ async fn test_old_worker_cannot_mutate_replacement_rebalance_state() {
|
|||||||
..Default::default()
|
..Default::default()
|
||||||
};
|
};
|
||||||
let store = test_store_with_rebalance_meta(meta);
|
let store = test_store_with_rebalance_meta(meta);
|
||||||
let mut fi = FileInfo::default();
|
let fi = FileInfo {
|
||||||
fi.size = 128;
|
size: 128,
|
||||||
|
..Default::default()
|
||||||
|
};
|
||||||
|
|
||||||
for err in [
|
for err in [
|
||||||
store
|
store
|
||||||
|
|||||||
Reference in New Issue
Block a user