OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "content/renderer/service_worker/embedded_worker_context_client.h" | 5 #include "content/renderer/service_worker/embedded_worker_context_client.h" |
6 | 6 |
7 #include "base/lazy_instance.h" | 7 #include "base/lazy_instance.h" |
8 #include "base/message_loop/message_loop_proxy.h" | 8 #include "base/message_loop/message_loop_proxy.h" |
9 #include "base/pickle.h" | 9 #include "base/pickle.h" |
10 #include "base/threading/thread_local.h" | 10 #include "base/threading/thread_local.h" |
(...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
85 const GURL& script_url) | 85 const GURL& script_url) |
86 : embedded_worker_id_(embedded_worker_id), | 86 : embedded_worker_id_(embedded_worker_id), |
87 service_worker_version_id_(service_worker_version_id), | 87 service_worker_version_id_(service_worker_version_id), |
88 script_url_(script_url), | 88 script_url_(script_url), |
89 sender_(ChildThread::current()->thread_safe_sender()), | 89 sender_(ChildThread::current()->thread_safe_sender()), |
90 main_thread_proxy_(base::MessageLoopProxy::current()), | 90 main_thread_proxy_(base::MessageLoopProxy::current()), |
91 weak_factory_(this) { | 91 weak_factory_(this) { |
92 } | 92 } |
93 | 93 |
94 EmbeddedWorkerContextClient::~EmbeddedWorkerContextClient() { | 94 EmbeddedWorkerContextClient::~EmbeddedWorkerContextClient() { |
95 DCHECK(g_worker_client_tls.Pointer()->Get() != NULL); | 95 // g_worker_client_tls.Pointer()->Get() could be NULL if this gets |
| 96 // deleted before workerContextStarted() is called. |
96 g_worker_client_tls.Pointer()->Set(NULL); | 97 g_worker_client_tls.Pointer()->Set(NULL); |
97 } | 98 } |
98 | 99 |
99 bool EmbeddedWorkerContextClient::OnMessageReceived( | 100 bool EmbeddedWorkerContextClient::OnMessageReceived( |
100 const IPC::Message& msg) { | 101 const IPC::Message& msg) { |
101 bool handled = true; | 102 bool handled = true; |
102 IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerContextClient, msg) | 103 IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerContextClient, msg) |
103 IPC_MESSAGE_HANDLER(EmbeddedWorkerContextMsg_SendMessageToWorker, | 104 IPC_MESSAGE_HANDLER(EmbeddedWorkerContextMsg_SendMessageToWorker, |
104 OnSendMessageToWorker) | 105 OnSendMessageToWorker) |
105 IPC_MESSAGE_UNHANDLED(handled = false) | 106 IPC_MESSAGE_UNHANDLED(handled = false) |
(...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
226 } | 227 } |
227 | 228 |
228 void EmbeddedWorkerContextClient::SendWorkerStarted() { | 229 void EmbeddedWorkerContextClient::SendWorkerStarted() { |
229 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); | 230 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); |
230 sender_->Send(new EmbeddedWorkerHostMsg_WorkerStarted( | 231 sender_->Send(new EmbeddedWorkerHostMsg_WorkerStarted( |
231 WorkerTaskRunner::Instance()->CurrentWorkerId(), | 232 WorkerTaskRunner::Instance()->CurrentWorkerId(), |
232 embedded_worker_id_)); | 233 embedded_worker_id_)); |
233 } | 234 } |
234 | 235 |
235 } // namespace content | 236 } // namespace content |
OLD | NEW |