| 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 "base/files/file_path.h" | 7 #include "base/files/file_path.h" |
| 8 #include "base/message_loop/message_loop_proxy.h" | 8 #include "base/message_loop/message_loop_proxy.h" |
| 9 #include "base/strings/string_util.h" | 9 #include "base/strings/string_util.h" |
| 10 #include "content/browser/service_worker/embedded_worker_registry.h" | 10 #include "content/browser/service_worker/embedded_worker_registry.h" |
| (...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 76 ProviderMap* provider_map = process_iterator_->GetCurrentValue(); | 76 ProviderMap* provider_map = process_iterator_->GetCurrentValue(); |
| 77 provider_host_iterator_.reset(new ProviderMap::iterator(provider_map)); | 77 provider_host_iterator_.reset(new ProviderMap::iterator(provider_map)); |
| 78 if (!provider_host_iterator_->IsAtEnd()) | 78 if (!provider_host_iterator_->IsAtEnd()) |
| 79 return; | 79 return; |
| 80 process_iterator_->Advance(); | 80 process_iterator_->Advance(); |
| 81 } | 81 } |
| 82 } | 82 } |
| 83 | 83 |
| 84 ServiceWorkerContextCore::ServiceWorkerContextCore( | 84 ServiceWorkerContextCore::ServiceWorkerContextCore( |
| 85 const base::FilePath& path, | 85 const base::FilePath& path, |
| 86 base::SequencedTaskRunner* stores_task_runner, | 86 base::SequencedTaskRunner* cache_task_runner, |
| 87 base::SequencedTaskRunner* database_task_runner, | 87 base::SequencedTaskRunner* database_task_runner, |
| 88 base::MessageLoopProxy* disk_cache_thread, | 88 base::MessageLoopProxy* disk_cache_thread, |
| 89 quota::QuotaManagerProxy* quota_manager_proxy, | 89 quota::QuotaManagerProxy* quota_manager_proxy, |
| 90 ObserverListThreadSafe<ServiceWorkerContextObserver>* observer_list, | 90 ObserverListThreadSafe<ServiceWorkerContextObserver>* observer_list, |
| 91 ServiceWorkerContextWrapper* wrapper) | 91 ServiceWorkerContextWrapper* wrapper) |
| 92 : weak_factory_(this), | 92 : weak_factory_(this), |
| 93 wrapper_(wrapper), | 93 wrapper_(wrapper), |
| 94 providers_(new ProcessToProviderMap), | 94 providers_(new ProcessToProviderMap), |
| 95 storage_(ServiceWorkerStorage::Create(path, | 95 storage_(ServiceWorkerStorage::Create(path, |
| 96 AsWeakPtr(), | 96 AsWeakPtr(), |
| 97 database_task_runner, | 97 database_task_runner, |
| 98 disk_cache_thread, | 98 disk_cache_thread, |
| 99 quota_manager_proxy)), | 99 quota_manager_proxy)), |
| 100 fetch_stores_manager_( | 100 cache_manager_( |
| 101 ServiceWorkerCacheStorageManager::Create(path, stores_task_runner)), | 101 ServiceWorkerCacheStorageManager::Create(path, cache_task_runner)), |
| 102 embedded_worker_registry_(EmbeddedWorkerRegistry::Create(AsWeakPtr())), | 102 embedded_worker_registry_(EmbeddedWorkerRegistry::Create(AsWeakPtr())), |
| 103 job_coordinator_(new ServiceWorkerJobCoordinator(AsWeakPtr())), | 103 job_coordinator_(new ServiceWorkerJobCoordinator(AsWeakPtr())), |
| 104 next_handle_id_(0), | 104 next_handle_id_(0), |
| 105 observer_list_(observer_list) { | 105 observer_list_(observer_list) { |
| 106 } | 106 } |
| 107 | 107 |
| 108 ServiceWorkerContextCore::ServiceWorkerContextCore( | 108 ServiceWorkerContextCore::ServiceWorkerContextCore( |
| 109 ServiceWorkerContextCore* old_context, | 109 ServiceWorkerContextCore* old_context, |
| 110 ServiceWorkerContextWrapper* wrapper) | 110 ServiceWorkerContextWrapper* wrapper) |
| 111 : weak_factory_(this), | 111 : weak_factory_(this), |
| 112 wrapper_(wrapper), | 112 wrapper_(wrapper), |
| 113 providers_(old_context->providers_.release()), | 113 providers_(old_context->providers_.release()), |
| 114 storage_( | 114 storage_( |
| 115 ServiceWorkerStorage::Create(AsWeakPtr(), old_context->storage())), | 115 ServiceWorkerStorage::Create(AsWeakPtr(), old_context->storage())), |
| 116 fetch_stores_manager_(ServiceWorkerCacheStorageManager::Create( | 116 cache_manager_(ServiceWorkerCacheStorageManager::Create( |
| 117 old_context->fetch_stores_manager())), | 117 old_context->cache_manager())), |
| 118 embedded_worker_registry_(EmbeddedWorkerRegistry::Create( | 118 embedded_worker_registry_(EmbeddedWorkerRegistry::Create( |
| 119 AsWeakPtr(), | 119 AsWeakPtr(), |
| 120 old_context->embedded_worker_registry())), | 120 old_context->embedded_worker_registry())), |
| 121 job_coordinator_(new ServiceWorkerJobCoordinator(AsWeakPtr())), | 121 job_coordinator_(new ServiceWorkerJobCoordinator(AsWeakPtr())), |
| 122 next_handle_id_(0), | 122 next_handle_id_(0), |
| 123 observer_list_(old_context->observer_list_) { | 123 observer_list_(old_context->observer_list_) { |
| 124 } | 124 } |
| 125 | 125 |
| 126 ServiceWorkerContextCore::~ServiceWorkerContextCore() { | 126 ServiceWorkerContextCore::~ServiceWorkerContextCore() { |
| 127 for (VersionMap::iterator it = live_versions_.begin(); | 127 for (VersionMap::iterator it = live_versions_.begin(); |
| (...skipping 261 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 389 version->embedded_worker()->thread_id(), | 389 version->embedded_worker()->thread_id(), |
| 390 ServiceWorkerContextObserver::ConsoleMessage( | 390 ServiceWorkerContextObserver::ConsoleMessage( |
| 391 source_identifier, message_level, message, line_number, source_url)); | 391 source_identifier, message_level, message, line_number, source_url)); |
| 392 } | 392 } |
| 393 | 393 |
| 394 ServiceWorkerProcessManager* ServiceWorkerContextCore::process_manager() { | 394 ServiceWorkerProcessManager* ServiceWorkerContextCore::process_manager() { |
| 395 return wrapper_->process_manager(); | 395 return wrapper_->process_manager(); |
| 396 } | 396 } |
| 397 | 397 |
| 398 } // namespace content | 398 } // namespace content |
| OLD | NEW |