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

Merge 'make_from_btree should wait for IO to complete' from Pedro Muniz

Browse Source 
Reviewed-by: Jussi Saurio <jussi.saurio@gmail.com>

Closes #2144
This commit is contained in:
Jussi Saurio
2025-07-17 23:44:29 +03:00
parent 1b52b5c764 9690eb41c2
commit 68427c9b31
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
core/schema.rs
View File

@@ -157,19 +157,21 @@ impl Schema {
let mut automatic_indices: HashMap<String, Vec<(String, usize)>> =
HashMap::with_capacity(10);
match pager.begin_read_tx()? {
IOResult::Done(v) => {
if matches!(v, LimboResult::Busy) {
return Err(LimboError::Busy);
loop {
match pager.begin_read_tx()? {
IOResult::Done(v) => {
if matches!(v, LimboResult::Busy) {
return Err(LimboError::Busy);
}
break;
}
IOResult::IO => pager.io.run_once()?,
}
IOResult::IO => pager.io.run_once()?,
}
match cursor.rewind()? {
IOResult::Done(v) => v,
IOResult::IO => pager.io.run_once()?,
};
while let IOResult::IO = cursor.rewind()? {
pager.io.run_once()?
}
loop {
let Some(row) = (loop {
@@ -285,9 +287,9 @@ impl Schema {
drop(record_cursor);
drop(row);
if matches!(cursor.next()?, IOResult::IO) {
while let IOResult::IO = cursor.next()? {
pager.io.run_once()?;
};
}
}
pager.end_read_tx()?;