Enable pipelined storage
Some checks failed
continuous-integration/drone the build failed

This commit is contained in:
Olivier 'reivilibre' 2021-11-20 14:47:40 +00:00
parent 8802994d96
commit b055c5559c
3 changed files with 4 additions and 4 deletions

View File

@ -202,7 +202,7 @@ pub fn backup_source_to_destination<PT: ProgressTracker>(
parent, parent,
num_workers, num_workers,
progress_bar, progress_bar,
false, true,
)?; )?;
info!("Stored!"); info!("Stored!");

View File

@ -248,7 +248,7 @@ pub fn backup_remote_source_to_destination<PT: ProgressTracker + Send + 'static>
raw_pile, raw_pile,
parent, parent,
progress_bar, progress_bar,
false, true,
)?; )?;
quit(&mut read, &mut write)?; quit(&mut read, &mut write)?;

View File

@ -71,7 +71,7 @@ pub fn chunking<R: Read + Send + 'static, W: Write + Send + 'static>(
parent, parent,
get_number_of_workers("YAMA_CHUNKERS"), get_number_of_workers("YAMA_CHUNKERS"),
progress_bar, progress_bar,
false, true,
)?; )?;
for join_handle in requester_join_handles { for join_handle in requester_join_handles {
@ -169,7 +169,7 @@ pub fn chunking_stdio() -> anyhow::Result<()> {
parent, parent,
get_number_of_workers("YAMA_CHUNKERS"), get_number_of_workers("YAMA_CHUNKERS"),
&mut progress_bar, &mut progress_bar,
false, true,
)?; )?;
requester_join_handles requester_join_handles