Propagate server response error and interrupt the download.

content/browser/download/parallel_download_job.cc

 // Copyright 2017 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/browser/download/parallel_download_job.h"
 
 #include "base/memory/ptr_util.h"
 #include "content/browser/download/download_create_info.h"
 #include "content/browser/download/parallel_download_utils.h"
 #include "content/public/browser/browser_context.h"
@@ skipping 71 matching lines @@
                &ParallelDownloadJob::BuildParallelRequests);
 }
 
 void ParallelDownloadJob::OnByteStreamReady(
     DownloadWorker* worker,
     std::unique_ptr<ByteStreamReader> stream_reader) {
   DownloadJob::AddByteStream(std::move(stream_reader), worker->offset(),
                              worker->length());
 }
 
+void ParallelDownloadJob::OnServerResponseError(
+    DownloadWorker* worker,
+    DownloadInterruptReason reason) {
+  // TODO(xingliu): Consider to let the original request to cover the full
+  // content if the sub-requests get invalid response. Consider retry on certain
+  // error.
+  DownloadJob::Interrupt(reason);
+}
+
 void ParallelDownloadJob::BuildParallelRequests() {
   DCHECK(!requests_sent_);
   // TODO(qinmin): The size of |slices_to_download| should be no larger than
   // |kParallelRequestCount| unless |kParallelRequestCount| is changed after
   // a download is interrupted. This could happen if we use finch to config
   // the number of parallel requests.
   // Get the next |kParallelRequestCount - 1| slices and fork
   // new requests. For the remaining slices, they will be handled once some
   // of the workers finish their job.
   DownloadItem::ReceivedSlices slices_to_download;
@@ skipping 59 matching lines @@
   // download request.
   download_params->set_referrer(Referrer(download_item_->GetReferrerUrl(),
                                          blink::WebReferrerPolicyAlways));
   // Send the request.
   worker->SendRequest(std::move(download_params));
   DCHECK(workers_.find(offset) == workers_.end());
   workers_[offset] = std::move(worker);
 }
 
 }  // namespace content