From b75eb9f09d8802ddbfdace9a8ca027cff5c1cf37 Mon Sep 17 00:00:00 2001
From: Pere Diaz Bou <pere-altea@hotmail.com>
Date: Thu, 25 Sep 2025 13:31:03 +0200
Subject: [PATCH] core/mvcc/logical-log: drain consumed bytes on read_more_data

---
 core/mvcc/persistent_storage/logical_log.rs | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/core/mvcc/persistent_storage/logical_log.rs b/core/mvcc/persistent_storage/logical_log.rs
index c9fa74bee..7cc22b5ea 100644
--- a/core/mvcc/persistent_storage/logical_log.rs
+++ b/core/mvcc/persistent_storage/logical_log.rs
@@ -413,6 +413,10 @@ impl StreamingLogicalLogReader {
         let c = self.file.pread(self.offset as u64, c)?;
         io.wait_for_completion(c)?;
         self.offset += to_read;
+        // cleanup consumed bytes
+        // this could be better for sure
+        let _ = self.buffer.borrow_mut().drain(0..self.buffer_offset);
+        self.buffer_offset = 0;
         Ok(())
     }