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

fix op_sorter

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-09-17 21:30:40 +04:00
parent c1176356f7
commit bf5397dade
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
core/vdbe/execute.rs
View File

@@ -8,7 +8,7 @@ use crate::storage::btree::{
use crate::storage::database::DatabaseFile;
use crate::storage::page_cache::PageCache;
use crate::storage::pager::{AtomicDbState, CreateBTreeFlags, DbState};
use crate::storage::sqlite3_ondisk::read_varint;
use crate::storage::sqlite3_ondisk::{read_varint, PageSize};
use crate::translate::collate::CollationSeq;
use crate::types::{
compare_immutable, compare_records_generic, Extendable, IOCompletions, ImmutableRecord,
@@ -3998,7 +3998,11 @@ pub fn op_sorter_open(
insn
);
// be careful here - we must not use any async operations after pager.with_header because this op-code has no proper state-machine
let page_size = return_if_io!(pager.with_header(|header| header.page_size));
let page_size = match pager.with_header(|header| header.page_size) {
Ok(IOResult::Done(page_size)) => page_size,
Err(_) => PageSize::default(),
Ok(IOResult::IO(io)) => return Ok(InsnFunctionStepResult::IO(io)),
};
let page_size = page_size.get() as usize;
let cache_size = program.connection.get_cache_size();