From b24a0771ed78c2a90f075f6b452ef31186a47c39 Mon Sep 17 00:00:00 2001
From: Olivier 'reivilibre <olivier@librepush.net>
Date: Tue, 11 Jan 2022 07:23:32 +0000
Subject: [PATCH] Fix Requester's storage pipeline not returning to issuing new
 commands

after pausing because too many were in flight
---
 yama/src/remote/requester.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/yama/src/remote/requester.rs b/yama/src/remote/requester.rs
index c39f2f6..142d540 100644
--- a/yama/src/remote/requester.rs
+++ b/yama/src/remote/requester.rs
@@ -401,6 +401,7 @@ impl RawPile for Requester {
                         // Either the pipeline is stopping or we are too busy to accept new chunks,
                         // so only process responses.
                         let resp = response_rx.recv().unwrap();
+                        in_flight_writes -= 1;
                         match resp {
                             ResponseBody::Success => {
                                 // nop