asp/keep
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: remove redundant compression engine initialization

Browse Source
This commit is contained in:
Andrew Phillips
2025-05-06 13:51:58 -03:00
committed by Andrew Phillips (aider)
parent 43eff88003
commit a6d5db2a84
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main.rs
View File

@@ -506,7 +506,6 @@ fn mode_diff(cmd: &mut Command, args: Args, ids: &mut Vec<i64>, tags: &mut Vec<S
let compression_type_a = CompressionType::from_str(&item_a.compression)?;
debug!("MAIN: Item A has compression type {:?}", compression_type_a.clone());
let compression_engine_a = compression::get_engine(compression_type_a).expect("Unable to get compression engine");
if let Some(item_b) = item_b {
debug!("MAIN: Found item B {:?}", item_b);
@@ -517,8 +516,6 @@ fn mode_diff(cmd: &mut Command, args: Args, ids: &mut Vec<i64>, tags: &mut Vec<S
let compression_type_b = CompressionType::from_str(&item_b.compression)?;
debug!("MAIN: Item B has compression type {:?}", compression_type_b.clone());
let compression_engine_b = compression::get_engine(compression_type_b).expect("Unable to get compression engine");
let (fd_a_read, fd_a_write) = unistd::pipe().unwrap();
let (fd_b_read, fd_b_write) = unistd::pipe().unwrap();
@@ -545,7 +542,7 @@ fn mode_diff(cmd: &mut Command, args: Args, ids: &mut Vec<i64>, tags: &mut Vec<S
let handle_a = {
let stdout_a = stdout_a;
let item_path_a = item_path_a.clone();
let compression_engine_a = compression_engine_a;
let compression_engine_a = compression::get_engine(compression_type_a).expect("Unable to get compression engine");
std::thread::spawn(move || {
compression_engine_a.copy(item_path_a, &mut stdout_a).unwrap()
})
@@ -555,7 +552,7 @@ fn mode_diff(cmd: &mut Command, args: Args, ids: &mut Vec<i64>, tags: &mut Vec<S
let handle_b = {
let stdout_b = stdout_b;
let item_path_b = item_path_b.clone();
let compression_engine_b = compression_engine_b;
let compression_engine_b = compression::get_engine(compression_type_b).expect("Unable to get compression engine");
std::thread::spawn(move || {
compression_engine_b.copy(item_path_b, &mut stdout_b).unwrap()
})