Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(293)

Side by Side Diff: content/browser/service_worker/service_worker_context_core.cc

Issue 411973004: Stitch CacheStorage messages to implementation. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@cache_storage_stitch
Patch Set: Addresses all comments from PS5 Created 6 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
OLDNEW
« no previous file with comments | « content/browser/service_worker/service_worker_context_core.h ('k') | content/browser/service_worker/service_worker_version.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698