Set error on WebDataConsumerHandle while loading body.

content/child/web_url_loader_impl.cc

 // Copyright 2014 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 "content/child/web_url_loader_impl.h"
 
 #include <algorithm>
 #include <string>
 
 #include "base/bind.h"
@@ skipping 344 matching lines @@
       request_id_(-1) {
 }
 
 void WebURLLoaderImpl::Context::Cancel() {
   if (resource_dispatcher_ && // NULL in unittest.
       request_id_ != -1) {
     resource_dispatcher_->Cancel(request_id_);
     request_id_ = -1;
   }
 
+  if (body_stream_writer_)
+    body_stream_writer_->Fail();
+
   // Ensure that we do not notify the multipart delegate anymore as it has
   // its own pointer to the client.
   if (multipart_delegate_)
     multipart_delegate_->Cancel();
   // Ditto for the ftp delegate.
   if (ftp_listing_delegate_)
     ftp_listing_delegate_->Cancel();
 
   // Do not make any further calls to the client.
   client_ = NULL;
@@ skipping 346 matching lines @@
   scoped_refptr<Context> protect(this);
 
   if (ftp_listing_delegate_) {
     ftp_listing_delegate_->OnCompletedRequest();
     ftp_listing_delegate_.reset(NULL);
   } else if (multipart_delegate_) {
     multipart_delegate_->OnCompletedRequest();
     multipart_delegate_.reset(NULL);
   }
 
-  if (request_.useStreamOnResponse()) {
-    // TODO(yhirano): Notify error.
-    body_stream_writer_.reset();
-  }
+  if (body_stream_writer_ && error_code != net::OK)
+    body_stream_writer_->Fail();
+  body_stream_writer_.reset();
 
   if (client_) {
     if (error_code != net::OK) {
       client_->didFail(
           loader_,
           CreateWebURLError(request_.url(), stale_copy_in_cache, error_code));
     } else {
       client_->didFinishLoading(loader_,
                                 (completion_time - TimeTicks()).InSecondsF(),
                                 total_transfer_size);
@@ skipping 253 matching lines @@
                                          int intra_priority_value) {
   context_->DidChangePriority(new_priority, intra_priority_value);
 }
 
 bool WebURLLoaderImpl::attachThreadedDataReceiver(
     blink::WebThreadedDataReceiver* threaded_data_receiver) {
   return context_->AttachThreadedDataReceiver(threaded_data_receiver);
 }
 
 }  // namespace content