[proof-of-concept] SW thread independent of the main thread

content/browser/renderer_host/render_process_host_impl.cc

 // Copyright 2012 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.
 
 // Represents the browser side of the browser <--> renderer communication
 // channel. There will be one RenderProcessHost per renderer process.
 
 #include "content/browser/renderer_host/render_process_host_impl.h"
 
 #include <algorithm>
@@ skipping 116 matching lines @@
 #include "content/common/child_process_messages.h"
 #include "content/common/content_switches_internal.h"
 #include "content/common/frame_messages.h"
 #include "content/common/gpu_host_messages.h"
 #include "content/common/in_process_child_thread_params.h"
 #include "content/common/mojo/constants.h"
 #include "content/common/mojo/mojo_child_connection.h"
 #include "content/common/mojo/mojo_shell_connection_impl.h"
 #include "content/common/render_process_messages.h"
 #include "content/common/resource_messages.h"
+#include "content/common/service_worker/embedded_worker_setup.mojom.h"
 #include "content/common/site_isolation_policy.h"
 #include "content/common/view_messages.h"
 #include "content/public/browser/browser_context.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/content_browser_client.h"
 #include "content/public/browser/notification_service.h"
 #include "content/public/browser/notification_types.h"
 #include "content/public/browser/render_process_host_factory.h"
 #include "content/public/browser/render_process_host_observer.h"
 #include "content/public/browser/render_widget_host.h"
@@ skipping 308 matching lines @@
   DISALLOW_COPY_AND_ASSIGN(SessionStorageHolder);
 };
 
 void CreateMemoryCoordinatorHandle(
     int render_process_id,
     memory_coordinator::mojom::MemoryCoordinatorHandleRequest request) {
   memory_coordinator::MemoryCoordinator::GetInstance()->CreateHandle(
       render_process_id, std::move(request));
 }
 
+class IsolatedWorkerDispatcherRecieverImpl
+    : public mojom::IsolatedWorkerDispatcherReciever {
+ public:
+  IsolatedWorkerDispatcherRecieverImpl(
+      base::WeakPtr<RenderProcessHostImpl> process,
+      mojom::IsolatedWorkerDispatcherRecieverRequest request)
+      : process_(process), binding_(this, std::move(request)) {
+    TRACE_EVENT0("ServiceWorker",
+                 "IsolatedWorkerDispatcherRecieverImpl::"
+                 "IsolatedWorkerDispatcherRecieverImpl");
+    LOG(ERROR) << "IsolatedWorkerDispatcherRecieverImpl";
+  }
+  ~IsolatedWorkerDispatcherRecieverImpl() override {
+    LOG(ERROR) << "~IsolatedWorkerDispatcherRecieverImpl";
+  }
+
+  void SetDispatcher(mojom::IsolatedWorkerDispatcherPtr dispatcher) override {
+    TRACE_EVENT0("ServiceWorker",
+                 "IsolatedWorkerDispatcherRecieverImpl::SetDispatcher");
+    LOG(ERROR) << "IsolatedWorkerDispatcherRecieverImpl::SetDispatcher";
+    if (process_)
+      process_->SetIsolatedWorkerDispatcher(std::move(dispatcher));
+  }
+
+ private:
+  base::WeakPtr<RenderProcessHostImpl> process_;
+  mojo::StrongBinding<mojom::IsolatedWorkerDispatcherReciever> binding_;
+};
+
+void CreateIsolatedWorkerDispatcherReciever(
+    base::WeakPtr<RenderProcessHostImpl> process,
+    mojom::IsolatedWorkerDispatcherRecieverRequest request) {
+  TRACE_EVENT0("ServiceWorker", "CreateIsolatedWorkerDispatcherReciever");
+  LOG(ERROR) << "CreateIsolatedWorkerDispatcherReciever";
+  new IsolatedWorkerDispatcherRecieverImpl(process, std::move(request));
+}
+
 }  // namespace
 
 RendererMainThreadFactoryFunction g_renderer_main_thread_factory = NULL;
 
 base::MessageLoop* g_in_process_thread;
 
 // Stores the maximum number of renderer processes the content module can
 // create.
 static size_t g_max_renderer_count_override = 0;
 
@@ skipping 739 matching lines @@
       registry.get(),
       base::Bind(&BackgroundSyncContext::CreateService,
                  base::Unretained(
                      storage_partition_impl_->GetBackgroundSyncContext())));
   AddUIThreadInterface(
       registry.get(),
       base::Bind(&PlatformNotificationContextImpl::CreateService,
                  base::Unretained(
                      storage_partition_impl_->GetPlatformNotificationContext()),
                  GetID()));
+  AddUIThreadInterface(registry.get(),
+                       base::Bind(&CreateIsolatedWorkerDispatcherReciever,
+                                  weak_factory_.GetWeakPtr()));
   AddUIThreadInterface(
       registry.get(),
       base::Bind(&RenderProcessHostImpl::CreateStoragePartitionService,
                  base::Unretained(this)));
   AddUIThreadInterface(
       registry.get(),
       base::Bind(&BroadcastChannelProvider::Connect,
                  base::Unretained(
                      storage_partition_impl_->GetBroadcastChannelProvider())));
   if (memory_coordinator::IsEnabled()) {
@@ skipping 10 matching lines @@
                          file_task_runner);
 #endif
 
   // These callbacks will be run immediately on the IO thread.
   registry->AddInterface(base::Bind(&DeviceLightHost::Create));
   registry->AddInterface(base::Bind(&DeviceMotionHost::Create));
   registry->AddInterface(base::Bind(&DeviceOrientationHost::Create));
   registry->AddInterface(base::Bind(&DeviceOrientationAbsoluteHost::Create));
   registry->AddInterface(
       base::Bind(&URLLoaderFactoryImpl::Create, resource_message_filter_));
+  registry->AddInterface(base::Bind(
+      &ServiceWorkerContextWrapper::CreateService,
+      base::Unretained(storage_partition_impl_->GetServiceWorkerContext())));
 
   // This is to support usage of WebSockets in cases in which there is no
   // associated RenderFrame (e.g., Shared Workers).
   AddUIThreadInterface(
       registry.get(), base::Bind(&WebSocketManager::CreateWebSocket, GetID(),
                                  MSG_ROUTING_NONE));
 
   GetContentClient()->browser()->ExposeInterfacesToRenderer(registry.get(),
                                                             this);
 
@@ skipping 1664 matching lines @@
     return;
   LOG(ERROR) << "Terminating render process for bad Mojo message: " << error;
 
   // The ReceivedBadMessage call below will trigger a DumpWithoutCrashing. Alias
   // enough information here so that we can determine what the bad message was.
   base::debug::Alias(&error);
   bad_message::ReceivedBadMessage(process.get(),
                                   bad_message::RPH_MOJO_PROCESS_ERROR);
 }
 
+void RenderProcessHostImpl::SetIsolatedWorkerDispatcher(
+    mojo::InterfacePtr<mojom::IsolatedWorkerDispatcher> dispatcher) {
+  LOG(ERROR)
+      << "RenderProcessHostImpl::SetIsolatedWorkerDispatcher----------SetSet";
+  isolated_worker_dispatcher_.reset(
+      new mojom::IsolatedWorkerDispatcherPtr(std::move(dispatcher)));
+  if (isolated_worker_dispatcher_callbacks_.empty())
+    return;
+  std::vector<base::Callback<void(
+      mojo::InterfacePtr<mojom::IsolatedWorkerDispatcher>*)>>
+      callbacks;
+  callbacks.swap(isolated_worker_dispatcher_callbacks_);
+  for (auto& callback : callbacks) {
+    LOG(ERROR)
+        << "callback>><>>><><><<<>><>>><><><<<>><>>><><><<<>><>>><><><<<";
+    callback.Run(isolated_worker_dispatcher_.get());
+  }
+}
+void RenderProcessHostImpl::GetIsolatedWorkerDispatcher(
+    const base::Callback<
+        void(mojo::InterfacePtr<mojom::IsolatedWorkerDispatcher>*)>& callback) {
+  LOG(ERROR) << "GetIsolatedWorkerDispatcher";
+  if (isolated_worker_dispatcher_) {
+    callback.Run(isolated_worker_dispatcher_.get());
+    return;
+  }
+  LOG(ERROR) << "adding to "
+                "callback>><>>><><><<<>><>>><><><<<>><>>><><><<<>><>>><><><<"
+                "<";
+  isolated_worker_dispatcher_callbacks_.push_back(callback);
+}
+
 }  // namespace content