Treat ERR_CONNECTION_CLOSED as end-of-data marker for downloads.

content/browser/renderer_host/resource_dispatcher_host.cc

 // Copyright (c) 2011 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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #include "content/browser/renderer_host/resource_dispatcher_host.h"
 
 #include <set>
 #include <vector>
@@ skipping 1371 matching lines @@
 void ResourceDispatcherHost::ResumeRequest(const GlobalRequestID& request_id) {
   PendingRequestList::iterator i = pending_requests_.find(request_id);
   if (i == pending_requests_.end())  // The request may have been destroyed
     return;
 
   net::URLRequest* request = i->second;
   ResourceDispatcherHostRequestInfo* info = InfoForRequest(request);
   if (!info->is_paused())
     return;
 
-  VLOG(1) << "Resuming: " << i->second->url().spec();
+  VLOG(1) << "Resuming: \"" << i->second->url().spec() << "\""
+          << " paused_read_bytes = " << info->paused_read_bytes()
+          << " called response started = " << info->called_on_response_started()
+          << " started reading = " << info->has_started_reading();
 
   info->set_is_paused(false);
 
   if (info->called_on_response_started()) {
     if (info->has_started_reading()) {
       OnReadCompleted(i->second, info->paused_read_bytes());
     } else {
       StartReading(request);
     }
   } else {
@@ skipping 27 matching lines @@
   DCHECK(buf);
   DCHECK(buf_size > 0);
 
   info->set_has_started_reading(true);
   return request->Read(buf, buf_size, bytes_read);
 }
 
 void ResourceDispatcherHost::OnReadCompleted(net::URLRequest* request,
                                              int bytes_read) {
   DCHECK(request);
-  VLOG(1) << "OnReadCompleted: " << request->url().spec();
+  VLOG(1) << "OnReadCompleted: \"" << request->url().spec() << "\""
+          << " bytes_read = " << bytes_read;
   ResourceDispatcherHostRequestInfo* info = InfoForRequest(request);
 
   // OnReadCompleted can be called without Read (e.g., for chrome:// URLs).
   // Make sure we know that a read has begun.
   info->set_has_started_reading(true);
 
   if (PauseRequestIfNeeded(info)) {
     info->set_paused_read_bytes(bytes_read);
-    VLOG(1) << "OnReadCompleted pausing: " << request->url().spec();
+    VLOG(1) << "OnReadCompleted pausing: \"" << request->url().spec() << "\""
+            << " bytes_read = " << bytes_read;
     return;
   }
 
   if (request->status().is_success() && CompleteRead(request, &bytes_read)) {
     // The request can be paused if we realize that the renderer is not
     // servicing messages fast enough.
     if (info->pause_count() == 0 &&
         Read(request, &bytes_read) &&
         request->status().is_success()) {
       if (bytes_read == 0) {
         CompleteRead(request, &bytes_read);
       } else {
         // Force the next CompleteRead / Read pair to run as a separate task.
         // This avoids a fast, large network request from monopolizing the IO
         // thread and starving other IO operations from running.
+        VLOG(1) << "OnReadCompleted postponing: \""
+                << request->url().spec() << "\""
+                << " bytes_read = " << bytes_read;
         info->set_paused_read_bytes(bytes_read);
         info->set_is_paused(true);
         GlobalRequestID id(info->child_id(), info->request_id());
         MessageLoop::current()->PostTask(
             FROM_HERE,
             method_runner_.NewRunnableMethod(
                 &ResourceDispatcherHost::ResumeRequest, id));
         return;
       }
     }
   }
 
   if (PauseRequestIfNeeded(info)) {
     info->set_paused_read_bytes(bytes_read);
-    VLOG(1) << "OnReadCompleted (CompleteRead) pausing: "
-            << request->url().spec();
+    VLOG(1) << "OnReadCompleted (CompleteRead) pausing: \""
+            << request->url().spec() << "\""
+            << " bytes_read = " << bytes_read;
     return;
   }
 
   // If the status is not IO pending then we've either finished (success) or we
   // had an error.  Either way, we're done!
   if (!request->status().is_io_pending())
     OnResponseCompleted(request);
 }
 
 bool ResourceDispatcherHost::CompleteRead(net::URLRequest* request,
@@ skipping 498 matching lines @@
   return is_prefetch_enabled_;
 }
 
 // static
 void ResourceDispatcherHost::set_is_prefetch_enabled(bool value) {
   is_prefetch_enabled_ = value;
 }
 
 // static
 bool ResourceDispatcherHost::is_prefetch_enabled_ = false;