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

cosmetic fix

Browse Source
This commit is contained in:
Iaroslav Zeigerman
2025-07-17 08:03:39 +02:00
parent a88b828268
commit 6a609398fe
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/vdbe/sorter.rs
View File

@@ -243,7 +243,7 @@ impl Sorter {
self.current_buffer_size,
chunk_buffer_size,
);
chunk.write(&mut self.records, self.current_buffer_size)?;
chunk.write(&mut self.records)?;
self.chunks.push(chunk);
self.current_buffer_size = 0;
@@ -393,16 +393,12 @@ impl SortedChunk {
Ok(())
}
fn write(
&mut self,
records: &mut Vec<SortableImmutableRecord>,
total_size: usize,
) -> Result<()> {
fn write(&mut self, records: &mut Vec<SortableImmutableRecord>) -> Result<()> {
assert!(self.io_state.get() == SortedChunkIOState::None);
self.io_state.set(SortedChunkIOState::WaitingForWrite);
let drop_fn = Rc::new(|_buffer: BufferData| {});
let mut buffer = Buffer::allocate(total_size, drop_fn);
let mut buffer = Buffer::allocate(self.chunk_size, drop_fn);
let mut buf_pos = 0;
let buf = buffer.as_mut_slice();