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

core/mvcc/logical-log: add rows size field for transaction format

Browse Source
This commit is contained in:
Pere Diaz Bou
2025-09-22 13:15:07 +02:00
parent 2cd1562966
commit 4c959e760b
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -138,6 +138,7 @@ impl LogicalLog {
buffer.extend_from_slice(&tx.tx_timestamp.to_be_bytes());
// TODO: checksum
buffer.extend_from_slice(&[0; 8]);
let buffer_pos_for_rows_size = buffer.len();
// 3. Serialize rows
tx.row_versions.iter().for_each(|row_version| {
@@ -145,8 +146,13 @@ impl LogicalLog {
row_type.serialize(&mut buffer, row_version);
});
// 4. Serialize transaction's end marker. This marker will be the position of the offset
// 4. Serialize transaction's end marker and rows size. This marker will be the position of the offset
// after writing the buffer.
let rows_size = (buffer.len() - buffer_pos_for_rows_size) as u64;
buffer.splice(
buffer_pos_for_rows_size..buffer_pos_for_rows_size,
rows_size.to_be_bytes(),
);
let offset_after_buffer = self.offset + buffer.len() as u64 + size_of::<u64>() as u64;
buffer.extend_from_slice(&offset_after_buffer.to_be_bytes());