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_context_core.h" | 5 #include "content/browser/service_worker/service_worker_context_core.h" |
6 | 6 |
7 #include <limits> | 7 #include <limits> |
8 #include <set> | 8 #include <set> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
11 #include "base/barrier_closure.h" | 11 #include "base/barrier_closure.h" |
12 #include "base/bind.h" | 12 #include "base/bind.h" |
13 #include "base/bind_helpers.h" | 13 #include "base/bind_helpers.h" |
14 #include "base/files/file_path.h" | 14 #include "base/files/file_path.h" |
15 #include "base/location.h" | 15 #include "base/location.h" |
16 #include "base/macros.h" | 16 #include "base/macros.h" |
17 #include "base/memory/ptr_util.h" | 17 #include "base/memory/ptr_util.h" |
18 #include "base/single_thread_task_runner.h" | 18 #include "base/single_thread_task_runner.h" |
19 #include "base/strings/string_util.h" | 19 #include "base/strings/string_util.h" |
20 #include "base/threading/thread_task_runner_handle.h" | 20 #include "base/threading/thread_task_runner_handle.h" |
21 #include "content/browser/frame_host/render_frame_host_impl.h" | 21 #include "content/browser/frame_host/render_frame_host_impl.h" |
22 #include "content/browser/service_worker/embedded_worker_registry.h" | 22 #include "content/browser/service_worker/embedded_worker_registry.h" |
23 #include "content/browser/service_worker/embedded_worker_status.h" | 23 #include "content/browser/service_worker/embedded_worker_status.h" |
24 #include "content/browser/service_worker/service_worker_context_observer.h" | 24 #include "content/browser/service_worker/service_worker_context_observer.h" |
25 #include "content/browser/service_worker/service_worker_context_wrapper.h" | 25 #include "content/browser/service_worker/service_worker_context_wrapper.h" |
26 #include "content/browser/service_worker/service_worker_database_task_manager.h" | 26 #include "content/browser/service_worker/service_worker_database_task_manager.h" |
| 27 #include "content/browser/service_worker/service_worker_dispatcher_host.h" |
27 #include "content/browser/service_worker/service_worker_info.h" | 28 #include "content/browser/service_worker/service_worker_info.h" |
28 #include "content/browser/service_worker/service_worker_job_coordinator.h" | 29 #include "content/browser/service_worker/service_worker_job_coordinator.h" |
29 #include "content/browser/service_worker/service_worker_process_manager.h" | 30 #include "content/browser/service_worker/service_worker_process_manager.h" |
30 #include "content/browser/service_worker/service_worker_provider_host.h" | 31 #include "content/browser/service_worker/service_worker_provider_host.h" |
31 #include "content/browser/service_worker/service_worker_register_job.h" | 32 #include "content/browser/service_worker/service_worker_register_job.h" |
32 #include "content/browser/service_worker/service_worker_registration.h" | 33 #include "content/browser/service_worker/service_worker_registration.h" |
33 #include "content/browser/service_worker/service_worker_storage.h" | 34 #include "content/browser/service_worker/service_worker_storage.h" |
34 #include "content/common/service_worker/service_worker_utils.h" | 35 #include "content/common/service_worker/service_worker_utils.h" |
35 #include "content/public/browser/browser_thread.h" | 36 #include "content/public/browser/browser_thread.h" |
36 #include "ipc/ipc_message.h" | 37 #include "ipc/ipc_message.h" |
(...skipping 176 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
213 | 214 |
214 ServiceWorkerContextCore::ServiceWorkerContextCore( | 215 ServiceWorkerContextCore::ServiceWorkerContextCore( |
215 const base::FilePath& path, | 216 const base::FilePath& path, |
216 std::unique_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, | 217 std::unique_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, |
217 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, | 218 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, |
218 storage::QuotaManagerProxy* quota_manager_proxy, | 219 storage::QuotaManagerProxy* quota_manager_proxy, |
219 storage::SpecialStoragePolicy* special_storage_policy, | 220 storage::SpecialStoragePolicy* special_storage_policy, |
220 base::ObserverListThreadSafe<ServiceWorkerContextObserver>* observer_list, | 221 base::ObserverListThreadSafe<ServiceWorkerContextObserver>* observer_list, |
221 ServiceWorkerContextWrapper* wrapper) | 222 ServiceWorkerContextWrapper* wrapper) |
222 : wrapper_(wrapper), | 223 : wrapper_(wrapper), |
223 providers_(new ProcessToProviderMap), | 224 providers_(base::MakeUnique<ProcessToProviderMap>()), |
224 provider_by_uuid_(new ProviderByClientUUIDMap), | 225 provider_by_uuid_(base::MakeUnique<ProviderByClientUUIDMap>()), |
225 force_update_on_page_load_(false), | 226 force_update_on_page_load_(false), |
226 next_handle_id_(0), | 227 next_handle_id_(0), |
227 next_registration_handle_id_(0), | 228 next_registration_handle_id_(0), |
228 was_service_worker_registered_(false), | 229 was_service_worker_registered_(false), |
229 observer_list_(observer_list), | 230 observer_list_(observer_list), |
230 weak_factory_(this) { | 231 weak_factory_(this) { |
231 // These get a WeakPtr from weak_factory_, so must be set after weak_factory_ | 232 // These get a WeakPtr from weak_factory_, so must be set after weak_factory_ |
232 // is initialized. | 233 // is initialized. |
233 storage_ = ServiceWorkerStorage::Create( | 234 storage_ = ServiceWorkerStorage::Create( |
234 path, AsWeakPtr(), std::move(database_task_manager), disk_cache_thread, | 235 path, AsWeakPtr(), std::move(database_task_manager), disk_cache_thread, |
235 quota_manager_proxy, special_storage_policy); | 236 quota_manager_proxy, special_storage_policy); |
236 embedded_worker_registry_ = EmbeddedWorkerRegistry::Create(AsWeakPtr()); | 237 embedded_worker_registry_ = EmbeddedWorkerRegistry::Create(AsWeakPtr()); |
237 job_coordinator_.reset(new ServiceWorkerJobCoordinator(AsWeakPtr())); | 238 job_coordinator_.reset(new ServiceWorkerJobCoordinator(AsWeakPtr())); |
238 } | 239 } |
239 | 240 |
240 ServiceWorkerContextCore::ServiceWorkerContextCore( | 241 ServiceWorkerContextCore::ServiceWorkerContextCore( |
241 ServiceWorkerContextCore* old_context, | 242 ServiceWorkerContextCore* old_context, |
242 ServiceWorkerContextWrapper* wrapper) | 243 ServiceWorkerContextWrapper* wrapper) |
243 : wrapper_(wrapper), | 244 : wrapper_(wrapper), |
| 245 dispatcher_hosts_(std::move(old_context->dispatcher_hosts_)), |
244 providers_(old_context->providers_.release()), | 246 providers_(old_context->providers_.release()), |
245 provider_by_uuid_(old_context->provider_by_uuid_.release()), | 247 provider_by_uuid_(old_context->provider_by_uuid_.release()), |
246 next_handle_id_(old_context->next_handle_id_), | 248 next_handle_id_(old_context->next_handle_id_), |
247 next_registration_handle_id_(old_context->next_registration_handle_id_), | 249 next_registration_handle_id_(old_context->next_registration_handle_id_), |
248 was_service_worker_registered_( | 250 was_service_worker_registered_( |
249 old_context->was_service_worker_registered_), | 251 old_context->was_service_worker_registered_), |
250 observer_list_(old_context->observer_list_), | 252 observer_list_(old_context->observer_list_), |
251 weak_factory_(this) { | 253 weak_factory_(this) { |
252 // These get a WeakPtr from weak_factory_, so must be set after weak_factory_ | 254 // These get a WeakPtr from weak_factory_, so must be set after weak_factory_ |
253 // is initialized. | 255 // is initialized. |
254 storage_ = ServiceWorkerStorage::Create(AsWeakPtr(), old_context->storage()); | 256 storage_ = ServiceWorkerStorage::Create(AsWeakPtr(), old_context->storage()); |
255 embedded_worker_registry_ = EmbeddedWorkerRegistry::Create( | 257 embedded_worker_registry_ = EmbeddedWorkerRegistry::Create( |
256 AsWeakPtr(), | 258 AsWeakPtr(), |
257 old_context->embedded_worker_registry()); | 259 old_context->embedded_worker_registry()); |
258 job_coordinator_.reset(new ServiceWorkerJobCoordinator(AsWeakPtr())); | 260 job_coordinator_.reset(new ServiceWorkerJobCoordinator(AsWeakPtr())); |
259 } | 261 } |
260 | 262 |
261 ServiceWorkerContextCore::~ServiceWorkerContextCore() { | 263 ServiceWorkerContextCore::~ServiceWorkerContextCore() { |
262 DCHECK(storage_); | 264 DCHECK(storage_); |
263 for (VersionMap::iterator it = live_versions_.begin(); | 265 for (VersionMap::iterator it = live_versions_.begin(); |
264 it != live_versions_.end(); | 266 it != live_versions_.end(); |
265 ++it) { | 267 ++it) { |
266 it->second->RemoveListener(this); | 268 it->second->RemoveListener(this); |
267 } | 269 } |
268 weak_factory_.InvalidateWeakPtrs(); | 270 weak_factory_.InvalidateWeakPtrs(); |
269 } | 271 } |
270 | 272 |
271 ServiceWorkerProviderHost* ServiceWorkerContextCore::GetProviderHost( | 273 void ServiceWorkerContextCore::AddDispatcherHost( |
272 int process_id, int provider_id) { | 274 int process_id, |
273 ProviderMap* map = GetProviderMapForProcess(process_id); | 275 content::ServiceWorkerDispatcherHost* dispatcher_host) { |
274 if (!map) | 276 DCHECK(dispatcher_hosts_.find(process_id) == dispatcher_hosts_.end()); |
275 return NULL; | 277 dispatcher_hosts_[process_id] = dispatcher_host; |
276 return map->Lookup(provider_id); | 278 } |
| 279 |
| 280 ServiceWorkerDispatcherHost* ServiceWorkerContextCore::GetDispatcherHost( |
| 281 int process_id) { |
| 282 auto it = dispatcher_hosts_.find(process_id); |
| 283 if (it == dispatcher_hosts_.end()) |
| 284 return nullptr; |
| 285 return it->second; |
| 286 } |
| 287 |
| 288 void ServiceWorkerContextCore::RemoveDispatcherHost(int process_id) { |
| 289 DCHECK(dispatcher_hosts_.find(process_id) != dispatcher_hosts_.end()); |
| 290 RemoveAllProviderHostsForProcess(process_id); |
| 291 embedded_worker_registry_->RemoveProcess(process_id); |
| 292 dispatcher_hosts_.erase(process_id); |
277 } | 293 } |
278 | 294 |
279 void ServiceWorkerContextCore::AddProviderHost( | 295 void ServiceWorkerContextCore::AddProviderHost( |
280 std::unique_ptr<ServiceWorkerProviderHost> host) { | 296 std::unique_ptr<ServiceWorkerProviderHost> host) { |
281 int process_id = host->process_id(); | 297 int process_id = host->process_id(); |
282 int provider_id = host->provider_id(); | 298 int provider_id = host->provider_id(); |
283 ProviderMap* map = GetProviderMapForProcess(process_id); | 299 ProviderMap* map = GetProviderMapForProcess(process_id); |
284 if (!map) { | 300 if (!map) { |
285 providers_->AddWithID(base::MakeUnique<ProviderMap>(), process_id); | 301 providers_->AddWithID(base::MakeUnique<ProviderMap>(), process_id); |
286 map = GetProviderMapForProcess(process_id); | 302 map = GetProviderMapForProcess(process_id); |
287 } | 303 } |
288 map->AddWithID(std::move(host), provider_id); | 304 map->AddWithID(std::move(host), provider_id); |
289 } | 305 } |
290 | 306 |
| 307 ServiceWorkerProviderHost* ServiceWorkerContextCore::GetProviderHost( |
| 308 int process_id, |
| 309 int provider_id) { |
| 310 ProviderMap* map = GetProviderMapForProcess(process_id); |
| 311 if (!map) |
| 312 return nullptr; |
| 313 return map->Lookup(provider_id); |
| 314 } |
| 315 |
291 void ServiceWorkerContextCore::RemoveProviderHost( | 316 void ServiceWorkerContextCore::RemoveProviderHost( |
292 int process_id, int provider_id) { | 317 int process_id, int provider_id) { |
293 ProviderMap* map = GetProviderMapForProcess(process_id); | 318 ProviderMap* map = GetProviderMapForProcess(process_id); |
294 DCHECK(map); | 319 DCHECK(map); |
295 map->Remove(provider_id); | 320 map->Remove(provider_id); |
296 } | 321 } |
297 | 322 |
298 void ServiceWorkerContextCore::RemoveAllProviderHostsForProcess( | 323 void ServiceWorkerContextCore::RemoveAllProviderHostsForProcess( |
299 int process_id) { | 324 int process_id) { |
300 if (providers_->Lookup(process_id)) | 325 if (providers_->Lookup(process_id)) |
(...skipping 197 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
498 if (status == SERVICE_WORKER_OK && observer_list_.get()) { | 523 if (status == SERVICE_WORKER_OK && observer_list_.get()) { |
499 observer_list_->Notify(FROM_HERE, | 524 observer_list_->Notify(FROM_HERE, |
500 &ServiceWorkerContextObserver::OnRegistrationDeleted, | 525 &ServiceWorkerContextObserver::OnRegistrationDeleted, |
501 registration_id, pattern); | 526 registration_id, pattern); |
502 } | 527 } |
503 } | 528 } |
504 | 529 |
505 ServiceWorkerRegistration* ServiceWorkerContextCore::GetLiveRegistration( | 530 ServiceWorkerRegistration* ServiceWorkerContextCore::GetLiveRegistration( |
506 int64_t id) { | 531 int64_t id) { |
507 RegistrationsMap::iterator it = live_registrations_.find(id); | 532 RegistrationsMap::iterator it = live_registrations_.find(id); |
508 return (it != live_registrations_.end()) ? it->second : NULL; | 533 return (it != live_registrations_.end()) ? it->second : nullptr; |
509 } | 534 } |
510 | 535 |
511 void ServiceWorkerContextCore::AddLiveRegistration( | 536 void ServiceWorkerContextCore::AddLiveRegistration( |
512 ServiceWorkerRegistration* registration) { | 537 ServiceWorkerRegistration* registration) { |
513 // TODO(nhiroki): Change CHECK to DCHECK after https://crbug.com/619294 is | 538 // TODO(nhiroki): Change CHECK to DCHECK after https://crbug.com/619294 is |
514 // fixed. | 539 // fixed. |
515 CHECK(!GetLiveRegistration(registration->id())); | 540 CHECK(!GetLiveRegistration(registration->id())); |
516 live_registrations_[registration->id()] = registration; | 541 live_registrations_[registration->id()] = registration; |
517 if (observer_list_.get()) { | 542 if (observer_list_.get()) { |
518 observer_list_->Notify(FROM_HERE, | 543 observer_list_->Notify(FROM_HERE, |
519 &ServiceWorkerContextObserver::OnNewLiveRegistration, | 544 &ServiceWorkerContextObserver::OnNewLiveRegistration, |
520 registration->id(), registration->pattern()); | 545 registration->id(), registration->pattern()); |
521 } | 546 } |
522 } | 547 } |
523 | 548 |
524 void ServiceWorkerContextCore::RemoveLiveRegistration(int64_t id) { | 549 void ServiceWorkerContextCore::RemoveLiveRegistration(int64_t id) { |
525 live_registrations_.erase(id); | 550 live_registrations_.erase(id); |
526 } | 551 } |
527 | 552 |
528 ServiceWorkerVersion* ServiceWorkerContextCore::GetLiveVersion(int64_t id) { | 553 ServiceWorkerVersion* ServiceWorkerContextCore::GetLiveVersion(int64_t id) { |
529 VersionMap::iterator it = live_versions_.find(id); | 554 VersionMap::iterator it = live_versions_.find(id); |
530 return (it != live_versions_.end()) ? it->second : NULL; | 555 return (it != live_versions_.end()) ? it->second : nullptr; |
531 } | 556 } |
532 | 557 |
533 // PlzNavigate | 558 // PlzNavigate |
534 void ServiceWorkerContextCore::AddNavigationHandleCore( | 559 void ServiceWorkerContextCore::AddNavigationHandleCore( |
535 int service_worker_provider_id, | 560 int service_worker_provider_id, |
536 ServiceWorkerNavigationHandleCore* handle) { | 561 ServiceWorkerNavigationHandleCore* handle) { |
537 auto result = navigation_handle_cores_map_.insert( | 562 auto result = navigation_handle_cores_map_.insert( |
538 std::pair<int, ServiceWorkerNavigationHandleCore*>( | 563 std::pair<int, ServiceWorkerNavigationHandleCore*>( |
539 service_worker_provider_id, handle)); | 564 service_worker_provider_id, handle)); |
540 DCHECK(result.second) | 565 DCHECK(result.second) |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
629 job_coordinator_->AbortAll(); | 654 job_coordinator_->AbortAll(); |
630 storage_->DeleteAndStartOver(callback); | 655 storage_->DeleteAndStartOver(callback); |
631 } | 656 } |
632 | 657 |
633 std::unique_ptr<ServiceWorkerProviderHost> | 658 std::unique_ptr<ServiceWorkerProviderHost> |
634 ServiceWorkerContextCore::TransferProviderHostOut(int process_id, | 659 ServiceWorkerContextCore::TransferProviderHostOut(int process_id, |
635 int provider_id) { | 660 int provider_id) { |
636 ProviderMap* map = GetProviderMapForProcess(process_id); | 661 ProviderMap* map = GetProviderMapForProcess(process_id); |
637 ServiceWorkerProviderHost* transferee = map->Lookup(provider_id); | 662 ServiceWorkerProviderHost* transferee = map->Lookup(provider_id); |
638 std::unique_ptr<ServiceWorkerProviderHost> replacement = | 663 std::unique_ptr<ServiceWorkerProviderHost> replacement = |
639 base::MakeUnique<ServiceWorkerProviderHost>( | 664 transferee->PrepareForCrossSiteTransfer(); |
640 process_id, transferee->frame_id(), provider_id, | |
641 transferee->provider_type(), | |
642 transferee->is_parent_frame_secure() | |
643 ? ServiceWorkerProviderHost::FrameSecurityLevel::SECURE | |
644 : ServiceWorkerProviderHost::FrameSecurityLevel::INSECURE, | |
645 AsWeakPtr(), transferee->dispatcher_host()); | |
646 transferee->PrepareForCrossSiteTransfer(); | |
647 return map->Replace(provider_id, std::move(replacement)); | 665 return map->Replace(provider_id, std::move(replacement)); |
648 } | 666 } |
649 | 667 |
650 void ServiceWorkerContextCore::TransferProviderHostIn( | 668 void ServiceWorkerContextCore::TransferProviderHostIn( |
651 int new_process_id, | 669 int new_process_id, |
652 int new_provider_id, | 670 int new_provider_id, |
653 std::unique_ptr<ServiceWorkerProviderHost> transferee) { | 671 std::unique_ptr<ServiceWorkerProviderHost> transferee) { |
654 ProviderMap* map = GetProviderMapForProcess(new_process_id); | 672 ProviderMap* map = GetProviderMapForProcess(new_process_id); |
655 ServiceWorkerProviderHost* temp = map->Lookup(new_provider_id); | 673 ServiceWorkerProviderHost* temp = map->Lookup(new_provider_id); |
656 if (!temp) | 674 if (!temp) |
(...skipping 207 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
864 } | 882 } |
865 | 883 |
866 void ServiceWorkerContextCore::OnRegistrationFinishedForCheckHasServiceWorker( | 884 void ServiceWorkerContextCore::OnRegistrationFinishedForCheckHasServiceWorker( |
867 const ServiceWorkerContext::CheckHasServiceWorkerCallback callback, | 885 const ServiceWorkerContext::CheckHasServiceWorkerCallback callback, |
868 scoped_refptr<ServiceWorkerRegistration> registration) { | 886 scoped_refptr<ServiceWorkerRegistration> registration) { |
869 callback.Run(registration->active_version() || | 887 callback.Run(registration->active_version() || |
870 registration->waiting_version()); | 888 registration->waiting_version()); |
871 } | 889 } |
872 | 890 |
873 } // namespace content | 891 } // namespace content |
OLD | NEW |