| 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/browser/service_worker/service_worker_dispatcher_host.h" | 5 #include "content/browser/service_worker/service_worker_dispatcher_host.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/strings/utf_string_conversions.h" | 8 #include "base/strings/utf_string_conversions.h" |
| 9 #include "content/browser/message_port_message_filter.h" | 9 #include "content/browser/message_port_message_filter.h" |
| 10 #include "content/browser/message_port_service.h" | 10 #include "content/browser/message_port_service.h" |
| (...skipping 375 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 386 void ServiceWorkerDispatcherHost::OnWorkerReadyForInspection( | 386 void ServiceWorkerDispatcherHost::OnWorkerReadyForInspection( |
| 387 int embedded_worker_id) { | 387 int embedded_worker_id) { |
| 388 if (!GetContext()) | 388 if (!GetContext()) |
| 389 return; | 389 return; |
| 390 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); | 390 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); |
| 391 if (!registry->CanHandle(embedded_worker_id)) | 391 if (!registry->CanHandle(embedded_worker_id)) |
| 392 return; | 392 return; |
| 393 registry->OnWorkerReadyForInspection(render_process_id_, embedded_worker_id); | 393 registry->OnWorkerReadyForInspection(render_process_id_, embedded_worker_id); |
| 394 } | 394 } |
| 395 | 395 |
| 396 void ServiceWorkerDispatcherHost::OnWorkerScriptLoaded(int embedded_worker_id) { | 396 void ServiceWorkerDispatcherHost::OnWorkerScriptLoaded( |
| 397 int embedded_worker_id, |
| 398 int thread_id) { |
| 397 if (!GetContext()) | 399 if (!GetContext()) |
| 398 return; | 400 return; |
| 399 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); | 401 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); |
| 400 if (!registry->CanHandle(embedded_worker_id)) | 402 if (!registry->CanHandle(embedded_worker_id)) |
| 401 return; | 403 return; |
| 402 registry->OnWorkerScriptLoaded(render_process_id_, embedded_worker_id); | 404 registry->OnWorkerScriptLoaded( |
| 405 render_process_id_, thread_id, embedded_worker_id); |
| 403 } | 406 } |
| 404 | 407 |
| 405 void ServiceWorkerDispatcherHost::OnWorkerScriptLoadFailed( | 408 void ServiceWorkerDispatcherHost::OnWorkerScriptLoadFailed( |
| 406 int embedded_worker_id) { | 409 int embedded_worker_id) { |
| 407 if (!GetContext()) | 410 if (!GetContext()) |
| 408 return; | 411 return; |
| 409 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); | 412 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); |
| 410 if (!registry->CanHandle(embedded_worker_id)) | 413 if (!registry->CanHandle(embedded_worker_id)) |
| 411 return; | 414 return; |
| 412 registry->OnWorkerScriptLoadFailed(render_process_id_, embedded_worker_id); | 415 registry->OnWorkerScriptLoadFailed(render_process_id_, embedded_worker_id); |
| 413 } | 416 } |
| 414 | 417 |
| 415 void ServiceWorkerDispatcherHost::OnWorkerStarted( | 418 void ServiceWorkerDispatcherHost::OnWorkerStarted(int embedded_worker_id) { |
| 416 int thread_id, int embedded_worker_id) { | |
| 417 if (!GetContext()) | 419 if (!GetContext()) |
| 418 return; | 420 return; |
| 419 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); | 421 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); |
| 420 if (!registry->CanHandle(embedded_worker_id)) | 422 if (!registry->CanHandle(embedded_worker_id)) |
| 421 return; | 423 return; |
| 422 registry->OnWorkerStarted(render_process_id_, thread_id, embedded_worker_id); | 424 registry->OnWorkerStarted(render_process_id_, embedded_worker_id); |
| 423 } | 425 } |
| 424 | 426 |
| 425 void ServiceWorkerDispatcherHost::OnWorkerStopped(int embedded_worker_id) { | 427 void ServiceWorkerDispatcherHost::OnWorkerStopped(int embedded_worker_id) { |
| 426 if (!GetContext()) | 428 if (!GetContext()) |
| 427 return; | 429 return; |
| 428 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); | 430 EmbeddedWorkerRegistry* registry = GetContext()->embedded_worker_registry(); |
| 429 if (!registry->CanHandle(embedded_worker_id)) | 431 if (!registry->CanHandle(embedded_worker_id)) |
| 430 return; | 432 return; |
| 431 registry->OnWorkerStopped(render_process_id_, embedded_worker_id); | 433 registry->OnWorkerStopped(render_process_id_, embedded_worker_id); |
| 432 } | 434 } |
| (...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 541 status, &error_type, &error_message); | 543 status, &error_type, &error_message); |
| 542 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( | 544 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( |
| 543 thread_id, request_id, error_type, error_message)); | 545 thread_id, request_id, error_type, error_message)); |
| 544 } | 546 } |
| 545 | 547 |
| 546 ServiceWorkerContextCore* ServiceWorkerDispatcherHost::GetContext() { | 548 ServiceWorkerContextCore* ServiceWorkerDispatcherHost::GetContext() { |
| 547 return context_wrapper_->context(); | 549 return context_wrapper_->context(); |
| 548 } | 550 } |
| 549 | 551 |
| 550 } // namespace content | 552 } // namespace content |
| OLD | NEW |