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 |