Skip to content

Commit 5dde3cb

Browse files
committed
fix: server acking entries too early
1 parent b2bacd0 commit 5dde3cb

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

loglogd/src/node/request_handler.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -298,7 +298,7 @@ impl RequestHandlerInner {
298298
let last_fsynced_log_offset =
299299
*last_fsynced_log_offset_rx.borrow_and_update();
300300

301-
if last_fsynced_log_offset < allocation_id.offset {
301+
if last_fsynced_log_offset <= allocation_id.offset {
302302
if last_fsynced_log_offset_rx.changed().await.is_err() {
303303
return Ok(());
304304
}

0 commit comments

Comments
 (0)