Handle the situation when remote server returns Connection: close

after several pipelined requests.

We call Request::setMaxPipelinedRequest(1) if Connection: close is
received. Also call Request::supportsPersistentConnection(true) and
Request::setMaxPipelinedRequest(1) when closing the connection.

1 files changed, 6 insertions, 0 deletions

diff --git a/src/AbstractCommand.cc b/src/AbstractCommand.cc
index 5a15e86a..b4e5ee2f 100644
--- a/src/AbstractCommand.cc
+++ b/src/AbstractCommand.cc
@@ -347,6 +347,12 @@ bool AbstractCommand::prepareForRetry(time_t wait) {
     getSegmentMan()->cancelSegment(getCuid());
   }
   if(req_) {
+    // Reset persistentConnection and maxPipelinedRequest to handle
+    // the situation where remote server returns Connection: close
+    // after several pipelined requests.
+    req_->supportsPersistentConnection(true);
+    req_->setMaxPipelinedRequest(1);
+
     fileEntry_->poolRequest(req_);
     A2_LOG_DEBUG(fmt("CUID#%lld - Pooling request URI=%s",
                      getCuid(), req_->getUri().c_str()));