gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-10-04 20:43:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(heal): keep outage objects in the replacement erasure set

Browse Source 
(cherry picked from commit a669f50a366e35505e7745f8b680d8ecf1aa31be)
This commit is contained in:
overtrue
2026-09-15 03:11:56 +08:00
parent 14a464a313
commit 63fec31f72
1 changed files with 27 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/e2e_test/src/heal_erasure_disk_rebuild_test.rs
+27 -1
View File
@@ -1563,6 +1563,21 @@ mod tests {
"replacement target must retain only its preformatted topology identity"
);
// A multi-set pool can route a successful outage PUT away from the
// replacement drive. Identify its set through a witnessed baseline.
let target_set_peer_drives = cluster
.nodes
.iter()
.enumerate()
.filter(|(node_index, _)| *node_index != 1)
.flat_map(|(_, node)| node.data_dirs.iter().map(PathBuf::from))
.filter(|drive| object_metadata_exists_on_disk(drive, bucket, &expected_manifests[0].key))
.collect::<Vec<_>>();
assert!(
!outage_target_manifest_required || !target_set_peer_drives.is_empty(),
"the replacement erasure set must retain an online baseline shard"
);
let outage_payload_seed = 0xf1;
let max_outage_write_attempts = topology.total_drives().max(1);
let mut outage_key = None;
@@ -1593,7 +1608,10 @@ mod tests {
&candidate_peer_manifest,
erasure_set_drive_count,
replacement_set_slot,
) {
) || !target_set_peer_drives
.iter()
.any(|drive| object_metadata_exists_on_disk(drive, bucket, &candidate_key))
{
rejected_outage_keys.push(candidate_key);
continue;
}
@@ -1638,6 +1656,14 @@ mod tests {
}
};
assert!(
!outage_target_manifest_required
|| target_set_peer_drives
.iter()
.any(|drive| object_metadata_exists_on_disk(drive, bucket, &outage_key)),
"outage object {outage_key} belongs to a different erasure set than the replacement drive"
);
if !outage_write_deferred_until_rejoin && outage_peer_manifest.erasure_indices.is_empty() {
outage_peer_manifest = collect_outage_peer_manifest(&cluster, 1, bucket, &outage_key, erasure_set_drive_count)?;
replacement_outage_erasure_index =