We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1e93bc8 commit e22ba69Copy full SHA for e22ba69
1 file changed
libsql-wal/src/registry.rs
@@ -533,6 +533,9 @@ where
533
.stream(&mut seen, remote_durable_frame_no, 1)
534
.peekable();
535
let mut injector = Injector::new(shared.clone(), 10)?;
536
+ // we set the durable frame_no before we start injecting, because the wal may want to
537
+ // checkpoint on commit.
538
+ injector.set_durable(remote_durable_frame_no);
539
// use pin to the heap so that we can drop the stream in the loop, and count `seen`.
540
let mut stream = Box::pin(stream);
541
loop {
0 commit comments