mirror of
https://github.com/aljazceru/turso.git
synced 2026-01-06 01:34:21 +01:00
@@ -5001,26 +5001,30 @@ impl CursorTrait for BTreeCursor {
|
||||
first_overflow_page,
|
||||
..
|
||||
}) => (payload, payload_size, first_overflow_page),
|
||||
BTreeCell::IndexLeafCell(IndexLeafCell {
|
||||
payload,
|
||||
payload_size,
|
||||
first_overflow_page,
|
||||
}) => (payload, payload_size, first_overflow_page),
|
||||
BTreeCell::IndexInteriorCell(IndexInteriorCell {
|
||||
payload,
|
||||
payload_size,
|
||||
first_overflow_page,
|
||||
..
|
||||
}) => (payload, payload_size, first_overflow_page),
|
||||
BTreeCell::IndexLeafCell(IndexLeafCell {
|
||||
payload,
|
||||
first_overflow_page,
|
||||
payload_size,
|
||||
}) => (payload, payload_size, first_overflow_page),
|
||||
_ => unreachable!("unexpected page_type"),
|
||||
};
|
||||
if let Some(next_page) = first_overflow_page {
|
||||
return_if_io!(self.process_overflow_read(payload, next_page, payload_size))
|
||||
} else {
|
||||
let mut record = self.get_immutable_record_or_create();
|
||||
let record = record.as_mut().unwrap();
|
||||
record.invalidate();
|
||||
record.start_serialization(payload);
|
||||
self.get_immutable_record_or_create()
|
||||
.as_mut()
|
||||
.unwrap()
|
||||
.invalidate();
|
||||
self.get_immutable_record_or_create()
|
||||
.as_mut()
|
||||
.unwrap()
|
||||
.start_serialization(payload);
|
||||
self.record_cursor.borrow_mut().invalidate();
|
||||
};
|
||||
|
||||
|
||||
Reference in New Issue
Block a user