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_job_controller.h" | 9 #include "content/browser/background_fetch/background_fetch_job_controller.h" |
10 #include "content/browser/background_fetch/background_fetch_registration_id.h" | 10 #include "content/browser/background_fetch/background_fetch_registration_id.h" |
11 #include "content/browser/service_worker/service_worker_context_wrapper.h" | 11 #include "content/browser/service_worker/service_worker_context_wrapper.h" |
12 #include "content/browser/storage_partition_impl.h" | 12 #include "content/browser/storage_partition_impl.h" |
13 #include "content/public/browser/browser_context.h" | 13 #include "content/public/browser/browser_context.h" |
| 14 #include "net/url_request/url_request_context_getter.h" |
14 #include "url/origin.h" | 15 #include "url/origin.h" |
15 | 16 |
16 namespace content { | 17 namespace content { |
17 | 18 |
18 BackgroundFetchContext::BackgroundFetchContext( | 19 BackgroundFetchContext::BackgroundFetchContext( |
19 BrowserContext* browser_context, | 20 BrowserContext* browser_context, |
20 StoragePartitionImpl* storage_partition, | 21 StoragePartitionImpl* storage_partition, |
21 const scoped_refptr<ServiceWorkerContextWrapper>& service_worker_context) | 22 const scoped_refptr<ServiceWorkerContextWrapper>& service_worker_context) |
22 : browser_context_(browser_context), | 23 : browser_context_(browser_context), |
23 storage_partition_(storage_partition), | |
24 service_worker_context_(service_worker_context), | 24 service_worker_context_(service_worker_context), |
25 background_fetch_data_manager_( | 25 background_fetch_data_manager_( |
26 base::MakeUnique<BackgroundFetchDataManager>(browser_context)) { | 26 base::MakeUnique<BackgroundFetchDataManager>(browser_context)) { |
27 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 27 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
28 download_manager_ = BrowserContext::GetDownloadManager(browser_context_); | 28 download_manager_ = BrowserContext::GetDownloadManager(browser_context_); |
| 29 request_context_ = |
| 30 make_scoped_refptr(storage_partition->GetURLRequestContext()); |
29 } | 31 } |
30 | 32 |
31 BackgroundFetchContext::~BackgroundFetchContext() { | 33 BackgroundFetchContext::~BackgroundFetchContext() { |
32 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 34 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
33 } | 35 } |
34 | 36 |
35 void BackgroundFetchContext::Shutdown() { | 37 void BackgroundFetchContext::Shutdown() { |
36 DCHECK_CURRENTLY_ON(BrowserThread::UI); | 38 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
37 BrowserThread::PostTask( | 39 BrowserThread::PostTask( |
38 BrowserThread::IO, FROM_HERE, | 40 BrowserThread::IO, FROM_HERE, |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
117 | 119 |
118 return controller; | 120 return controller; |
119 } | 121 } |
120 | 122 |
121 void BackgroundFetchContext::CreateController( | 123 void BackgroundFetchContext::CreateController( |
122 const BackgroundFetchRegistrationId& registration_id, | 124 const BackgroundFetchRegistrationId& registration_id, |
123 const BackgroundFetchOptions& options, | 125 const BackgroundFetchOptions& options, |
124 std::vector<BackgroundFetchRequestInfo> initial_requests) { | 126 std::vector<BackgroundFetchRequestInfo> initial_requests) { |
125 std::unique_ptr<BackgroundFetchJobController> controller = | 127 std::unique_ptr<BackgroundFetchJobController> controller = |
126 base::MakeUnique<BackgroundFetchJobController>( | 128 base::MakeUnique<BackgroundFetchJobController>( |
127 registration_id, options, download_manager_, storage_partition_, | 129 registration_id, options, background_fetch_data_manager_.get(), |
128 background_fetch_data_manager_.get(), | 130 download_manager_, request_context_, |
129 base::BindOnce(&BackgroundFetchContext::DidCompleteJob, this)); | 131 base::BindOnce(&BackgroundFetchContext::DidCompleteJob, this)); |
130 | 132 |
131 // TODO(peter): Start actually fetching the files. | 133 // TODO(peter): We should actually be able to use Background Fetch in layout |
| 134 // tests. That requires a download manager and a request context. |
| 135 if (download_manager_ && request_context_) { |
| 136 // Start fetching the |initial_requests| immediately. At some point in the |
| 137 // future we may want a more elaborate scheduling mechanism here. |
| 138 controller->Start(std::move(initial_requests)); |
| 139 } |
132 | 140 |
133 active_fetches_.insert( | 141 active_fetches_.insert( |
134 std::make_pair(registration_id, std::move(controller))); | 142 std::make_pair(registration_id, std::move(controller))); |
135 } | 143 } |
136 | 144 |
137 void BackgroundFetchContext::DidCompleteJob( | 145 void BackgroundFetchContext::DidCompleteJob( |
138 BackgroundFetchJobController* controller) { | 146 BackgroundFetchJobController* controller) { |
139 const BackgroundFetchRegistrationId& registration_id = | 147 const BackgroundFetchRegistrationId& registration_id = |
140 controller->registration_id(); | 148 controller->registration_id(); |
141 | 149 |
142 DCHECK_GT(active_fetches_.count(registration_id), 0u); | 150 DCHECK_GT(active_fetches_.count(registration_id), 0u); |
143 | 151 |
144 if (controller->state() == BackgroundFetchJobController::State::COMPLETED) { | 152 if (controller->state() == BackgroundFetchJobController::State::COMPLETED) { |
145 // TODO(peter): Dispatch the `backgroundfetched` or `backgroundfetchfail` | 153 // TODO(peter): Dispatch the `backgroundfetched` or `backgroundfetchfail` |
146 // event to the Service Worker to inform the developer. | 154 // event to the Service Worker to inform the developer. |
147 } | 155 } |
148 | 156 |
149 active_fetches_.erase(registration_id); | 157 active_fetches_.erase(registration_id); |
150 } | 158 } |
151 | 159 |
152 } // namespace content | 160 } // namespace content |
OLD | NEW |