Index: content/renderer/service_worker/service_worker_context_client.cc |
diff --git a/content/renderer/service_worker/service_worker_context_client.cc b/content/renderer/service_worker/service_worker_context_client.cc |
index 4efd01bca69345e152c32b5d28ea24e8077500d7..1009bcb840fadc9301539a16c2ccbd38217bcbf9 100644 |
--- a/content/renderer/service_worker/service_worker_context_client.cc |
+++ b/content/renderer/service_worker/service_worker_context_client.cc |
@@ -40,6 +40,7 @@ |
#include "content/renderer/devtools/devtools_agent.h" |
#include "content/renderer/render_thread_impl.h" |
#include "content/renderer/service_worker/embedded_worker_dispatcher.h" |
+#include "content/renderer/service_worker/embedded_worker_instance_client_impl.h" |
#include "content/renderer/service_worker/service_worker_type_util.h" |
#include "ipc/ipc_message.h" |
#include "ipc/ipc_message_macros.h" |
@@ -221,7 +222,8 @@ ServiceWorkerContextClient::ServiceWorkerContextClient( |
int64_t service_worker_version_id, |
const GURL& service_worker_scope, |
const GURL& script_url, |
- int worker_devtools_agent_route_id) |
+ int worker_devtools_agent_route_id, |
+ std::unique_ptr<EmbeddedWorkerInstanceClientImpl> embedded_worker_client) |
: embedded_worker_id_(embedded_worker_id), |
service_worker_version_id_(service_worker_version_id), |
service_worker_scope_(service_worker_scope), |
@@ -229,7 +231,8 @@ ServiceWorkerContextClient::ServiceWorkerContextClient( |
worker_devtools_agent_route_id_(worker_devtools_agent_route_id), |
sender_(ChildThreadImpl::current()->thread_safe_sender()), |
main_thread_task_runner_(base::ThreadTaskRunnerHandle::Get()), |
- proxy_(nullptr) { |
+ proxy_(nullptr), |
+ embedded_worker_client_(std::move(embedded_worker_client)) { |
TRACE_EVENT_ASYNC_BEGIN0("ServiceWorker", |
"ServiceWorkerContextClient::StartingWorkerContext", |
this); |
@@ -441,6 +444,15 @@ void ServiceWorkerContextClient::willDestroyWorkerContext( |
void ServiceWorkerContextClient::workerContextDestroyed() { |
DCHECK(g_worker_client_tls.Pointer()->Get() == NULL); |
+ // Check if mojo is enabled |
+ if (embedded_worker_client_) { |
horo
2016/09/27 01:59:23
if (ServiceWorkerUtils::IsMojoForServiceWorkerEnab
shimazu
2016/10/06 03:50:51
Done.
|
+ main_thread_task_runner_->PostTask( |
+ FROM_HERE, |
+ base::Bind(&EmbeddedWorkerInstanceClientImpl::StopWorkerCompleted, |
+ base::Passed(std::move(embedded_worker_client_)))); |
dcheng
2016/09/30 08:25:28
base::Passed(&embedded_worker_client_)
shimazu
2016/10/06 03:50:51
Done.
|
+ return; |
+ } |
+ |
// Now we should be able to free the WebEmbeddedWorker container on the |
// main thread. |
main_thread_task_runner_->PostTask( |