HttpStreamParser: Don't reuse sockets which receive unparsed data.

net/http/http_response_body_drainer.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/http/http_response_body_drainer.h"
 
 #include "base/compiler_specific.h"
 #include "base/logging.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
 #include "net/http/http_network_session.h"
+#include "net/http/http_response_info.h"
 #include "net/http/http_stream.h"
 
 namespace net {
 
-HttpResponseBodyDrainer::HttpResponseBodyDrainer(HttpStream* stream)
-    : stream_(stream),
+HttpResponseBodyDrainer::HttpResponseBodyDrainer(
+    HttpStream* stream,
+    scoped_ptr<HttpResponseInfo> response_info)
+    : response_info_(std::move(response_info)),
+      stream_(stream),
       next_state_(STATE_NONE),
       total_read_(0),
-      session_(NULL) {}
+      session_(nullptr) {}
 
 HttpResponseBodyDrainer::~HttpResponseBodyDrainer() {}
 
 void HttpResponseBodyDrainer::Start(HttpNetworkSession* session) {
   read_buf_ = new IOBuffer(kDrainBodyBufferSize);
   next_state_ = STATE_DRAIN_RESPONSE_BODY;
   int rv = DoLoop(OK);
 
   if (rv == ERR_IO_PENDING) {
     timer_.Start(FROM_HERE,
@@ skipping 75 matching lines @@
 void HttpResponseBodyDrainer::OnTimerFired() {
   Finish(ERR_TIMED_OUT);
 }
 
 void HttpResponseBodyDrainer::Finish(int result) {
   DCHECK_NE(ERR_IO_PENDING, result);
 
   if (session_)
     session_->RemoveResponseDrainer(this);
 
-  if (result < 0) {
+  if (result < 0 || !stream_->CanReuseConnection()) {
     stream_->Close(true /* no keep-alive */);
   } else {
     DCHECK_EQ(OK, result);
     stream_->Close(false /* keep-alive */);
   }
 
   delete this;
 }
 
 }  // namespace net