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

core/vdbe/sorter: Replace IOCompletions::Many with completion group

Browse Source
This commit is contained in:
Pekka Enberg
2025-10-13 10:57:30 +03:00
parent 840d6a0df5
commit ff7f462981
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
core/vdbe/sorter.rs
View File

@@ -298,9 +298,11 @@ impl Sorter {
fn next_from_chunk_heap(&mut self) -> Result<IOResult<Option<SortableImmutableRecord>>> {
if !self.pending_completions.is_empty() {
return Ok(IOResult::IO(IOCompletions::Many(
self.pending_completions.drain(..).collect(),
)));
let mut group = CompletionGroup::new(|_| {});
for c in self.pending_completions.drain(..) {
group.add(&c);
}
return Ok(IOResult::IO(IOCompletions::Single(group.build())));
}
// Make sure all chunks read at least one record into their buffer.
if let Some((next_record, next_chunk_idx)) = self.chunk_heap.pop() {