Skip to content

Commit 4d745e0

Browse files
committed
fix merge
1 parent 1a5ab87 commit 4d745e0

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

storage/src/qmdb/conformance.rs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -237,11 +237,12 @@ async fn apply_writes<F: Family, D: DbAny<F, Key = Digest, Value = Digest>>(
237237
/// Apply a batch of immutable sets to the database.
238238
macro_rules! apply_sets {
239239
($db:ident, $ops:expr) => {{
240+
let floor = $db.inactivity_floor_loc();
240241
let mut batch = $db.new_batch();
241242
for (k, v) in $ops {
242243
batch = batch.set(k, v);
243244
}
244-
let merkleized = batch.merkleize(&$db, None);
245+
let merkleized = batch.merkleize(&$db, None, floor);
245246
$db.apply_batch(merkleized).await.unwrap();
246247
}};
247248
}
@@ -641,18 +642,20 @@ macro_rules! assert_immutable_order_independent {
641642
ops.push((colliding_digest(0xCD, i), to_val(i, 100)));
642643
}
643644

645+
let fwd_floor = $fwd.inactivity_floor_loc();
644646
let mut batch = $fwd.new_batch();
645647
for &(k, v) in &ops {
646648
batch = batch.set(k, v);
647649
}
648-
let merkleized = batch.merkleize(&$fwd, None);
650+
let merkleized = batch.merkleize(&$fwd, None, fwd_floor);
649651
$fwd.apply_batch(merkleized).await.unwrap();
650652

653+
let rev_floor = $rev.inactivity_floor_loc();
651654
let mut batch = $rev.new_batch();
652655
for &(k, v) in ops.iter().rev() {
653656
batch = batch.set(k, v);
654657
}
655-
let merkleized = batch.merkleize(&$rev, None);
658+
let merkleized = batch.merkleize(&$rev, None, rev_floor);
656659
$rev.apply_batch(merkleized).await.unwrap();
657660

658661
assert_eq!(

0 commit comments

Comments
 (0)