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

test(ecstore): match format reads exactly

Browse Source
This commit is contained in:
马登山
2026-08-18 10:04:08 +08:00
parent 6158955db2
commit d94681f841
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/cluster/rpc/remote_disk.rs
+4 -2
View File
@@ -3502,9 +3502,11 @@ mod tests {
Box::pin(async move { Box::pin(async move {
peer.verify_auth(&request, "/node_service.NodeService/ReadAll")?; peer.verify_auth(&request, "/node_service.NodeService/ReadAll")?;
let request = request.into_inner(); let request = request.into_inner();
let is_format_read = request.volume == crate::disk::RUSTFS_META_BUCKET
&& request.path == crate::disk::FORMAT_CONFIG_FILE;
let disk = request.disk; let disk = request.disk;
peer.read_all_calls.fetch_add(1, Ordering::AcqRel); peer.read_all_calls.fetch_add(1, Ordering::AcqRel);
let data = if request.path.ends_with("format.json") { let data = if is_format_read {
peer.format_data.clone() peer.format_data.clone()
} else { } else {
peer.object_read_all_disks peer.object_read_all_disks
@@ -4832,7 +4834,7 @@ mod tests {
0, 0,
0, 0,
vec![endpoint.clone()], vec![endpoint.clone()],
format.clone(), format,
Vec::new(), Vec::new(),
) )
.await; .await;