| 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/profiler/scoped_tracker.h" | 8 #include "base/profiler/scoped_tracker.h" |
| 9 #include "base/strings/utf_string_conversions.h" | 9 #include "base/strings/utf_string_conversions.h" |
| 10 #include "base/trace_event/trace_event.h" | 10 #include "base/trace_event/trace_event.h" |
| (...skipping 150 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 161 } | 161 } |
| 162 | 162 |
| 163 bool ServiceWorkerDispatcherHost::OnMessageReceived( | 163 bool ServiceWorkerDispatcherHost::OnMessageReceived( |
| 164 const IPC::Message& message) { | 164 const IPC::Message& message) { |
| 165 bool handled = true; | 165 bool handled = true; |
| 166 IPC_BEGIN_MESSAGE_MAP(ServiceWorkerDispatcherHost, message) | 166 IPC_BEGIN_MESSAGE_MAP(ServiceWorkerDispatcherHost, message) |
| 167 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_RegisterServiceWorker, | 167 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_RegisterServiceWorker, |
| 168 OnRegisterServiceWorker) | 168 OnRegisterServiceWorker) |
| 169 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_UpdateServiceWorker, | 169 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_UpdateServiceWorker, |
| 170 OnUpdateServiceWorker) | 170 OnUpdateServiceWorker) |
| 171 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_DeprecatedUnregisterServiceWorker, |
| 172 OnDeprecatedUnregisterServiceWorker) |
| 171 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_UnregisterServiceWorker, | 173 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_UnregisterServiceWorker, |
| 172 OnUnregisterServiceWorker) | 174 OnUnregisterServiceWorker) |
| 173 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_GetRegistration, | 175 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_GetRegistration, |
| 174 OnGetRegistration) | 176 OnGetRegistration) |
| 175 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_GetRegistrations, | 177 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_GetRegistrations, |
| 176 OnGetRegistrations) | 178 OnGetRegistrations) |
| 177 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_GetRegistrationForReady, | 179 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_GetRegistrationForReady, |
| 178 OnGetRegistrationForReady) | 180 OnGetRegistrationForReady) |
| 179 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_ProviderCreated, | 181 IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_ProviderCreated, |
| 180 OnProviderCreated) | 182 OnProviderCreated) |
| (...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 417 // Abort the following steps according to the spec. | 419 // Abort the following steps according to the spec. |
| 418 return; | 420 return; |
| 419 } | 421 } |
| 420 | 422 |
| 421 // The spec says, "update() pings the server for an updated version of this | 423 // The spec says, "update() pings the server for an updated version of this |
| 422 // script without consulting caches", so set |force_bypass_cache| to true. | 424 // script without consulting caches", so set |force_bypass_cache| to true. |
| 423 GetContext()->UpdateServiceWorker(registration, | 425 GetContext()->UpdateServiceWorker(registration, |
| 424 true /* force_bypass_cache */); | 426 true /* force_bypass_cache */); |
| 425 } | 427 } |
| 426 | 428 |
| 427 void ServiceWorkerDispatcherHost::OnUnregisterServiceWorker( | 429 void ServiceWorkerDispatcherHost::OnDeprecatedUnregisterServiceWorker( |
| 428 int thread_id, | 430 int thread_id, |
| 429 int request_id, | 431 int request_id, |
| 430 int provider_id, | 432 int provider_id, |
| 431 const GURL& pattern) { | 433 const GURL& pattern) { |
| 432 TRACE_EVENT0("ServiceWorker", | 434 TRACE_EVENT0("ServiceWorker", |
| 433 "ServiceWorkerDispatcherHost::OnUnregisterServiceWorker"); | 435 "ServiceWorkerDispatcherHost::OnUnregisterServiceWorker"); |
| 434 if (!GetContext()) { | 436 if (!GetContext()) { |
| 435 Send(new ServiceWorkerMsg_ServiceWorkerUnregistrationError( | 437 Send(new ServiceWorkerMsg_ServiceWorkerUnregistrationError( |
| 436 thread_id, | 438 thread_id, |
| 437 request_id, | 439 request_id, |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 491 request_id, | 493 request_id, |
| 492 "Pattern", pattern.spec()); | 494 "Pattern", pattern.spec()); |
| 493 GetContext()->UnregisterServiceWorker( | 495 GetContext()->UnregisterServiceWorker( |
| 494 pattern, | 496 pattern, |
| 495 base::Bind(&ServiceWorkerDispatcherHost::UnregistrationComplete, | 497 base::Bind(&ServiceWorkerDispatcherHost::UnregistrationComplete, |
| 496 this, | 498 this, |
| 497 thread_id, | 499 thread_id, |
| 498 request_id)); | 500 request_id)); |
| 499 } | 501 } |
| 500 | 502 |
| 503 void ServiceWorkerDispatcherHost::OnUnregisterServiceWorker( |
| 504 int thread_id, |
| 505 int request_id, |
| 506 int provider_id, |
| 507 int64 registration_id) { |
| 508 TRACE_EVENT0("ServiceWorker", |
| 509 "ServiceWorkerDispatcherHost::OnUnregisterServiceWorker"); |
| 510 if (!GetContext()) { |
| 511 Send(new ServiceWorkerMsg_ServiceWorkerUnregistrationError( |
| 512 thread_id, request_id, blink::WebServiceWorkerError::ErrorTypeAbort, |
| 513 base::ASCIIToUTF16(kShutdownErrorMessage))); |
| 514 return; |
| 515 } |
| 516 |
| 517 ServiceWorkerProviderHost* provider_host = |
| 518 GetContext()->GetProviderHost(render_process_id_, provider_id); |
| 519 if (!provider_host) { |
| 520 bad_message::ReceivedBadMessage(this, bad_message::SWDH_UNREGISTER_NO_HOST); |
| 521 return; |
| 522 } |
| 523 if (!provider_host->IsContextAlive()) { |
| 524 Send(new ServiceWorkerMsg_ServiceWorkerUnregistrationError( |
| 525 thread_id, request_id, blink::WebServiceWorkerError::ErrorTypeAbort, |
| 526 base::ASCIIToUTF16(kShutdownErrorMessage))); |
| 527 return; |
| 528 } |
| 529 |
| 530 // TODO(ksakamoto): This check can be removed once crbug.com/439697 is fixed. |
| 531 if (provider_host->document_url().is_empty()) { |
| 532 Send(new ServiceWorkerMsg_ServiceWorkerUnregistrationError( |
| 533 thread_id, request_id, WebServiceWorkerError::ErrorTypeSecurity, |
| 534 base::ASCIIToUTF16(kNoDocumentURLErrorMessage))); |
| 535 return; |
| 536 } |
| 537 |
| 538 ServiceWorkerRegistration* registration = |
| 539 GetContext()->GetLiveRegistration(registration_id); |
| 540 if (!registration) { |
| 541 // |registration| must be alive because a renderer retains a registration |
| 542 // reference at this point. |
| 543 bad_message::ReceivedBadMessage( |
| 544 this, bad_message::SWDH_UNREGISTER_BAD_REGISTRATION_ID); |
| 545 return; |
| 546 } |
| 547 |
| 548 if (!CanUnregisterServiceWorker(provider_host->document_url(), |
| 549 registration->pattern())) { |
| 550 bad_message::ReceivedBadMessage(this, bad_message::SWDH_UNREGISTER_CANNOT); |
| 551 return; |
| 552 } |
| 553 |
| 554 if (!GetContentClient()->browser()->AllowServiceWorker( |
| 555 registration->pattern(), provider_host->topmost_frame_url(), |
| 556 resource_context_, render_process_id_, provider_host->frame_id())) { |
| 557 Send(new ServiceWorkerMsg_ServiceWorkerUnregistrationError( |
| 558 thread_id, request_id, WebServiceWorkerError::ErrorTypeUnknown, |
| 559 base::ASCIIToUTF16(kUserDeniedPermissionMessage))); |
| 560 return; |
| 561 } |
| 562 |
| 563 TRACE_EVENT_ASYNC_BEGIN1( |
| 564 "ServiceWorker", "ServiceWorkerDispatcherHost::UnregisterServiceWorker", |
| 565 request_id, "Pattern", registration->pattern().spec()); |
| 566 GetContext()->UnregisterServiceWorker( |
| 567 registration->pattern(), |
| 568 base::Bind(&ServiceWorkerDispatcherHost::UnregistrationComplete, this, |
| 569 thread_id, request_id)); |
| 570 } |
| 571 |
| 501 void ServiceWorkerDispatcherHost::OnGetRegistration( | 572 void ServiceWorkerDispatcherHost::OnGetRegistration( |
| 502 int thread_id, | 573 int thread_id, |
| 503 int request_id, | 574 int request_id, |
| 504 int provider_id, | 575 int provider_id, |
| 505 const GURL& document_url) { | 576 const GURL& document_url) { |
| 506 TRACE_EVENT0("ServiceWorker", | 577 TRACE_EVENT0("ServiceWorker", |
| 507 "ServiceWorkerDispatcherHost::OnGetRegistration"); | 578 "ServiceWorkerDispatcherHost::OnGetRegistration"); |
| 508 | 579 |
| 509 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 580 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 510 | 581 |
| (...skipping 725 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1236 if (!handle) { | 1307 if (!handle) { |
| 1237 bad_message::ReceivedBadMessage(this, | 1308 bad_message::ReceivedBadMessage(this, |
| 1238 bad_message::SWDH_TERMINATE_BAD_HANDLE); | 1309 bad_message::SWDH_TERMINATE_BAD_HANDLE); |
| 1239 return; | 1310 return; |
| 1240 } | 1311 } |
| 1241 handle->version()->StopWorker( | 1312 handle->version()->StopWorker( |
| 1242 base::Bind(&ServiceWorkerUtils::NoOpStatusCallback)); | 1313 base::Bind(&ServiceWorkerUtils::NoOpStatusCallback)); |
| 1243 } | 1314 } |
| 1244 | 1315 |
| 1245 } // namespace content | 1316 } // namespace content |
| OLD | NEW |