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 <map> | 7 #include <map> |
8 #include <string> | 8 #include <string> |
9 | 9 |
10 #include "base/debug/trace_event.h" | 10 #include "base/debug/trace_event.h" |
(...skipping 343 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
354 | 354 |
355 void EmbeddedWorkerContextClient::postMessageToClient( | 355 void EmbeddedWorkerContextClient::postMessageToClient( |
356 int client_id, | 356 int client_id, |
357 const blink::WebString& message, | 357 const blink::WebString& message, |
358 blink::WebMessagePortChannelArray* channels) { | 358 blink::WebMessagePortChannelArray* channels) { |
359 DCHECK(script_context_); | 359 DCHECK(script_context_); |
360 script_context_->PostMessageToDocument(client_id, message, | 360 script_context_->PostMessageToDocument(client_id, message, |
361 make_scoped_ptr(channels)); | 361 make_scoped_ptr(channels)); |
362 } | 362 } |
363 | 363 |
| 364 void EmbeddedWorkerContextClient::skipWaiting( |
| 365 blink::WebServiceWorkerSkipWaitingCallbacks* callbacks) { |
| 366 DCHECK(script_context_); |
| 367 script_context_->SkipWaiting(callbacks); |
| 368 } |
| 369 |
364 void EmbeddedWorkerContextClient::OnMessageToWorker( | 370 void EmbeddedWorkerContextClient::OnMessageToWorker( |
365 int thread_id, | 371 int thread_id, |
366 int embedded_worker_id, | 372 int embedded_worker_id, |
367 const IPC::Message& message) { | 373 const IPC::Message& message) { |
368 if (!script_context_) | 374 if (!script_context_) |
369 return; | 375 return; |
370 DCHECK_EQ(embedded_worker_id_, embedded_worker_id); | 376 DCHECK_EQ(embedded_worker_id_, embedded_worker_id); |
371 script_context_->OnMessageReceived(message); | 377 script_context_->OnMessageReceived(message); |
372 } | 378 } |
373 | 379 |
374 void EmbeddedWorkerContextClient::SendWorkerStarted() { | 380 void EmbeddedWorkerContextClient::SendWorkerStarted() { |
375 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); | 381 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); |
376 TRACE_EVENT_ASYNC_END0("ServiceWorker", | 382 TRACE_EVENT_ASYNC_END0("ServiceWorker", |
377 "EmbeddedWorkerContextClient::StartingWorkerContext", | 383 "EmbeddedWorkerContextClient::StartingWorkerContext", |
378 this); | 384 this); |
379 Send(new EmbeddedWorkerHostMsg_WorkerStarted(embedded_worker_id_)); | 385 Send(new EmbeddedWorkerHostMsg_WorkerStarted(embedded_worker_id_)); |
380 } | 386 } |
381 | 387 |
382 } // namespace content | 388 } // namespace content |
OLD | NEW |