Get rid of URLLoaderFactory in browser-side case

content/browser/loader/mojo_async_resource_handler.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/browser/loader/mojo_async_resource_handler.h"
 
 #include <algorithm>
 #include <utility>
 #include <vector>
 
@@ skipping 102 matching lines @@
 };
 
 MojoAsyncResourceHandler::MojoAsyncResourceHandler(
     net::URLRequest* request,
     ResourceDispatcherHostImpl* rdh,
     mojom::URLLoaderAssociatedRequest mojo_request,
     mojom::URLLoaderClientPtr url_loader_client,
     ResourceType resource_type)
     : ResourceHandler(request),
       rdh_(rdh),
-      binding_(this, std::move(mojo_request)),
+      binding_(this),
       handle_watcher_(FROM_HERE, mojo::SimpleWatcher::ArmingPolicy::MANUAL),
-      url_loader_client_(std::move(url_loader_client)),
       weak_factory_(this) {
-  DCHECK(url_loader_client_);
+  Start(std::move(mojo_request), std::move(url_loader_client));
+
   InitializeResourceBufferConstants();
-  // This unretained pointer is safe, because |binding_| is owned by |this| and
-  // the callback will never be called after |this| is destroyed.
-  binding_.set_connection_error_handler(
-      base::Bind(&MojoAsyncResourceHandler::Cancel, base::Unretained(this)));
 
   if (IsResourceTypeFrame(resource_type)) {
     GetRequestInfo()->set_on_transfer(base::Bind(
         &MojoAsyncResourceHandler::OnTransfer, weak_factory_.GetWeakPtr()));
   } else {
     GetRequestInfo()->set_on_transfer(base::Bind(&NotReached));
   }
 }
 
 MojoAsyncResourceHandler::~MojoAsyncResourceHandler() {
@@ skipping 316 matching lines @@
   request_complete_data.completion_time = base::TimeTicks::Now();
   request_complete_data.encoded_data_length =
       request()->GetTotalReceivedBytes();
   request_complete_data.encoded_body_length = request()->GetRawBodyBytes();
   request_complete_data.decoded_body_length = total_written_bytes_;
 
   url_loader_client_->OnComplete(request_complete_data);
   controller->Resume();
 }
 
+void MojoAsyncResourceHandler::Start(
+    mojom::URLLoaderAssociatedRequest mojo_request,
+    mojom::URLLoaderClientPtr url_loader_client) {
+  DCHECK(!binding_.is_bound());
+
+  binding_.Bind(std::move(mojo_request));
+  // This unretained pointer is safe, because |binding_| is owned by |this| and
+  // the callback will never be called after |this| is destroyed.
+  binding_.set_connection_error_handler(
+      base::Bind(&MojoAsyncResourceHandler::Cancel, base::Unretained(this)));
+
+  url_loader_client_ = std::move(url_loader_client);
+  DCHECK(url_loader_client_);
+}
+
 bool MojoAsyncResourceHandler::CopyReadDataToDataPipe(bool* defer) {
   while (buffer_bytes_read_ > 0) {
     scoped_refptr<net::IOBufferWithSize> dest;
     if (!AllocateWriterIOBuffer(&dest, defer))
       return false;
     if (*defer)
       return true;
 
     size_t copied_size =
         std::min(buffer_bytes_read_, static_cast<size_t>(dest->size()));
@@ skipping 124 matching lines @@
       base::Bind(&MojoAsyncResourceHandler::OnUploadProgressACK,
                  weak_factory_.GetWeakPtr()));
 }
 
 void MojoAsyncResourceHandler::OnUploadProgressACK() {
   if (upload_progress_tracker_)
     upload_progress_tracker_->OnAckReceived();
 }
 
 }  // namespace content