From 358ff0f0e6cb3584e0a6bad49909a39d22832f2c Mon Sep 17 00:00:00 2001 From: overtrue Date: Sun, 6 Sep 2026 11:36:33 +0800 Subject: [PATCH] test(rpc): select fixture disks through the store topology --- rustfs/src/storage/rpc/node_service.rs | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/rustfs/src/storage/rpc/node_service.rs b/rustfs/src/storage/rpc/node_service.rs index cb21022ce..b413661a4 100644 --- a/rustfs/src/storage/rpc/node_service.rs +++ b/rustfs/src/storage/rpc/node_service.rs @@ -4706,14 +4706,14 @@ mod tests { async fn stage_target_rpc(fixture: &TargetRpcFixture) -> (super::DiskStore, rustfs_filemeta::FileInfo, Vec) { use crate::storage::storage_api::ecstore_disk::{DiskAPI, ReadOptions}; - let disk = fixture - .instance - .local_disk_map() - .read() - .await - .values() - .find_map(Clone::clone) - .expect("local target"); + let set = fixture + .env + .ecstore + .all_set_disks() + .into_iter() + .next() + .expect("target erasure set"); + let disk = set.disks.read().await.iter().find_map(Clone::clone).expect("local target"); let mut fi = rustfs_filemeta::FileInfo::new("destination", 1, 0); fi.erasure.index = 1; fi.version_id = Some(Uuid::new_v4());