Fix Requester's storage pipeline not returning to issuing new commands

after pausing because too many were in flight
This commit is contained in:
Olivier 'reivilibre' 2022-01-11 07:23:32 +00:00
parent ff583d7ed0
commit b24a0771ed
1 changed files with 1 additions and 0 deletions

View File

@ -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