Fix and refactor downloaded file handling in the loading stack

content/child/resource_dispatcher.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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #include "content/child/resource_dispatcher.h"
 
 #include <utility>
 
@@ skipping 70 matching lines @@
   URLLoaderClientImpl(int request_id,
                       ResourceDispatcher* resource_dispatcher,
                       scoped_refptr<base::SingleThreadTaskRunner> task_runner)
       : binding_(this),
         request_id_(request_id),
         resource_dispatcher_(resource_dispatcher),
         task_runner_(std::move(task_runner)) {}
   ~URLLoaderClientImpl() override {
     if (body_consumer_)
       body_consumer_->Cancel();
+    if (downloaded_file_)
+      downloaded_file_->Release();
   }
 
-  void OnReceiveResponse(const ResourceResponseHead& response_head) override {
+  void OnReceiveResponse(
+      const ResourceResponseHead& response_head,
+      mojom::DownloadedTempFilePtr downloaded_file) override {
     has_received_response_ = true;
     if (body_consumer_)
       body_consumer_->Start(task_runner_.get());
+    downloaded_file_ = std::move(downloaded_file);
     resource_dispatcher_->OnMessageReceived(
         ResourceMsg_ReceivedResponse(request_id_, response_head));
   }
 
   void OnDataDownloaded(int64_t data_len, int64_t encoded_data_len) override {
     resource_dispatcher_->OnMessageReceived(
         ResourceMsg_DataDownloaded(request_id_, data_len, encoded_data_len));
   }
 
   void OnStartLoadingResponseBody(
@@ skipping 15 matching lines @@
   }
 
   void Bind(mojom::URLLoaderClientAssociatedPtrInfo* client_ptr_info,
             mojo::AssociatedGroup* associated_group) {
     binding_.Bind(client_ptr_info, associated_group);
   }
 
  private:
   mojo::AssociatedBinding<mojom::URLLoaderClient> binding_;
   scoped_refptr<URLResponseBodyConsumer> body_consumer_;
+  mojom::DownloadedTempFilePtr downloaded_file_;
   const int request_id_;
   bool has_received_response_ = false;
   ResourceDispatcher* const resource_dispatcher_;
   scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
 };
 
 void CheckSchemeForReferrerPolicy(const ResourceRequest& request) {
   if ((request.referrer_policy == blink::WebReferrerPolicyDefault ||
        request.referrer_policy ==
            blink::WebReferrerPolicyNoReferrerWhenDowngrade) &&
@@ skipping 695 matching lines @@
     delete message;
   }
 }
 
 void ResourceDispatcher::SetResourceSchedulingFilter(
     scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter) {
   resource_scheduling_filter_ = resource_scheduling_filter;
 }
 
 }  // namespace content