gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-09-07 12:35:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(ecstore): drain source writes before corrupting shards (#7291)

Browse Source
This commit is contained in:
Zhengchao An
2026-09-06 17:51:07 +08:00
committed by GitHub
parent 0b72f39023
commit 3496277e7c
1 changed files with 17 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/set_disk/ops/object.rs
+17 -1
View File
@@ -16291,7 +16291,23 @@ mod transition_upload_integrity_tests {
let bucket = format!("transition-real-bitrot-{}", position.label()); let bucket = format!("transition-real-bitrot-{}", position.label());
let object = format!("{}-corrupt.bin", position.label()); let object = format!("{}-corrupt.bin", position.label());
let payload = vec![0x41; 2 * 1024 * 1024]; let payload = vec![0x41; 2 * 1024 * 1024];
let original = write_source(&set_disks, &disk_stores, &bucket, &object, &payload).await; // Corruption edits physical shards, so every healthy rename must finish first.
for disk in &disk_stores {
disk.make_volume(&bucket).await.expect("bucket volume should be created");
}
let mut reader = PutObjReader::from_vec(payload.to_vec());
let original = set_disks
.put_object(
&bucket,
&object,
&mut reader,
&ObjectOptions {
write_completion: WriteCompletion::TailDrained,
..Default::default()
},
)
.await
.expect("source object should be written");
let source = set_disks let source = set_disks
.get_object_fileinfo( .get_object_fileinfo(
&bucket, &bucket,