RGBCube/uutils-coreutils
1
Fork 0
mirror of https://github.com/RGBCube/uutils-coreutils synced 2025-08-05 07:27:46 +00:00
Code Issues Activity

Adjust max buffer size for read back as well

Browse source
This commit is contained in:
electricboogie 2021-04-25 16:33:12 -05:00
parent 6f82cd4f15
commit 0f707cdb25
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/uu/sort/src/external_sort/mod.rs
View file

@ -181,7 +181,7 @@ where
for seq in unsorted { for seq in unsorted {
let seq_size = seq.get_size(); let seq_size = seq.get_size();
total_read += seq_size; total_read += seq_size;
// Grow buffer size for a Line larger than buffer // Grow buffer size for a struct/Line larger than buffer
adjusted_buffer_size = adjusted_buffer_size =
if adjusted_buffer_size < seq_size { if adjusted_buffer_size < seq_size {
seq_size seq_size
@ -212,10 +212,9 @@ where
} }
// initialize buffers for each chunk // initialize buffers for each chunk
iter.max_per_chunk = self iter.max_per_chunk = adjusted_buffer_size
.buffer_bytes
.checked_div(iter.chunks) .checked_div(iter.chunks)
.unwrap_or(self.buffer_bytes); .unwrap_or(adjusted_buffer_size);
iter.buffers = vec![VecDeque::new(); iter.chunks as usize]; iter.buffers = vec![VecDeque::new(); iter.chunks as usize];
iter.chunk_offsets = vec![0 as u64; iter.chunks as usize]; iter.chunk_offsets = vec![0 as u64; iter.chunks as usize];
for chunk_num in 0..iter.chunks { for chunk_num in 0..iter.chunks {