github/ouch
1
1
Fork 0
mirror of https://github.com/ouch-org/ouch.git synced 2025-06-07 20:15:27 +00:00
Code Issues 15 Packages Projects Releases Wiki Activity

Merge pull request #65 from ouch-org/buffers-capacity-improvement

Browse Source 
Increasing read and writer buffers capacity
This commit is contained in:
Vinícius Miguel 2021-10-06 01:07:28 -03:00 committed by GitHub
commit a8beaaae84
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/commands.rs
View File

@ -22,6 +22,9 @@ use crate::{
utils::to_utf, utils::to_utf,
}; };
// Used in BufReader and BufWriter to perform less syscalls
const BUFFER_CAPACITY: usize = 1024 * 64;
pub fn run(command: Command, flags: &oof::Flags) -> crate::Result<()> { pub fn run(command: Command, flags: &oof::Flags) -> crate::Result<()> {
match command { match command {
Command::Compress { files, output_path } => { Command::Compress { files, output_path } => {
@ -150,7 +153,7 @@ fn compress_files(
output_file: fs::File, output_file: fs::File,
_flags: &oof::Flags, _flags: &oof::Flags,
) -> crate::Result<()> { ) -> crate::Result<()> {
let file_writer = BufWriter::new(output_file); let file_writer = BufWriter::with_capacity(BUFFER_CAPACITY, output_file);
if formats.len() == 1 { if formats.len() == 1 {
let build_archive_from_paths = match formats[0] { let build_archive_from_paths = match formats[0] {
@ -254,7 +257,7 @@ fn decompress_file(
} }
// Will be used in decoder chaining // Will be used in decoder chaining
let reader = BufReader::new(reader); let reader = BufReader::with_capacity(BUFFER_CAPACITY, reader);
let mut reader: Box<dyn Read> = Box::new(reader); let mut reader: Box<dyn Read> = Box::new(reader);
// Grab previous decoder and wrap it inside of a new one // Grab previous decoder and wrap it inside of a new one