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

begin_write_btree_page should return completion

Browse Source
This commit is contained in:
pedrocarlo
2025-07-28 12:54:26 -03:00
parent 3104e3fee5
commit 28d6245440
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
core/storage/pager.rs
View File

@@ -1464,7 +1464,7 @@ impl Pager {
(default_header.get_page_size() - default_header.reserved_space as u32) as u16,
);
let write_counter = Rc::new(RefCell::new(0));
begin_write_btree_page(self, &page1.get(), write_counter.clone())?;
let c= begin_write_btree_page(self, &page1.get(), write_counter.clone())?;
self.allocate_page1_state
.replace(AllocatePage1State::Writing {

2
core/storage/sqlite3_ondisk.rs
View File

@@ -814,7 +814,7 @@ pub fn begin_write_btree_page(
pager: &Pager,
page: &PageRef,
write_counter: Rc<RefCell<usize>>,
) -> Result<()> {
) -> Result<Arc<Completion>> {
tracing::trace!("begin_write_btree_page(page={})", page.get().id);
let page_source = &pager.db_file;
let page_finish = page.clone();

2
core/storage/wal.rs
View File

@@ -914,7 +914,7 @@ impl Wal for WalFile {
}
CheckpointState::WritePage => {
self.ongoing_checkpoint.page.set_dirty();
begin_write_btree_page(
let c = begin_write_btree_page(
pager,
&self.ongoing_checkpoint.page,
write_counter.clone(),