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()), | |
michaeln
2014/08/12 18:55:45
omg!
sorry i didn't notice that this is not the r
| |
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 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
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 |