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

test(ecstore): adapt metadata mutation fixtures

Browse Source
This commit is contained in:
马登山
2026-08-13 08:21:25 +08:00
parent fd727a8053
commit 46baa20e87
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/set_disk/ops/object.rs
+15 -5
View File
@@ -5835,7 +5835,7 @@ mod metadata_mutation_generation_tests {
}
async fn persist_part_checksum_sidecar(set_disks: &Arc<SetDisks>, bucket: &str, object: &str, value: &str) {
let (mut fi, _, disks) = set_disks
let (fi, _, disks) = set_disks
.get_object_fileinfo(
bucket,
object,
@@ -5849,6 +5849,8 @@ mod metadata_mutation_generation_tests {
)
.await
.expect("object metadata should be readable before adding the checksum sidecar");
let mut fi = fi.into_owned();
let disks = disks.into_owned();
rustfs_utils::http::insert_str(&mut fi.metadata, rustfs_utils::http::SUFFIX_PART_CHECKSUMS, value.to_string());
set_disks
.update_object_meta(bucket, object, fi, &disks)
@@ -5992,7 +5994,7 @@ mod metadata_mutation_generation_tests {
let conflicting_object = "conflicting-sidecar";
let (mut conflicting_source, _) =
put_and_prime(&set_disks, bucket, conflicting_object, b"conflicting sidecar body").await;
let (mut fi, _, disks) = set_disks
let (fi, _, disks) = set_disks
.get_object_fileinfo(
bucket,
conflicting_object,
@@ -6006,6 +6008,8 @@ mod metadata_mutation_generation_tests {
)
.await
.expect("conflicting object metadata should be readable before corruption is injected");
let mut fi = fi.into_owned();
let disks = disks.into_owned();
let rustfs_key = format!(
"{}{}",
rustfs_utils::http::RUSTFS_INTERNAL_PREFIX,
@@ -6155,7 +6159,7 @@ mod transition_commit_failure_tests {
)
.await
.expect("source multipart upload should complete");
let (mut source_fi, _, online_disks) = set_disks
let (source_fi, _, online_disks) = set_disks
.get_object_fileinfo(
bucket,
object,
@@ -6169,6 +6173,8 @@ mod transition_commit_failure_tests {
)
.await
.expect("source metadata should be readable before adding the checksum sidecar");
let mut source_fi = source_fi.into_owned();
let online_disks = online_disks.into_owned();
rustfs_utils::http::insert_str(
&mut source_fi.metadata,
rustfs_utils::http::SUFFIX_PART_CHECKSUMS,
@@ -7905,7 +7911,7 @@ mod transition_upload_integrity_tests {
let object = "object.bin";
let payload = b"transition remote object must be bound to its transaction id".repeat(1024);
let original = write_source(&set_disks, &disk_stores, bucket, object, &payload).await;
let (mut source_fi, _, online_disks) = set_disks
let (source_fi, _, online_disks) = set_disks
.get_object_fileinfo(
bucket,
object,
@@ -7919,6 +7925,8 @@ mod transition_upload_integrity_tests {
)
.await
.expect("source metadata should be readable");
let mut source_fi = source_fi.into_owned();
let online_disks = online_disks.into_owned();
rustfs_utils::http::insert_str(
&mut source_fi.metadata,
rustfs_utils::http::SUFFIX_PART_CHECKSUMS,
@@ -9983,7 +9991,7 @@ mod put_object_tags_early_stop_regression_tests {
.await
.expect("put_object should succeed");
let (mut fi, _, disks) = set_disks
let (fi, _, disks) = set_disks
.get_object_fileinfo(
bucket,
object,
@@ -9997,6 +10005,8 @@ mod put_object_tags_early_stop_regression_tests {
)
.await
.expect("object metadata should be readable before adding the checksum sidecar");
let mut fi = fi.into_owned();
let disks = disks.into_owned();
rustfs_utils::http::insert_str(
&mut fi.metadata,
rustfs_utils::http::SUFFIX_PART_CHECKSUMS,