[Mojo-Loading] Use independent URLLoaderClient

content/child/url_loader_client_impl.cc

 // Copyright 2016 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/url_loader_client_impl.h"
 
 #include "base/callback.h"
 #include "base/single_thread_task_runner.h"
 #include "content/child/resource_dispatcher.h"
 #include "content/child/url_response_body_consumer.h"
@@ skipping 10 matching lines @@
       request_id_(request_id),
       resource_dispatcher_(resource_dispatcher),
       task_runner_(std::move(task_runner)),
       weak_factory_(this) {}
 
 URLLoaderClientImpl::~URLLoaderClientImpl() {
   if (body_consumer_)
     body_consumer_->Cancel();
 }
 
-void URLLoaderClientImpl::Bind(
-    mojom::URLLoaderClientAssociatedPtrInfo* client_ptr_info) {
-  // TODO(yhirano): Use |task_runner_| here.
-  // Currently it is unable because of a ChannelAssociatedInterface restriction.
-  binding_.Bind(client_ptr_info);
+void URLLoaderClientImpl::Bind(mojom::URLLoaderClientPtr* client_ptr) {
+  binding_.Bind(client_ptr, task_runner_);
 }
 
 void URLLoaderClientImpl::SetDefersLoading() {
   is_deferred_ = true;
   if (body_consumer_)
     body_consumer_->SetDefersLoading();
 }
 
 void URLLoaderClientImpl::UnsetDefersLoading() {
   is_deferred_ = false;
@@ skipping 59 matching lines @@
   if (has_completion_message) {
     DCHECK_GT(messages.size(), 0u);
     DCHECK_EQ(messages.back().type(),
               static_cast<uint32_t>(ResourceMsg_RequestComplete::ID));
     Dispatch(messages.back());
   }
 }
 
 void URLLoaderClientImpl::OnReceiveResponse(
     const ResourceResponseHead& response_head,
-    mojom::DownloadedTempFileAssociatedPtrInfo downloaded_file) {
+    mojom::DownloadedTempFilePtr downloaded_file) {
   has_received_response_ = true;
-  downloaded_file_.Bind(std::move(downloaded_file));
+  downloaded_file_ = std::move(downloaded_file);
   Dispatch(ResourceMsg_ReceivedResponse(request_id_, response_head));
 }
 
 void URLLoaderClientImpl::OnReceiveRedirect(
     const net::RedirectInfo& redirect_info,
     const ResourceResponseHead& response_head) {
   DCHECK(!has_received_response_);
   DCHECK(!body_consumer_);
   Dispatch(
       ResourceMsg_ReceivedRedirect(request_id_, redirect_info, response_head));
@@ skipping 52 matching lines @@
 
 void URLLoaderClientImpl::OnUploadProgress(int64_t current_position,
                                            int64_t total_size,
                                            const base::Closure& ack_callback) {
   Dispatch(
       ResourceMsg_UploadProgress(request_id_, current_position, total_size));
   ack_callback.Run();
 }
 
 }  // namespace content