| 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/child/service_worker/service_worker_dispatcher.h" | 5 #include "content/child/service_worker/service_worker_dispatcher.h" |
| 6 | 6 |
| 7 #include "base/lazy_instance.h" | 7 #include "base/lazy_instance.h" |
| 8 #include "base/single_thread_task_runner.h" | 8 #include "base/single_thread_task_runner.h" |
| 9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
| 10 #include "base/thread_task_runner_handle.h" | 10 #include "base/thread_task_runner_handle.h" |
| (...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 112 const GURL& script_url, | 112 const GURL& script_url, |
| 113 WebServiceWorkerRegistrationCallbacks* callbacks) { | 113 WebServiceWorkerRegistrationCallbacks* callbacks) { |
| 114 DCHECK(callbacks); | 114 DCHECK(callbacks); |
| 115 | 115 |
| 116 if (pattern.possibly_invalid_spec().size() > GetMaxURLChars() || | 116 if (pattern.possibly_invalid_spec().size() > GetMaxURLChars() || |
| 117 script_url.possibly_invalid_spec().size() > GetMaxURLChars()) { | 117 script_url.possibly_invalid_spec().size() > GetMaxURLChars()) { |
| 118 scoped_ptr<WebServiceWorkerRegistrationCallbacks> | 118 scoped_ptr<WebServiceWorkerRegistrationCallbacks> |
| 119 owned_callbacks(callbacks); | 119 owned_callbacks(callbacks); |
| 120 std::string error_message(kServiceWorkerRegisterErrorPrefix); | 120 std::string error_message(kServiceWorkerRegisterErrorPrefix); |
| 121 error_message += "The provided scriptURL or scope is too long."; | 121 error_message += "The provided scriptURL or scope is too long."; |
| 122 scoped_ptr<WebServiceWorkerError> error( | 122 callbacks->onError( |
| 123 new WebServiceWorkerError(WebServiceWorkerError::ErrorTypeSecurity, | 123 new WebServiceWorkerError(WebServiceWorkerError::ErrorTypeSecurity, |
| 124 blink::WebString::fromUTF8(error_message))); | 124 blink::WebString::fromUTF8(error_message))); |
| 125 callbacks->onError(error.release()); | |
| 126 return; | 125 return; |
| 127 } | 126 } |
| 128 | 127 |
| 129 int request_id = pending_registration_callbacks_.Add(callbacks); | 128 int request_id = pending_registration_callbacks_.Add(callbacks); |
| 130 TRACE_EVENT_ASYNC_BEGIN2("ServiceWorker", | 129 TRACE_EVENT_ASYNC_BEGIN2("ServiceWorker", |
| 131 "ServiceWorkerDispatcher::RegisterServiceWorker", | 130 "ServiceWorkerDispatcher::RegisterServiceWorker", |
| 132 request_id, | 131 request_id, |
| 133 "Scope", pattern.spec(), | 132 "Scope", pattern.spec(), |
| 134 "Script URL", script_url.spec()); | 133 "Script URL", script_url.spec()); |
| 135 thread_safe_sender_->Send(new ServiceWorkerHostMsg_RegisterServiceWorker( | 134 thread_safe_sender_->Send(new ServiceWorkerHostMsg_RegisterServiceWorker( |
| (...skipping 27 matching lines...) Expand all Loading... |
| 163 int provider_id, | 162 int provider_id, |
| 164 const GURL& document_url, | 163 const GURL& document_url, |
| 165 WebServiceWorkerRegistrationCallbacks* callbacks) { | 164 WebServiceWorkerRegistrationCallbacks* callbacks) { |
| 166 DCHECK(callbacks); | 165 DCHECK(callbacks); |
| 167 | 166 |
| 168 if (document_url.possibly_invalid_spec().size() > GetMaxURLChars()) { | 167 if (document_url.possibly_invalid_spec().size() > GetMaxURLChars()) { |
| 169 scoped_ptr<WebServiceWorkerRegistrationCallbacks> | 168 scoped_ptr<WebServiceWorkerRegistrationCallbacks> |
| 170 owned_callbacks(callbacks); | 169 owned_callbacks(callbacks); |
| 171 std::string error_message(kServiceWorkerGetRegistrationErrorPrefix); | 170 std::string error_message(kServiceWorkerGetRegistrationErrorPrefix); |
| 172 error_message += "The provided documentURL is too long."; | 171 error_message += "The provided documentURL is too long."; |
| 173 scoped_ptr<WebServiceWorkerError> error( | 172 callbacks->onError( |
| 174 new WebServiceWorkerError(WebServiceWorkerError::ErrorTypeSecurity, | 173 new WebServiceWorkerError(WebServiceWorkerError::ErrorTypeSecurity, |
| 175 blink::WebString::fromUTF8(error_message))); | 174 blink::WebString::fromUTF8(error_message))); |
| 176 callbacks->onError(error.release()); | |
| 177 return; | 175 return; |
| 178 } | 176 } |
| 179 | 177 |
| 180 int request_id = pending_get_registration_callbacks_.Add(callbacks); | 178 int request_id = pending_get_registration_callbacks_.Add(callbacks); |
| 181 TRACE_EVENT_ASYNC_BEGIN1("ServiceWorker", | 179 TRACE_EVENT_ASYNC_BEGIN1("ServiceWorker", |
| 182 "ServiceWorkerDispatcher::GetRegistration", | 180 "ServiceWorkerDispatcher::GetRegistration", |
| 183 request_id, | 181 request_id, |
| 184 "Document URL", document_url.spec()); | 182 "Document URL", document_url.spec()); |
| 185 thread_safe_sender_->Send(new ServiceWorkerHostMsg_GetRegistration( | 183 thread_safe_sender_->Send(new ServiceWorkerHostMsg_GetRegistration( |
| 186 CurrentWorkerId(), request_id, provider_id, document_url)); | 184 CurrentWorkerId(), request_id, provider_id, document_url)); |
| (...skipping 282 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 469 request_id); | 467 request_id); |
| 470 | 468 |
| 471 WebServiceWorkerGetRegistrationsCallbacks* callbacks = | 469 WebServiceWorkerGetRegistrationsCallbacks* callbacks = |
| 472 pending_get_registrations_callbacks_.Lookup(request_id); | 470 pending_get_registrations_callbacks_.Lookup(request_id); |
| 473 DCHECK(callbacks); | 471 DCHECK(callbacks); |
| 474 if (!callbacks) | 472 if (!callbacks) |
| 475 return; | 473 return; |
| 476 | 474 |
| 477 typedef blink::WebVector<blink::WebServiceWorkerRegistration*> | 475 typedef blink::WebVector<blink::WebServiceWorkerRegistration*> |
| 478 WebServiceWorkerRegistrationArray; | 476 WebServiceWorkerRegistrationArray; |
| 479 scoped_ptr<WebServiceWorkerRegistrationArray> | 477 WebServiceWorkerRegistrationArray* registrations = |
| 480 registrations(new WebServiceWorkerRegistrationArray(infos.size())); | 478 new WebServiceWorkerRegistrationArray(infos.size()); |
| 481 for (size_t i = 0; i < infos.size(); ++i) { | 479 for (size_t i = 0; i < infos.size(); ++i) { |
| 482 if (infos[i].handle_id != kInvalidServiceWorkerHandleId) { | 480 if (infos[i].handle_id != kInvalidServiceWorkerHandleId) { |
| 483 ServiceWorkerRegistrationObjectInfo info(infos[i]); | 481 ServiceWorkerRegistrationObjectInfo info(infos[i]); |
| 484 ServiceWorkerVersionAttributes attr(attrs[i]); | 482 ServiceWorkerVersionAttributes attr(attrs[i]); |
| 485 (*registrations)[i] = FindOrCreateRegistration(info, attr); | 483 (*registrations)[i] = FindOrCreateRegistration(info, attr); |
| 486 } | 484 } |
| 487 } | 485 } |
| 488 | 486 |
| 489 callbacks->onSuccess(registrations.release()); | 487 callbacks->onSuccess(registrations); |
| 490 pending_get_registrations_callbacks_.Remove(request_id); | 488 pending_get_registrations_callbacks_.Remove(request_id); |
| 491 } | 489 } |
| 492 | 490 |
| 493 void ServiceWorkerDispatcher::OnDidGetRegistrationForReady( | 491 void ServiceWorkerDispatcher::OnDidGetRegistrationForReady( |
| 494 int thread_id, | 492 int thread_id, |
| 495 int request_id, | 493 int request_id, |
| 496 const ServiceWorkerRegistrationObjectInfo& info, | 494 const ServiceWorkerRegistrationObjectInfo& info, |
| 497 const ServiceWorkerVersionAttributes& attrs) { | 495 const ServiceWorkerVersionAttributes& attrs) { |
| 498 TRACE_EVENT_ASYNC_STEP_INTO0( | 496 TRACE_EVENT_ASYNC_STEP_INTO0( |
| 499 "ServiceWorker", | 497 "ServiceWorker", |
| (...skipping 27 matching lines...) Expand all Loading... |
| 527 "OnRegistrationError"); | 525 "OnRegistrationError"); |
| 528 TRACE_EVENT_ASYNC_END0("ServiceWorker", | 526 TRACE_EVENT_ASYNC_END0("ServiceWorker", |
| 529 "ServiceWorkerDispatcher::RegisterServiceWorker", | 527 "ServiceWorkerDispatcher::RegisterServiceWorker", |
| 530 request_id); | 528 request_id); |
| 531 WebServiceWorkerRegistrationCallbacks* callbacks = | 529 WebServiceWorkerRegistrationCallbacks* callbacks = |
| 532 pending_registration_callbacks_.Lookup(request_id); | 530 pending_registration_callbacks_.Lookup(request_id); |
| 533 DCHECK(callbacks); | 531 DCHECK(callbacks); |
| 534 if (!callbacks) | 532 if (!callbacks) |
| 535 return; | 533 return; |
| 536 | 534 |
| 537 scoped_ptr<WebServiceWorkerError> error( | 535 callbacks->onError(new WebServiceWorkerError(error_type, message)); |
| 538 new WebServiceWorkerError(error_type, message)); | |
| 539 callbacks->onError(error.release()); | |
| 540 pending_registration_callbacks_.Remove(request_id); | 536 pending_registration_callbacks_.Remove(request_id); |
| 541 } | 537 } |
| 542 | 538 |
| 543 void ServiceWorkerDispatcher::OnUpdateError( | 539 void ServiceWorkerDispatcher::OnUpdateError( |
| 544 int thread_id, | 540 int thread_id, |
| 545 int request_id, | 541 int request_id, |
| 546 WebServiceWorkerError::ErrorType error_type, | 542 WebServiceWorkerError::ErrorType error_type, |
| 547 const base::string16& message) { | 543 const base::string16& message) { |
| 548 TRACE_EVENT_ASYNC_STEP_INTO0("ServiceWorker", | 544 TRACE_EVENT_ASYNC_STEP_INTO0("ServiceWorker", |
| 549 "ServiceWorkerDispatcher::UpdateServiceWorker", | 545 "ServiceWorkerDispatcher::UpdateServiceWorker", |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 596 "OnGetRegistrationError"); | 592 "OnGetRegistrationError"); |
| 597 TRACE_EVENT_ASYNC_END0("ServiceWorker", | 593 TRACE_EVENT_ASYNC_END0("ServiceWorker", |
| 598 "ServiceWorkerDispatcher::GetRegistration", | 594 "ServiceWorkerDispatcher::GetRegistration", |
| 599 request_id); | 595 request_id); |
| 600 WebServiceWorkerGetRegistrationCallbacks* callbacks = | 596 WebServiceWorkerGetRegistrationCallbacks* callbacks = |
| 601 pending_get_registration_callbacks_.Lookup(request_id); | 597 pending_get_registration_callbacks_.Lookup(request_id); |
| 602 DCHECK(callbacks); | 598 DCHECK(callbacks); |
| 603 if (!callbacks) | 599 if (!callbacks) |
| 604 return; | 600 return; |
| 605 | 601 |
| 606 scoped_ptr<WebServiceWorkerError> error( | 602 callbacks->onError(new WebServiceWorkerError(error_type, message)); |
| 607 new WebServiceWorkerError(error_type, message)); | |
| 608 callbacks->onError(error.release()); | |
| 609 pending_get_registration_callbacks_.Remove(request_id); | 603 pending_get_registration_callbacks_.Remove(request_id); |
| 610 } | 604 } |
| 611 | 605 |
| 612 void ServiceWorkerDispatcher::OnGetRegistrationsError( | 606 void ServiceWorkerDispatcher::OnGetRegistrationsError( |
| 613 int thread_id, | 607 int thread_id, |
| 614 int request_id, | 608 int request_id, |
| 615 WebServiceWorkerError::ErrorType error_type, | 609 WebServiceWorkerError::ErrorType error_type, |
| 616 const base::string16& message) { | 610 const base::string16& message) { |
| 617 TRACE_EVENT_ASYNC_STEP_INTO0( | 611 TRACE_EVENT_ASYNC_STEP_INTO0( |
| 618 "ServiceWorker", | 612 "ServiceWorker", |
| 619 "ServiceWorkerDispatcher::GetRegistrations", | 613 "ServiceWorkerDispatcher::GetRegistrations", |
| 620 request_id, | 614 request_id, |
| 621 "OnGetRegistrationsError"); | 615 "OnGetRegistrationsError"); |
| 622 TRACE_EVENT_ASYNC_END0("ServiceWorker", | 616 TRACE_EVENT_ASYNC_END0("ServiceWorker", |
| 623 "ServiceWorkerDispatcher::GetRegistrations", | 617 "ServiceWorkerDispatcher::GetRegistrations", |
| 624 request_id); | 618 request_id); |
| 625 WebServiceWorkerGetRegistrationsCallbacks* callbacks = | 619 WebServiceWorkerGetRegistrationsCallbacks* callbacks = |
| 626 pending_get_registrations_callbacks_.Lookup(request_id); | 620 pending_get_registrations_callbacks_.Lookup(request_id); |
| 627 DCHECK(callbacks); | 621 DCHECK(callbacks); |
| 628 if (!callbacks) | 622 if (!callbacks) |
| 629 return; | 623 return; |
| 630 | 624 |
| 631 scoped_ptr<WebServiceWorkerError> error( | 625 callbacks->onError(new WebServiceWorkerError(error_type, message)); |
| 632 new WebServiceWorkerError(error_type, message)); | |
| 633 callbacks->onError(error.release()); | |
| 634 pending_get_registrations_callbacks_.Remove(request_id); | 626 pending_get_registrations_callbacks_.Remove(request_id); |
| 635 } | 627 } |
| 636 | 628 |
| 637 void ServiceWorkerDispatcher::OnServiceWorkerStateChanged( | 629 void ServiceWorkerDispatcher::OnServiceWorkerStateChanged( |
| 638 int thread_id, | 630 int thread_id, |
| 639 int handle_id, | 631 int handle_id, |
| 640 blink::WebServiceWorkerState state) { | 632 blink::WebServiceWorkerState state) { |
| 641 TRACE_EVENT2("ServiceWorker", | 633 TRACE_EVENT2("ServiceWorker", |
| 642 "ServiceWorkerDispatcher::OnServiceWorkerStateChanged", | 634 "ServiceWorkerDispatcher::OnServiceWorkerStateChanged", |
| 643 "Thread ID", thread_id, | 635 "Thread ID", thread_id, |
| (...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 803 bool adopt_handle = true; | 795 bool adopt_handle = true; |
| 804 WebServiceWorkerRegistrationImpl* registration = | 796 WebServiceWorkerRegistrationImpl* registration = |
| 805 CreateServiceWorkerRegistration(info, adopt_handle); | 797 CreateServiceWorkerRegistration(info, adopt_handle); |
| 806 registration->SetInstalling(GetServiceWorker(attrs.installing, adopt_handle)); | 798 registration->SetInstalling(GetServiceWorker(attrs.installing, adopt_handle)); |
| 807 registration->SetWaiting(GetServiceWorker(attrs.waiting, adopt_handle)); | 799 registration->SetWaiting(GetServiceWorker(attrs.waiting, adopt_handle)); |
| 808 registration->SetActive(GetServiceWorker(attrs.active, adopt_handle)); | 800 registration->SetActive(GetServiceWorker(attrs.active, adopt_handle)); |
| 809 return registration; | 801 return registration; |
| 810 } | 802 } |
| 811 | 803 |
| 812 } // namespace content | 804 } // namespace content |
| OLD | NEW |