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

test(heal): replay fixtures with source incarnation

Browse Source 
Co-Authored-By: heihutu <heihutu@gmail.com>

Co-Authored-By: zhi22915 <qiuzgang@gmail.com>
This commit is contained in:
Hauser
2026-09-30 13:46:07 +08:00
parent d32b1478bb
commit 607a0b9bb0
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/heal/src/heal/mrf_queue/partial_write.rs
+4 -4
View File
@@ -999,7 +999,7 @@ mod tests {
let replacement = intent("legacy");
writes
.admit(replacement, 1, 8192)
.admit_with_source_incarnation(replacement, Some(incarnation), 1, 8192)
.expect("a new generation should become retryable");
writes.mark_persisted();
assert_eq!(writes.unverified_legacy_count(), 0);
@@ -1007,7 +1007,7 @@ mod tests {
let mut restarted = PartialWrites::default();
restarted
.admit(original, 1, 8192)
.admit_with_source_incarnation(original, Some(incarnation), 1, 8192)
.expect("the unchanged journal re-arms the same responsibility after restart");
restarted.mark_persisted();
assert_eq!(restarted.unverified_legacy_count(), 0);
@@ -1043,7 +1043,7 @@ mod tests {
.expect("hold state checkpoint");
let mut restored = PartialWrites::default();
restored
.admit(original, 1, 8192)
.admit_with_source_incarnation(original, Some(incarnation), 1, 8192)
.expect("replay journal intent before applying lifecycle state");
assert!(restored.restore_state(&intent("legacy-lifecycle"), &checkpoint));
restored.mark_persisted();
@@ -1126,7 +1126,7 @@ mod tests {
let mut restored = PartialWrites::default();
restored
.admit(original.clone(), 1, 8192)
.admit_with_source_incarnation(original.clone(), Some(original_incarnation), 1, 8192)
.expect("replay creates retry index entry");
assert!(restored.restore_state(&original, &checkpoint));
let (previous, _) = restored