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 <utility> | 10 #include <utility> |
(...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
141 // Explicitly remove this object as an observer to avoid use-after-frees in | 141 // Explicitly remove this object as an observer to avoid use-after-frees in |
142 // tests where this object is not guaranteed to outlive the | 142 // tests where this object is not guaranteed to outlive the |
143 // ServiceWorkerContextCore it wraps. | 143 // ServiceWorkerContextCore it wraps. |
144 core_observer_list_->RemoveObserver(this); | 144 core_observer_list_->RemoveObserver(this); |
145 DCHECK(!resource_context_); | 145 DCHECK(!resource_context_); |
146 } | 146 } |
147 | 147 |
148 void ServiceWorkerContextWrapper::Init( | 148 void ServiceWorkerContextWrapper::Init( |
149 const base::FilePath& user_data_directory, | 149 const base::FilePath& user_data_directory, |
150 storage::QuotaManagerProxy* quota_manager_proxy, | 150 storage::QuotaManagerProxy* quota_manager_proxy, |
151 storage::SpecialStoragePolicy* special_storage_policy) { | 151 storage::SpecialStoragePolicy* special_storage_policy, |
| 152 ChromeBlobStorageContext* blob_context, |
| 153 URLLoaderFactoryGetter* loader_factory_getter) { |
152 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 154 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
153 | 155 |
154 is_incognito_ = user_data_directory.empty(); | 156 is_incognito_ = user_data_directory.empty(); |
155 base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool(); | 157 base::SequencedWorkerPool* pool = BrowserThread::GetBlockingPool(); |
156 std::unique_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager( | 158 std::unique_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager( |
157 new ServiceWorkerDatabaseTaskManagerImpl(pool)); | 159 new ServiceWorkerDatabaseTaskManagerImpl(pool)); |
158 scoped_refptr<base::SingleThreadTaskRunner> disk_cache_thread = | 160 scoped_refptr<base::SingleThreadTaskRunner> disk_cache_thread = |
159 BrowserThread::GetTaskRunnerForThread(BrowserThread::CACHE); | 161 BrowserThread::GetTaskRunnerForThread(BrowserThread::CACHE); |
160 InitInternal(user_data_directory, std::move(database_task_manager), | 162 InitInternal(user_data_directory, std::move(database_task_manager), |
161 disk_cache_thread, quota_manager_proxy, special_storage_policy); | 163 disk_cache_thread, quota_manager_proxy, special_storage_policy, |
| 164 blob_context, loader_factory_getter); |
162 } | 165 } |
163 | 166 |
164 void ServiceWorkerContextWrapper::Shutdown() { | 167 void ServiceWorkerContextWrapper::Shutdown() { |
165 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 168 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
166 | 169 |
167 storage_partition_ = nullptr; | 170 storage_partition_ = nullptr; |
168 process_manager_->Shutdown(); | 171 process_manager_->Shutdown(); |
169 BrowserThread::PostTask( | 172 BrowserThread::PostTask( |
170 BrowserThread::IO, | 173 BrowserThread::IO, |
171 FROM_HERE, | 174 FROM_HERE, |
(...skipping 610 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
782 if (!context_core_) | 785 if (!context_core_) |
783 return false; | 786 return false; |
784 return context_core_->storage()->OriginHasForeignFetchRegistrations(origin); | 787 return context_core_->storage()->OriginHasForeignFetchRegistrations(origin); |
785 } | 788 } |
786 | 789 |
787 void ServiceWorkerContextWrapper::InitInternal( | 790 void ServiceWorkerContextWrapper::InitInternal( |
788 const base::FilePath& user_data_directory, | 791 const base::FilePath& user_data_directory, |
789 std::unique_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, | 792 std::unique_ptr<ServiceWorkerDatabaseTaskManager> database_task_manager, |
790 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, | 793 const scoped_refptr<base::SingleThreadTaskRunner>& disk_cache_thread, |
791 storage::QuotaManagerProxy* quota_manager_proxy, | 794 storage::QuotaManagerProxy* quota_manager_proxy, |
792 storage::SpecialStoragePolicy* special_storage_policy) { | 795 storage::SpecialStoragePolicy* special_storage_policy, |
| 796 ChromeBlobStorageContext* blob_context, |
| 797 URLLoaderFactoryGetter* loader_factory_getter) { |
793 if (!BrowserThread::CurrentlyOn(BrowserThread::IO)) { | 798 if (!BrowserThread::CurrentlyOn(BrowserThread::IO)) { |
794 BrowserThread::PostTask( | 799 BrowserThread::PostTask( |
795 BrowserThread::IO, FROM_HERE, | 800 BrowserThread::IO, FROM_HERE, |
796 base::Bind(&ServiceWorkerContextWrapper::InitInternal, this, | 801 base::Bind(&ServiceWorkerContextWrapper::InitInternal, this, |
797 user_data_directory, base::Passed(&database_task_manager), | 802 user_data_directory, base::Passed(&database_task_manager), |
798 disk_cache_thread, base::RetainedRef(quota_manager_proxy), | 803 disk_cache_thread, base::RetainedRef(quota_manager_proxy), |
799 base::RetainedRef(special_storage_policy))); | 804 base::RetainedRef(special_storage_policy), |
| 805 base::RetainedRef(blob_context), |
| 806 base::RetainedRef(loader_factory_getter))); |
800 return; | 807 return; |
801 } | 808 } |
802 // TODO(pkasting): Remove ScopedTracker below once crbug.com/477117 is fixed. | 809 // TODO(pkasting): Remove ScopedTracker below once crbug.com/477117 is fixed. |
803 tracked_objects::ScopedTracker tracking_profile( | 810 tracked_objects::ScopedTracker tracking_profile( |
804 FROM_HERE_WITH_EXPLICIT_FUNCTION( | 811 FROM_HERE_WITH_EXPLICIT_FUNCTION( |
805 "477117 ServiceWorkerContextWrapper::InitInternal")); | 812 "477117 ServiceWorkerContextWrapper::InitInternal")); |
806 DCHECK(!context_core_); | 813 DCHECK(!context_core_); |
807 if (quota_manager_proxy) { | 814 if (quota_manager_proxy) { |
808 quota_manager_proxy->RegisterClient(new ServiceWorkerQuotaClient(this)); | 815 quota_manager_proxy->RegisterClient(new ServiceWorkerQuotaClient(this)); |
809 } | 816 } |
810 context_core_.reset(new ServiceWorkerContextCore( | 817 context_core_.reset(new ServiceWorkerContextCore( |
811 user_data_directory, std::move(database_task_manager), disk_cache_thread, | 818 user_data_directory, std::move(database_task_manager), disk_cache_thread, |
812 quota_manager_proxy, special_storage_policy, core_observer_list_.get(), | 819 quota_manager_proxy, special_storage_policy, blob_context, |
813 this)); | 820 loader_factory_getter, core_observer_list_.get(), this)); |
814 } | 821 } |
815 | 822 |
816 void ServiceWorkerContextWrapper::ShutdownOnIO() { | 823 void ServiceWorkerContextWrapper::ShutdownOnIO() { |
817 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 824 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
818 resource_context_ = nullptr; | 825 resource_context_ = nullptr; |
819 context_core_.reset(); | 826 context_core_.reset(); |
820 } | 827 } |
821 | 828 |
822 bool ServiceWorkerContextWrapper::StartingExternalRequest( | 829 bool ServiceWorkerContextWrapper::StartingExternalRequest( |
823 int64_t service_worker_version_id, | 830 int64_t service_worker_version_id, |
(...skipping 135 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
959 service_worker_provider_id, | 966 service_worker_provider_id, |
960 std::move(client_ptr_info)); | 967 std::move(client_ptr_info)); |
961 } | 968 } |
962 | 969 |
963 ServiceWorkerContextCore* ServiceWorkerContextWrapper::context() { | 970 ServiceWorkerContextCore* ServiceWorkerContextWrapper::context() { |
964 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 971 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
965 return context_core_.get(); | 972 return context_core_.get(); |
966 } | 973 } |
967 | 974 |
968 } // namespace content | 975 } // namespace content |
OLD | NEW |