Chromium Code Reviews| 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_wrapper.h" | 5 #include "content/browser/service_worker/service_worker_context_wrapper.h" |
| 6 | 6 |
| 7 #include "base/files/file_path.h" | 7 #include "base/files/file_path.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/threading/sequenced_worker_pool.h" | 9 #include "base/threading/sequenced_worker_pool.h" |
| 10 #include "content/browser/fileapi/chrome_blob_storage_context.h" | |
| 10 #include "content/browser/service_worker/service_worker_context_core.h" | 11 #include "content/browser/service_worker/service_worker_context_core.h" |
| 11 #include "content/browser/service_worker/service_worker_context_observer.h" | 12 #include "content/browser/service_worker/service_worker_context_observer.h" |
| 12 #include "content/browser/service_worker/service_worker_process_manager.h" | 13 #include "content/browser/service_worker/service_worker_process_manager.h" |
| 14 #include "content/public/browser/browser_context.h" | |
| 13 #include "content/public/browser/browser_thread.h" | 15 #include "content/public/browser/browser_thread.h" |
| 16 #include "net/url_request/url_request_context_getter.h" | |
| 14 #include "webkit/browser/quota/quota_manager_proxy.h" | 17 #include "webkit/browser/quota/quota_manager_proxy.h" |
| 15 | 18 |
| 16 namespace content { | 19 namespace content { |
| 17 | 20 |
| 18 ServiceWorkerContextWrapper::ServiceWorkerContextWrapper( | 21 ServiceWorkerContextWrapper::ServiceWorkerContextWrapper( |
| 19 BrowserContext* browser_context) | 22 BrowserContext* browser_context) |
| 20 : observer_list_( | 23 : observer_list_( |
| 21 new ObserverListThreadSafe<ServiceWorkerContextObserver>()), | 24 new ObserverListThreadSafe<ServiceWorkerContextObserver>()), |
| 22 process_manager_(new ServiceWorkerProcessManager(browser_context)), | 25 process_manager_(new ServiceWorkerProcessManager(browser_context)), |
| 23 is_incognito_(false) { | 26 is_incognito_(false), |
| 27 request_context_getter_(browser_context->GetRequestContext()), | |
| 28 blob_storage_context_(ChromeBlobStorageContext::GetFor(browser_context)) { | |
| 24 } | 29 } |
| 25 | 30 |
| 26 ServiceWorkerContextWrapper::~ServiceWorkerContextWrapper() { | 31 ServiceWorkerContextWrapper::~ServiceWorkerContextWrapper() { |
| 27 } | 32 } |
| 28 | 33 |
| 29 void ServiceWorkerContextWrapper::Init( | 34 void ServiceWorkerContextWrapper::Init( |
| 30 const base::FilePath& user_data_directory, | 35 const base::FilePath& user_data_directory, |
| 31 quota::QuotaManagerProxy* quota_manager_proxy) { | 36 quota::QuotaManagerProxy* quota_manager_proxy) { |
| 32 is_incognito_ = user_data_directory.empty(); | 37 is_incognito_ = user_data_directory.empty(); |
| 33 scoped_refptr<base::SequencedTaskRunner> database_task_runner = | 38 scoped_refptr<base::SequencedTaskRunner> database_task_runner = |
| 34 BrowserThread::GetBlockingPool()-> | 39 BrowserThread::GetBlockingPool()-> |
| 35 GetSequencedTaskRunnerWithShutdownBehavior( | 40 GetSequencedTaskRunnerWithShutdownBehavior( |
| 36 BrowserThread::GetBlockingPool()->GetSequenceToken(), | 41 BrowserThread::GetBlockingPool()->GetSequenceToken(), |
| 37 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); | 42 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); |
| 38 scoped_refptr<base::MessageLoopProxy> disk_cache_thread = | 43 scoped_refptr<base::MessageLoopProxy> disk_cache_thread = |
| 39 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::CACHE); | 44 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::CACHE); |
| 40 scoped_refptr<base::SequencedTaskRunner> stores_task_runner = | 45 scoped_refptr<base::SequencedTaskRunner> cache_task_runner = |
| 41 BrowserThread::GetBlockingPool() | 46 BrowserThread::GetBlockingPool() |
| 42 ->GetSequencedTaskRunnerWithShutdownBehavior( | 47 ->GetSequencedTaskRunnerWithShutdownBehavior( |
| 43 BrowserThread::GetBlockingPool()->GetSequenceToken(), | 48 BrowserThread::GetBlockingPool()->GetSequenceToken(), |
| 44 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); | 49 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); |
| 45 InitInternal(user_data_directory, | 50 InitInternal(user_data_directory, |
| 46 stores_task_runner, | 51 cache_task_runner, |
| 47 database_task_runner, | 52 database_task_runner, |
| 48 disk_cache_thread, | 53 disk_cache_thread, |
| 49 quota_manager_proxy); | 54 quota_manager_proxy); |
| 50 } | 55 } |
| 51 | 56 |
| 52 void ServiceWorkerContextWrapper::Shutdown() { | 57 void ServiceWorkerContextWrapper::Shutdown() { |
| 53 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 58 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 54 process_manager_->Shutdown(); | 59 process_manager_->Shutdown(); |
| 55 BrowserThread::PostTask( | 60 BrowserThread::PostTask( |
| 56 BrowserThread::IO, | 61 BrowserThread::IO, |
| (...skipping 111 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 168 make_scoped_refptr(quota_manager_proxy))); | 173 make_scoped_refptr(quota_manager_proxy))); |
| 169 return; | 174 return; |
| 170 } | 175 } |
| 171 DCHECK(!context_core_); | 176 DCHECK(!context_core_); |
| 172 context_core_.reset(new ServiceWorkerContextCore(user_data_directory, | 177 context_core_.reset(new ServiceWorkerContextCore(user_data_directory, |
| 173 stores_task_runner, | 178 stores_task_runner, |
| 174 database_task_runner, | 179 database_task_runner, |
| 175 disk_cache_thread, | 180 disk_cache_thread, |
| 176 quota_manager_proxy, | 181 quota_manager_proxy, |
| 177 observer_list_, | 182 observer_list_, |
| 178 this)); | 183 this)); |
|
michaeln
2014/08/12 03:48:52
in place of public getters can we unwrap the webki
jkarlin
2014/08/12 18:45:18
No longer applicable, see update. Though there is
| |
| 179 } | 184 } |
| 180 | 185 |
| 181 void ServiceWorkerContextWrapper::ShutdownOnIO() { | 186 void ServiceWorkerContextWrapper::ShutdownOnIO() { |
| 182 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 187 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 183 context_core_.reset(); | 188 context_core_.reset(); |
| 184 } | 189 } |
| 185 | 190 |
| 186 void ServiceWorkerContextWrapper::DidDeleteAndStartOver( | 191 void ServiceWorkerContextWrapper::DidDeleteAndStartOver( |
| 187 ServiceWorkerStatusCode status) { | 192 ServiceWorkerStatusCode status) { |
| 188 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 193 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 189 if (status != SERVICE_WORKER_OK) { | 194 if (status != SERVICE_WORKER_OK) { |
| 190 context_core_.reset(); | 195 context_core_.reset(); |
| 191 return; | 196 return; |
| 192 } | 197 } |
| 193 context_core_.reset(new ServiceWorkerContextCore(context_core_.get(), this)); | 198 context_core_.reset(new ServiceWorkerContextCore(context_core_.get(), this)); |
| 194 DVLOG(1) << "Restarted ServiceWorkerContextCore successfully."; | 199 DVLOG(1) << "Restarted ServiceWorkerContextCore successfully."; |
| 195 } | 200 } |
| 196 | 201 |
| 197 } // namespace content | 202 } // namespace content |
| OLD | NEW |