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 <map> | 7 #include <map> |
8 #include <set> | 8 #include <set> |
9 #include <string> | 9 #include <string> |
10 #include <vector> | 10 #include <vector> |
11 | 11 |
12 #include "base/barrier_closure.h" | 12 #include "base/barrier_closure.h" |
13 #include "base/bind.h" | 13 #include "base/bind.h" |
14 #include "base/files/file_path.h" | 14 #include "base/files/file_path.h" |
15 #include "base/lazy_instance.h" | 15 #include "base/lazy_instance.h" |
16 #include "base/logging.h" | 16 #include "base/logging.h" |
17 #include "base/threading/sequenced_worker_pool.h" | 17 #include "base/threading/sequenced_worker_pool.h" |
18 #include "content/browser/fileapi/chrome_blob_storage_context.h" | |
19 #include "content/browser/service_worker/service_worker_context_core.h" | 18 #include "content/browser/service_worker/service_worker_context_core.h" |
20 #include "content/browser/service_worker/service_worker_context_observer.h" | 19 #include "content/browser/service_worker/service_worker_context_observer.h" |
21 #include "content/browser/service_worker/service_worker_process_manager.h" | 20 #include "content/browser/service_worker/service_worker_process_manager.h" |
22 #include "content/browser/service_worker/service_worker_quota_client.h" | 21 #include "content/browser/service_worker/service_worker_quota_client.h" |
23 #include "content/browser/service_worker/service_worker_request_handler.h" | 22 #include "content/browser/service_worker/service_worker_request_handler.h" |
24 #include "content/browser/service_worker/service_worker_utils.h" | 23 #include "content/browser/service_worker/service_worker_utils.h" |
25 #include "content/browser/storage_partition_impl.h" | 24 #include "content/browser/storage_partition_impl.h" |
26 #include "content/public/browser/browser_context.h" | 25 #include "content/public/browser/browser_context.h" |
27 #include "content/public/browser/browser_thread.h" | 26 #include "content/public/browser/browser_thread.h" |
28 #include "content/public/browser/service_worker_context.h" | 27 #include "content/public/browser/service_worker_context.h" |
29 #include "net/base/net_errors.h" | 28 #include "net/base/net_errors.h" |
30 #include "net/base/net_util.h" | 29 #include "net/base/net_util.h" |
31 #include "net/url_request/url_request_context_getter.h" | |
32 #include "storage/browser/blob/blob_storage_context.h" | |
33 #include "storage/browser/quota/quota_manager_proxy.h" | 30 #include "storage/browser/quota/quota_manager_proxy.h" |
34 #include "storage/browser/quota/special_storage_policy.h" | 31 #include "storage/browser/quota/special_storage_policy.h" |
35 | 32 |
36 namespace content { | 33 namespace content { |
37 | 34 |
38 namespace { | 35 namespace { |
39 | 36 |
40 typedef std::set<std::string> HeaderNameSet; | 37 typedef std::set<std::string> HeaderNameSet; |
41 base::LazyInstance<HeaderNameSet> g_excluded_header_name_set = | 38 base::LazyInstance<HeaderNameSet> g_excluded_header_name_set = |
42 LAZY_INSTANCE_INITIALIZER; | 39 LAZY_INSTANCE_INITIALIZER; |
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
89 storage::QuotaManagerProxy* quota_manager_proxy, | 86 storage::QuotaManagerProxy* quota_manager_proxy, |
90 storage::SpecialStoragePolicy* special_storage_policy) { | 87 storage::SpecialStoragePolicy* special_storage_policy) { |
91 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 88 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
92 | 89 |
93 is_incognito_ = user_data_directory.empty(); | 90 is_incognito_ = user_data_directory.empty(); |
94 base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool(); | 91 base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool(); |
95 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager( | 92 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager( |
96 new ServiceWorkerDatabaseTaskManagerImpl(pool)); | 93 new ServiceWorkerDatabaseTaskManagerImpl(pool)); |
97 scoped_refptr<base::SingleThreadTaskRunner> disk_cache_thread = | 94 scoped_refptr<base::SingleThreadTaskRunner> disk_cache_thread = |
98 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::CACHE); | 95 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::CACHE); |
99 scoped_refptr<base::SequencedTaskRunner> cache_task_runner = | |
100 pool->GetSequencedTaskRunnerWithShutdownBehavior( | |
101 BrowserThread::GetBlockingPool()->GetSequenceToken(), | |
102 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); | |
103 InitInternal(user_data_directory, | 96 InitInternal(user_data_directory, |
104 cache_task_runner, | |
105 database_task_manager.Pass(), | 97 database_task_manager.Pass(), |
106 disk_cache_thread, | 98 disk_cache_thread, |
107 quota_manager_proxy, | 99 quota_manager_proxy, |
108 special_storage_policy); | 100 special_storage_policy); |
109 } | 101 } |
110 | 102 |
111 void ServiceWorkerContextWrapper::Shutdown() { | 103 void ServiceWorkerContextWrapper::Shutdown() { |
112 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 104 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
113 | 105 |
114 storage_partition_ = nullptr; | 106 storage_partition_ = nullptr; |
(...skipping 244 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
359 void ServiceWorkerContextWrapper::AddObserver( | 351 void ServiceWorkerContextWrapper::AddObserver( |
360 ServiceWorkerContextObserver* observer) { | 352 ServiceWorkerContextObserver* observer) { |
361 observer_list_->AddObserver(observer); | 353 observer_list_->AddObserver(observer); |
362 } | 354 } |
363 | 355 |
364 void ServiceWorkerContextWrapper::RemoveObserver( | 356 void ServiceWorkerContextWrapper::RemoveObserver( |
365 ServiceWorkerContextObserver* observer) { | 357 ServiceWorkerContextObserver* observer) { |
366 observer_list_->RemoveObserver(observer); | 358 observer_list_->RemoveObserver(observer); |
367 } | 359 } |
368 | 360 |
369 void ServiceWorkerContextWrapper::SetBlobParametersForCache( | |
370 net::URLRequestContextGetter* request_context, | |
371 ChromeBlobStorageContext* blob_storage_context) { | |
372 DCHECK_CURRENTLY_ON(BrowserThread::IO); | |
373 | |
374 if (context_core_ && request_context && blob_storage_context) { | |
375 context_core_->SetBlobParametersForCache( | |
376 request_context->GetURLRequestContext(), | |
377 blob_storage_context->context()->AsWeakPtr()); | |
378 } | |
379 } | |
380 | |
381 void ServiceWorkerContextWrapper::InitInternal( | 361 void ServiceWorkerContextWrapper::InitInternal( |
382 const base::FilePath& user_data_directory, | 362 const base::FilePath& user_data_directory, |
383 const scoped_refptr<base::SequencedTaskRunner>& stores_task_runner, | |
384 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, | 363 scoped_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, |
385 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, | 364 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, |
386 storage::QuotaManagerProxy* quota_manager_proxy, | 365 storage::QuotaManagerProxy* quota_manager_proxy, |
387 storage::SpecialStoragePolicy* special_storage_policy) { | 366 storage::SpecialStoragePolicy* special_storage_policy) { |
388 if (!BrowserThread::CurrentlyOn(BrowserThread::IO)) { | 367 if (!BrowserThread::CurrentlyOn(BrowserThread::IO)) { |
389 BrowserThread::PostTask( | 368 BrowserThread::PostTask( |
390 BrowserThread::IO, | 369 BrowserThread::IO, |
391 FROM_HERE, | 370 FROM_HERE, |
392 base::Bind(&ServiceWorkerContextWrapper::InitInternal, | 371 base::Bind(&ServiceWorkerContextWrapper::InitInternal, |
393 this, | 372 this, |
394 user_data_directory, | 373 user_data_directory, |
395 stores_task_runner, | |
396 base::Passed(&database_task_manager), | 374 base::Passed(&database_task_manager), |
397 disk_cache_thread, | 375 disk_cache_thread, |
398 make_scoped_refptr(quota_manager_proxy), | 376 make_scoped_refptr(quota_manager_proxy), |
399 make_scoped_refptr(special_storage_policy))); | 377 make_scoped_refptr(special_storage_policy))); |
400 return; | 378 return; |
401 } | 379 } |
402 DCHECK(!context_core_); | 380 DCHECK(!context_core_); |
403 if (quota_manager_proxy) { | 381 if (quota_manager_proxy) { |
404 quota_manager_proxy->RegisterClient(new ServiceWorkerQuotaClient(this)); | 382 quota_manager_proxy->RegisterClient(new ServiceWorkerQuotaClient(this)); |
405 } | 383 } |
406 context_core_.reset(new ServiceWorkerContextCore(user_data_directory, | 384 context_core_.reset(new ServiceWorkerContextCore(user_data_directory, |
407 stores_task_runner, | |
408 database_task_manager.Pass(), | 385 database_task_manager.Pass(), |
409 disk_cache_thread, | 386 disk_cache_thread, |
410 quota_manager_proxy, | 387 quota_manager_proxy, |
411 special_storage_policy, | 388 special_storage_policy, |
412 observer_list_.get(), | 389 observer_list_.get(), |
413 this)); | 390 this)); |
414 } | 391 } |
415 | 392 |
416 void ServiceWorkerContextWrapper::ShutdownOnIO() { | 393 void ServiceWorkerContextWrapper::ShutdownOnIO() { |
417 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 394 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
418 context_core_.reset(); | 395 context_core_.reset(); |
419 } | 396 } |
420 | 397 |
421 void ServiceWorkerContextWrapper::DidDeleteAndStartOver( | 398 void ServiceWorkerContextWrapper::DidDeleteAndStartOver( |
422 ServiceWorkerStatusCode status) { | 399 ServiceWorkerStatusCode status) { |
423 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 400 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
424 if (status != SERVICE_WORKER_OK) { | 401 if (status != SERVICE_WORKER_OK) { |
425 context_core_.reset(); | 402 context_core_.reset(); |
426 return; | 403 return; |
427 } | 404 } |
428 context_core_.reset(new ServiceWorkerContextCore(context_core_.get(), this)); | 405 context_core_.reset(new ServiceWorkerContextCore(context_core_.get(), this)); |
429 DVLOG(1) << "Restarted ServiceWorkerContextCore successfully."; | 406 DVLOG(1) << "Restarted ServiceWorkerContextCore successfully."; |
430 | 407 |
431 observer_list_->Notify(FROM_HERE, | 408 observer_list_->Notify(FROM_HERE, |
432 &ServiceWorkerContextObserver::OnStorageWiped); | 409 &ServiceWorkerContextObserver::OnStorageWiped); |
433 } | 410 } |
434 | 411 |
435 } // namespace content | 412 } // namespace content |
OLD | NEW |