aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-02-23 00:45:37 +01:00
Code Issues Packages Projects Releases Wiki Activity

core/mvcc/cursor: fix rewind

Browse Source
This commit is contained in:
Pere Diaz Bou
2025-10-21 13:41:21 +02:00
parent 3f41a092f2
commit 8857604161
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
core/mvcc/cursor.rs
View File

@@ -353,7 +353,12 @@ impl<Clock: LogicalClock + 'static> CursorTrait for MvccLazyCursor<Clock> {
}
fn rewind(&mut self) -> Result<IOResult<()>> {
self.current_pos.replace(CursorPosition::BeforeFirst);
self.invalidate_record();
if !matches!(self.get_current_pos(), CursorPosition::BeforeFirst) {
self.current_pos.replace(CursorPosition::BeforeFirst);
}
// Next will set cursor position to a valid position if it exists, otherwise it will set it to one that doesn't exist.
let _ = return_if_io!(self.next());
Ok(IOResult::Done(()))
}