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

core/mvcc/logical-log: fail in read_more_data if couldn't read enough

Browse Source
This commit is contained in:
Pere Diaz Bou
2025-10-01 14:25:22 +02:00
parent 9993a83be4
commit dc0245d758
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/mvcc/persistent_storage/logical_log.rs
View File

@@ -419,17 +419,21 @@ impl StreamingLogicalLogReader {
if bytes_can_read >= need {
return Ok(());
}
let to_read = 4096;
let to_read = 4096.max(need);
let to_read = to_read.min(self.file_size - self.offset);
let header_buf = Arc::new(Buffer::new_temporary(to_read));
let buffer = self.buffer.clone();
let completion: Box<ReadComplete> = Box::new(move |res| {
let buffer = buffer.clone();
let mut buffer = buffer.write().unwrap();
let Ok((buf, _bytes_read)) = res else {
let Ok((buf, bytes_read)) = res else {
tracing::trace!("couldn't ready log err={:?}", res,);
return;
return ;
};
turso_assert!(
bytes_read as usize >= need,
"couldn't read enough data. Requested={need} got={bytes_read}"
);
let buf = buf.as_slice();
buffer.extend_from_slice(buf);
});