From b055c5559ca8d9199bcd0c8077ef714d252d5636 Mon Sep 17 00:00:00 2001
From: Olivier 'reivilibre <olivier@librepush.net>
Date: Sat, 20 Nov 2021 14:47:40 +0000
Subject: [PATCH] Enable pipelined storage

---
 datman/src/commands/backup.rs                | 2 +-
 datman/src/remote/backup_source_requester.rs | 2 +-
 datman/src/remote/backup_source_responder.rs | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/datman/src/commands/backup.rs b/datman/src/commands/backup.rs
index 95a4655..caca8d0 100644
--- a/datman/src/commands/backup.rs
+++ b/datman/src/commands/backup.rs
@@ -202,7 +202,7 @@ pub fn backup_source_to_destination<PT: ProgressTracker>(
                 parent,
                 num_workers,
                 progress_bar,
-                false,
+                true,
             )?;
 
             info!("Stored!");
diff --git a/datman/src/remote/backup_source_requester.rs b/datman/src/remote/backup_source_requester.rs
index 2272b3c..c9b8ed4 100644
--- a/datman/src/remote/backup_source_requester.rs
+++ b/datman/src/remote/backup_source_requester.rs
@@ -248,7 +248,7 @@ pub fn backup_remote_source_to_destination<PT: ProgressTracker + Send + 'static>
                 raw_pile,
                 parent,
                 progress_bar,
-                false,
+                true,
             )?;
 
             quit(&mut read, &mut write)?;
diff --git a/datman/src/remote/backup_source_responder.rs b/datman/src/remote/backup_source_responder.rs
index 65cf394..1081bfe 100644
--- a/datman/src/remote/backup_source_responder.rs
+++ b/datman/src/remote/backup_source_responder.rs
@@ -71,7 +71,7 @@ pub fn chunking<R: Read + Send + 'static, W: Write + Send + 'static>(
         parent,
         get_number_of_workers("YAMA_CHUNKERS"),
         progress_bar,
-        false,
+        true,
     )?;
 
     for join_handle in requester_join_handles {
@@ -169,7 +169,7 @@ pub fn chunking_stdio() -> anyhow::Result<()> {
             parent,
             get_number_of_workers("YAMA_CHUNKERS"),
             &mut progress_bar,
-            false,
+            true,
         )?;
 
         requester_join_handles