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 |