Index: content/browser/renderer_host/render_process_host_impl.cc |
diff --git a/content/browser/renderer_host/render_process_host_impl.cc b/content/browser/renderer_host/render_process_host_impl.cc |
index 05f7cfe9247f713183ff4e815ee5bc3a72dcd862..c2ff38227696dae820fc980d92874a03ed64da9f 100644 |
--- a/content/browser/renderer_host/render_process_host_impl.cc |
+++ b/content/browser/renderer_host/render_process_host_impl.cc |
@@ -142,6 +142,7 @@ |
#include "content/common/service_manager/service_manager_connection_impl.h" |
#include "content/common/site_isolation_policy.h" |
#include "content/common/view_messages.h" |
+#include "content/common/worker_fetch_context_factory.mojom.h" |
#include "content/public/browser/browser_context.h" |
#include "content/public/browser/browser_thread.h" |
#include "content/public/browser/content_browser_client.h" |
@@ -472,6 +473,50 @@ void ForwardShapeDetectionRequest(R request) { |
std::move(request)); |
} |
+class WorkerFetchContextFactoryImpl : public mojom::WorkerFetchContextFactory { |
+ public: |
+ static void Create( |
+ int render_process_id, |
+ ResourceMessageFilter* resource_message_filter, |
+ scoped_refptr<ServiceWorkerContextWrapper> service_worker_context, |
+ mojom::WorkerFetchContextFactoryRequest request) { |
+ DCHECK(base::FeatureList::IsEnabled(features::kOffMainThreadFetch)); |
+ mojo::MakeStrongBinding( |
+ base::MakeUnique<WorkerFetchContextFactoryImpl>( |
+ render_process_id, resource_message_filter->GetWeakPtr(), |
+ std::move(service_worker_context)), |
+ std::move(request)); |
+ } |
+ WorkerFetchContextFactoryImpl( |
+ int render_process_id, |
+ base::WeakPtr<ResourceMessageFilter> resource_message_filter, |
+ scoped_refptr<ServiceWorkerContextWrapper> service_worker_context) |
+ : render_process_id_(render_process_id), |
+ url_loader_factory_binding_(resource_message_filter.get()), |
+ service_worker_context_(std::move(service_worker_context)) {} |
+ ~WorkerFetchContextFactoryImpl() override {} |
+ |
+ void CreateWorkerFetchContext( |
+ mojom::URLLoaderFactoryAssociatedRequest loader_request, |
+ mojom::ServiceWorkerClientAssociatedPtrInfo client_ptr_info, |
+ int service_worker_provider_id) override { |
+ url_loader_factory_binding_.Bind(std::move(loader_request)); |
+ service_worker_context_->BindWorkerFetchContext(render_process_id_, |
+ service_worker_provider_id, |
+ std::move(client_ptr_info)); |
+ }; |
+ void GetURLLoaderFactory( |
+ mojom::URLLoaderFactoryAssociatedRequest loader_request) override { |
+ url_loader_factory_binding_.Bind(std::move(loader_request)); |
+ } |
+ |
+ private: |
+ const int render_process_id_; |
+ mojo::AssociatedBinding<mojom::URLLoaderFactory> url_loader_factory_binding_; |
kinuko
2017/04/14 02:27:02
Question: if ResourceMessageFilter implements its
kinuko
2017/04/14 05:38:12
Per offline discussion it looks it's not possible
|
+ |
+ scoped_refptr<ServiceWorkerContextWrapper> service_worker_context_; |
+}; |
+ |
} // namespace |
RendererMainThreadFactoryFunction g_renderer_main_thread_factory = NULL; |
@@ -1300,6 +1345,16 @@ void RenderProcessHostImpl::RegisterMojoInterfaces() { |
base::Bind(&VideoCaptureHost::Create, |
BrowserMainLoop::GetInstance()->media_stream_manager())); |
+ if (base::FeatureList::IsEnabled(features::kOffMainThreadFetch)) { |
+ scoped_refptr<ServiceWorkerContextWrapper> service_worker_context( |
+ static_cast<ServiceWorkerContextWrapper*>( |
+ storage_partition_impl_->GetServiceWorkerContext())); |
+ registry->AddInterface( |
+ base::Bind(&WorkerFetchContextFactoryImpl::Create, GetID(), |
+ base::Unretained(resource_message_filter_.get()), |
+ service_worker_context)); |
+ } |
+ |
// This is to support usage of WebSockets in cases in which there is no |
// associated RenderFrame (e.g., Shared Workers). |
AddUIThreadInterface( |