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..42a2b68a77e44a1ead41f24c9039e1dc4ffdde28 |
--- /dev/null |
+++ b/content/browser/loader/url_loader_factory_impl.cc |
@@ -0,0 +1,90 @@ |
+// 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/resource_request.h" |
+#include "content/common/url_loader.mojom.h" |
+ |
+namespace content { |
+ |
+namespace { |
+ |
+// This class is an implementation of mojom::URLLoader which is a resource |
+// loader interface with Mojo. |
+class URLLoaderImpl final : public mojom::URLLoader { |
+ public: |
+ // Creates a URLLoader. This function returns nothing and registers the |
+ // created instance to the ResourceDispatcherHostImpl instead. |
+ static void Create(scoped_refptr<ResourceMessageFilter> filter, |
+ mojom::URLLoaderRequest request) { |
+ int child_id = filter->child_id(); |
+ ResourceDispatcherHostImpl::Get()->AddUninitiatedURLLoader( |
mmenke
2016/05/25 16:17:20
"Uninitiated" seems like a more ambiguous term for
yhirano
2016/05/26 15:42:44
Done.
|
+ child_id, |
+ base::WrapUnique(new URLLoaderImpl(filter.get(), std::move(request)))); |
mmenke
2016/05/25 16:17:20
This ownership model seems really weird and non-ob
yhirano
2016/05/26 15:42:44
URLLoaderImpl uses mojo::Binding[1]. mojo::Binding
|
+ } |
+ |
+ ~URLLoaderImpl() override {} |
+ |
+ void Load(int32_t request_id, |
+ const ResourceRequest& request, |
+ mojom::URLLoaderClientPtr client) override { |
+ DCHECK_CURRENTLY_ON(BrowserThread::IO); |
+ |
+ ResourceMessageFilter* filter = resource_message_filter_.get(); |
+ if (!filter) { |
+ // TODO(yhirano): Cancel the request. |
+ return; |
+ } |
+ |
+ std::unique_ptr<mojom::URLLoader> that = |
+ ResourceDispatcherHostImpl::Get()->TakeUninitiatedURLLoader(this); |
+ DCHECK(that); |
+ |
+ // TODO(yhirano): Provide the right routing ID. |
+ const int routing_id = 0; |
+ ResourceDispatcherHostImpl* rdh = ResourceDispatcherHostImpl::Get(); |
+ rdh->OnRequestResourceWithMojo(routing_id, request_id, request, |
+ std::move(that), std::move(client), 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_; |
+ 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 |