Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1103)

Side by Side Diff: content/renderer/service_worker/embedded_worker_context_client.cc

Issue 252633003: Introduce worker_devtools_agent_route_id for EmbeddedWorker. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: add comment Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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"
11 #include "content/child/request_extra_data.h" 11 #include "content/child/request_extra_data.h"
12 #include "content/child/service_worker/service_worker_network_provider.h" 12 #include "content/child/service_worker/service_worker_network_provider.h"
13 #include "content/child/thread_safe_sender.h" 13 #include "content/child/thread_safe_sender.h"
14 #include "content/child/worker_task_runner.h" 14 #include "content/child/worker_task_runner.h"
15 #include "content/child/worker_thread_task_runner.h" 15 #include "content/child/worker_thread_task_runner.h"
16 #include "content/common/devtools_messages.h"
16 #include "content/common/service_worker/embedded_worker_messages.h" 17 #include "content/common/service_worker/embedded_worker_messages.h"
17 #include "content/common/service_worker/service_worker_types.h" 18 #include "content/common/service_worker/service_worker_types.h"
18 #include "content/public/renderer/document_state.h" 19 #include "content/public/renderer/document_state.h"
19 #include "content/renderer/render_thread_impl.h" 20 #include "content/renderer/render_thread_impl.h"
20 #include "content/renderer/service_worker/embedded_worker_dispatcher.h" 21 #include "content/renderer/service_worker/embedded_worker_dispatcher.h"
21 #include "content/renderer/service_worker/service_worker_script_context.h" 22 #include "content/renderer/service_worker/service_worker_script_context.h"
22 #include "ipc/ipc_message_macros.h" 23 #include "ipc/ipc_message_macros.h"
23 #include "third_party/WebKit/public/platform/WebServiceWorkerResponse.h" 24 #include "third_party/WebKit/public/platform/WebServiceWorkerResponse.h"
24 #include "third_party/WebKit/public/platform/WebString.h" 25 #include "third_party/WebKit/public/platform/WebString.h"
25 #include "third_party/WebKit/public/web/WebDataSource.h" 26 #include "third_party/WebKit/public/web/WebDataSource.h"
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
76 77
77 EmbeddedWorkerContextClient* 78 EmbeddedWorkerContextClient*
78 EmbeddedWorkerContextClient::ThreadSpecificInstance() { 79 EmbeddedWorkerContextClient::ThreadSpecificInstance() {
79 return g_worker_client_tls.Pointer()->Get(); 80 return g_worker_client_tls.Pointer()->Get();
80 } 81 }
81 82
82 EmbeddedWorkerContextClient::EmbeddedWorkerContextClient( 83 EmbeddedWorkerContextClient::EmbeddedWorkerContextClient(
83 int embedded_worker_id, 84 int embedded_worker_id,
84 int64 service_worker_version_id, 85 int64 service_worker_version_id,
85 const GURL& service_worker_scope, 86 const GURL& service_worker_scope,
86 const GURL& script_url) 87 const GURL& script_url,
88 int worker_devtools_agent_route_id)
87 : embedded_worker_id_(embedded_worker_id), 89 : embedded_worker_id_(embedded_worker_id),
88 service_worker_version_id_(service_worker_version_id), 90 service_worker_version_id_(service_worker_version_id),
89 service_worker_scope_(service_worker_scope), 91 service_worker_scope_(service_worker_scope),
90 script_url_(script_url), 92 script_url_(script_url),
93 worker_devtools_agent_route_id_(worker_devtools_agent_route_id),
91 sender_(ChildThread::current()->thread_safe_sender()), 94 sender_(ChildThread::current()->thread_safe_sender()),
92 main_thread_proxy_(base::MessageLoopProxy::current()), 95 main_thread_proxy_(base::MessageLoopProxy::current()),
93 weak_factory_(this) { 96 weak_factory_(this) {
94 } 97 }
95 98
96 EmbeddedWorkerContextClient::~EmbeddedWorkerContextClient() { 99 EmbeddedWorkerContextClient::~EmbeddedWorkerContextClient() {
97 // g_worker_client_tls.Pointer()->Get() could be NULL if this gets 100 // g_worker_client_tls.Pointer()->Get() could be NULL if this gets
98 // deleted before workerContextStarted() is called. 101 // deleted before workerContextStarted() is called.
99 g_worker_client_tls.Pointer()->Set(NULL); 102 g_worker_client_tls.Pointer()->Set(NULL);
100 } 103 }
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after
183 params.source_identifier = source; 186 params.source_identifier = source;
184 params.message_level = level; 187 params.message_level = level;
185 params.message = message; 188 params.message = message;
186 params.line_number = line_number; 189 params.line_number = line_number;
187 params.source_url = GURL(source_url); 190 params.source_url = GURL(source_url);
188 191
189 Send(new EmbeddedWorkerHostMsg_ReportConsoleMessage( 192 Send(new EmbeddedWorkerHostMsg_ReportConsoleMessage(
190 embedded_worker_id_, params)); 193 embedded_worker_id_, params));
191 } 194 }
192 195
196 void EmbeddedWorkerContextClient::dispatchDevToolsMessage(
197 const blink::WebString& message) {
198 sender_->Send(new DevToolsClientMsg_DispatchOnInspectorFrontend(
199 worker_devtools_agent_route_id_, message.utf8()));
200 }
201
202 void EmbeddedWorkerContextClient::saveDevToolsAgentState(
203 const blink::WebString& state) {
204 sender_->Send(new DevToolsHostMsg_SaveAgentRuntimeState(
205 worker_devtools_agent_route_id_, state.utf8()));
206 }
207
193 void EmbeddedWorkerContextClient::didHandleActivateEvent( 208 void EmbeddedWorkerContextClient::didHandleActivateEvent(
194 int request_id, 209 int request_id,
195 blink::WebServiceWorkerEventResult result) { 210 blink::WebServiceWorkerEventResult result) {
196 DCHECK(script_context_); 211 DCHECK(script_context_);
197 script_context_->DidHandleActivateEvent(request_id, result); 212 script_context_->DidHandleActivateEvent(request_id, result);
198 } 213 }
199 214
200 void EmbeddedWorkerContextClient::didHandleInstallEvent( 215 void EmbeddedWorkerContextClient::didHandleInstallEvent(
201 int request_id, 216 int request_id,
202 blink::WebServiceWorkerEventResult result) { 217 blink::WebServiceWorkerEventResult result) {
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after
262 } 277 }
263 278
264 void EmbeddedWorkerContextClient::SendWorkerStarted() { 279 void EmbeddedWorkerContextClient::SendWorkerStarted() {
265 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); 280 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread());
266 Send(new EmbeddedWorkerHostMsg_WorkerStarted( 281 Send(new EmbeddedWorkerHostMsg_WorkerStarted(
267 WorkerTaskRunner::Instance()->CurrentWorkerId(), 282 WorkerTaskRunner::Instance()->CurrentWorkerId(),
268 embedded_worker_id_)); 283 embedded_worker_id_));
269 } 284 }
270 285
271 } // namespace content 286 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698