| OLD | NEW |
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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/background_fetch/background_fetch_context.h" | 5 #include "content/browser/background_fetch/background_fetch_context.h" |
| 6 | 6 |
| 7 #include "base/memory/ptr_util.h" | 7 #include "base/memory/ptr_util.h" |
| 8 #include "content/browser/background_fetch/background_fetch_data_manager.h" | 8 #include "content/browser/background_fetch/background_fetch_data_manager.h" |
| 9 #include "content/browser/background_fetch/background_fetch_event_dispatcher.h" | 9 #include "content/browser/background_fetch/background_fetch_event_dispatcher.h" |
| 10 #include "content/browser/background_fetch/background_fetch_job_controller.h" | 10 #include "content/browser/background_fetch/background_fetch_job_controller.h" |
| (...skipping 26 matching lines...) Expand all Loading... |
| 37 BackgroundFetchContext::BackgroundFetchContext( | 37 BackgroundFetchContext::BackgroundFetchContext( |
| 38 BrowserContext* browser_context, | 38 BrowserContext* browser_context, |
| 39 StoragePartitionImpl* storage_partition, | 39 StoragePartitionImpl* storage_partition, |
| 40 scoped_refptr<ServiceWorkerContextWrapper> service_worker_context) | 40 scoped_refptr<ServiceWorkerContextWrapper> service_worker_context) |
| 41 : browser_context_(browser_context), | 41 : browser_context_(browser_context), |
| 42 data_manager_( | 42 data_manager_( |
| 43 base::MakeUnique<BackgroundFetchDataManager>(browser_context)), | 43 base::MakeUnique<BackgroundFetchDataManager>(browser_context)), |
| 44 event_dispatcher_(base::MakeUnique<BackgroundFetchEventDispatcher>( | 44 event_dispatcher_(base::MakeUnique<BackgroundFetchEventDispatcher>( |
| 45 std::move(service_worker_context))) { | 45 std::move(service_worker_context))) { |
| 46 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 46 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 47 request_context_ = | |
| 48 make_scoped_refptr(storage_partition->GetURLRequestContext()); | |
| 49 } | 47 } |
| 50 | 48 |
| 51 BackgroundFetchContext::~BackgroundFetchContext() { | 49 BackgroundFetchContext::~BackgroundFetchContext() { |
| 52 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 50 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 53 } | 51 } |
| 54 | 52 |
| 53 void BackgroundFetchContext::InitializeOnIOThread( |
| 54 scoped_refptr<net::URLRequestContextGetter> request_context_getter) { |
| 55 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 56 request_context_getter_ = request_context_getter; |
| 57 } |
| 58 |
| 55 void BackgroundFetchContext::Shutdown() { | 59 void BackgroundFetchContext::Shutdown() { |
| 56 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 60 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 57 BrowserThread::PostTask( | 61 BrowserThread::PostTask( |
| 58 BrowserThread::IO, FROM_HERE, | 62 BrowserThread::IO, FROM_HERE, |
| 59 base::Bind(&BackgroundFetchContext::ShutdownOnIO, this)); | 63 base::Bind(&BackgroundFetchContext::ShutdownOnIO, this)); |
| 60 } | 64 } |
| 61 | 65 |
| 62 void BackgroundFetchContext::ShutdownOnIO() { | 66 void BackgroundFetchContext::ShutdownOnIO() { |
| 63 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 67 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 64 active_fetches_.clear(); | 68 active_fetches_.clear(); |
| (...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 139 return controller; | 143 return controller; |
| 140 } | 144 } |
| 141 | 145 |
| 142 void BackgroundFetchContext::CreateController( | 146 void BackgroundFetchContext::CreateController( |
| 143 const BackgroundFetchRegistrationId& registration_id, | 147 const BackgroundFetchRegistrationId& registration_id, |
| 144 const BackgroundFetchOptions& options, | 148 const BackgroundFetchOptions& options, |
| 145 std::vector<scoped_refptr<BackgroundFetchRequestInfo>> initial_requests) { | 149 std::vector<scoped_refptr<BackgroundFetchRequestInfo>> initial_requests) { |
| 146 std::unique_ptr<BackgroundFetchJobController> controller = | 150 std::unique_ptr<BackgroundFetchJobController> controller = |
| 147 base::MakeUnique<BackgroundFetchJobController>( | 151 base::MakeUnique<BackgroundFetchJobController>( |
| 148 registration_id, options, data_manager_.get(), browser_context_, | 152 registration_id, options, data_manager_.get(), browser_context_, |
| 149 request_context_, | 153 request_context_getter_, |
| 150 base::BindOnce(&BackgroundFetchContext::DidCompleteJob, this)); | 154 base::BindOnce(&BackgroundFetchContext::DidCompleteJob, this)); |
| 151 | 155 |
| 152 // TODO(peter): We should actually be able to use Background Fetch in layout | 156 // TODO(peter): We should actually be able to use Background Fetch in layout |
| 153 // tests. That requires a download manager and a request context. | 157 // tests. That requires a download manager and a request context. |
| 154 if (request_context_) { | 158 if (request_context_getter_) { |
| 155 // Start fetching the |initial_requests| immediately. At some point in the | 159 // Start fetching the |initial_requests| immediately. At some point in the |
| 156 // future we may want a more elaborate scheduling mechanism here. | 160 // future we may want a more elaborate scheduling mechanism here. |
| 157 controller->Start(std::move(initial_requests)); | 161 controller->Start(std::move(initial_requests)); |
| 158 } | 162 } |
| 159 | 163 |
| 160 active_fetches_.insert( | 164 active_fetches_.insert( |
| 161 std::make_pair(registration_id, std::move(controller))); | 165 std::make_pair(registration_id, std::move(controller))); |
| 162 } | 166 } |
| 163 | 167 |
| 164 void BackgroundFetchContext::DidCompleteJob( | 168 void BackgroundFetchContext::DidCompleteJob( |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 213 | 217 |
| 214 // Delete all persistent information associated with the |registration_id|. | 218 // Delete all persistent information associated with the |registration_id|. |
| 215 data_manager_->DeleteRegistration( | 219 data_manager_->DeleteRegistration( |
| 216 registration_id, base::BindOnce(&RecordRegistrationDeletedError)); | 220 registration_id, base::BindOnce(&RecordRegistrationDeletedError)); |
| 217 | 221 |
| 218 // Delete the local state associated with the |registration_id|. | 222 // Delete the local state associated with the |registration_id|. |
| 219 active_fetches_.erase(registration_id); | 223 active_fetches_.erase(registration_id); |
| 220 } | 224 } |
| 221 | 225 |
| 222 } // namespace content | 226 } // namespace content |
| OLD | NEW |