Use mojo for Chrome Loading, Part 1

content/browser/loader/url_loader_factory_impl.cc

Index: content/browser/loader/url_loader_factory_impl.cc
diff --git a/content/browser/loader/url_loader_factory_impl.cc b/content/browser/loader/url_loader_factory_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..60c83ceeb94f375c3b961fb6017cdf9e60fe8deb
--- /dev/null
+++ b/content/browser/loader/url_loader_factory_impl.cc
@@ -0,0 +1,93 @@
+// 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/url_loader_factory_impl.h"
+
+#include <memory>
+
+#include "base/memory/ptr_util.h"
+#include "base/memory/weak_ptr.h"
+#include "content/browser/loader/resource_dispatcher_host_impl.h"
+#include "content/browser/loader/resource_message_filter.h"
+#include "content/common/resource_messages.h"
+#include "content/common/url_loader.mojom.h"
+#include "content/common/url_loader_factory.mojom.h"
+#include "content/common/url_loader_type_converters.h"
+
+namespace content {
+
+namespace {
+
+class URLLoaderImpl final : public mojom::URLLoader {
+ public:
+  static void Create(scoped_refptr<ResourceMessageFilter> filter,
+                     mojom::URLLoaderRequest request) {
+    int child_id = filter->child_id();
+    ResourceDispatcherHostImpl::Get()->AddUninitiatedURLLoader(
+        child_id,
+        base::WrapUnique(new URLLoaderImpl(filter.get(), std::move(request))));
+  }
+
+  ~URLLoaderImpl() override {}
+
+  void Load(mojom::URLRequestPtr request,
+            mojom::URLLoaderClientPtr client) override {
+    DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+    ResourceMessageFilter* filter = resource_message_filter_.get();
+    if (!filter) {
+      // TODO(yhirano): Cancel the request.
+      return;
+    }
+
+    request_id_ = request->request_id;
+    routing_id_ = request->routing_id;
+
+    std::unique_ptr<mojom::URLLoader> that =
+        ResourceDispatcherHostImpl::Get()->TakeUninitiatedURLLoader(this);
+    DCHECK(that);
+
+    ResourceDispatcherHostImpl* rdh = ResourceDispatcherHostImpl::Get();
+    rdh->SetMojoLoaderAndClientrForNextLoadRequest(std::move(that),
+                                                   std::move(client));
+    rdh->OnMessageReceived(
+        ResourceHostMsg_RequestResource(routing_id_, request_id_,
+                                        request->To<ResourceHostMsg_Request>()),
+        filter);
+  }
+  void FollowRedirect() override {}
+  void Cancel() override {}
+
+ private:
+  URLLoaderImpl(ResourceMessageFilter* filter,
+                mojo::InterfaceRequest<mojom::URLLoader> request)
+      : resource_message_filter_(filter->GetWeakPtr()),
+        binding_(this, std::move(request)) {}
+
+  base::WeakPtr<ResourceMessageFilter> resource_message_filter_;
+  int32_t request_id_ = -1;
+  int32_t routing_id_ = -1;
+  mojo::Binding<mojom::URLLoader> binding_;
+};
+
+}  // namespace
+
+URLLoaderFactoryImpl::URLLoaderFactoryImpl(
+    scoped_refptr<ResourceMessageFilter> resource_message_filter,
+    mojo::InterfaceRequest<mojom::URLLoaderFactory> request)
+    : resource_message_filter_(resource_message_filter),
+      binding_(this, std::move(request)) {}
+
+URLLoaderFactoryImpl::~URLLoaderFactoryImpl() {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+}
+
+void URLLoaderFactoryImpl::CreateURLLoader(mojom::URLLoaderRequest request) {
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      base::Bind(&URLLoaderImpl::Create, resource_message_filter_,
+                 base::Passed(std::move(request))));
+}
+
+}  // namespace content