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

core/mvcc: Wrap header with RwLock

Browse Source
This commit is contained in:
Pekka Enberg
2025-09-26 14:02:12 +03:00
parent 506908e648
commit 96accef06c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -260,10 +260,10 @@ impl StreamingLogicalLogReader {
pub fn read_header(&mut self) -> Result<Completion> {
let header_buf = Arc::new(Buffer::new_temporary(LOG_HEADER_MAX_SIZE));
let header = Arc::new(RefCell::new(LogHeader::default()));
let header = Arc::new(RwLock::new(LogHeader::default()));
let completion: Box<ReadComplete> = Box::new(move |res| {
let header = header.clone();
let mut header = header.borrow_mut();
let mut header = header.write().unwrap();
let Ok((buf, bytes_read)) = res else {
tracing::error!("couldn't ready log err={:?}", res,);
return;