| 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_data_manager.h" | 5 #include "content/browser/background_fetch/background_fetch_data_manager.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <string> | 8 #include <string> |
| 9 #include <vector> | 9 #include <vector> |
| 10 | 10 |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 69 base::Unretained(this), run_loop.QuitClosure(), | 69 base::Unretained(this), run_loop.QuitClosure(), |
| 70 out_error)); | 70 out_error)); |
| 71 run_loop.Run(); | 71 run_loop.Run(); |
| 72 } | 72 } |
| 73 | 73 |
| 74 void CreateRequests(int num_requests) { | 74 void CreateRequests(int num_requests) { |
| 75 DCHECK_GT(num_requests, 0); | 75 DCHECK_GT(num_requests, 0); |
| 76 // Create |num_requests| BackgroundFetchRequestInfo's. | 76 // Create |num_requests| BackgroundFetchRequestInfo's. |
| 77 std::vector<std::unique_ptr<BackgroundFetchRequestInfo>> request_infos; | 77 std::vector<std::unique_ptr<BackgroundFetchRequestInfo>> request_infos; |
| 78 for (int i = 0; i < num_requests; i++) { | 78 for (int i = 0; i < num_requests; i++) { |
| 79 ServiceWorkerHeaderMap headers; |
| 80 ServiceWorkerFetchRequest request(GURL(kResource), "GET", headers, |
| 81 Referrer(), false /* is_reload */); |
| 79 request_infos.push_back( | 82 request_infos.push_back( |
| 80 base::MakeUnique<BackgroundFetchRequestInfo>(GURL(kResource), kTag)); | 83 base::MakeUnique<BackgroundFetchRequestInfo>(request)); |
| 81 } | 84 } |
| 82 std::unique_ptr<BackgroundFetchJobInfo> job_info = | 85 std::unique_ptr<BackgroundFetchJobInfo> job_info = |
| 83 base::MakeUnique<BackgroundFetchJobInfo>( | 86 base::MakeUnique<BackgroundFetchJobInfo>( |
| 84 "tag", url::Origin(GURL(kJobOrigin)), kServiceWorkerRegistrationId); | 87 kTag, url::Origin(GURL(kJobOrigin)), kServiceWorkerRegistrationId); |
| 85 job_info->set_num_requests(num_requests); | 88 job_info->set_num_requests(num_requests); |
| 86 | 89 |
| 87 job_guid_ = job_info->guid(); | 90 job_guid_ = job_info->guid(); |
| 88 | 91 |
| 89 background_fetch_data_manager_->WriteJobToStorage(std::move(job_info), | 92 background_fetch_data_manager_->WriteJobToStorage(std::move(job_info), |
| 90 std::move(request_infos)); | 93 std::move(request_infos)); |
| 91 } | 94 } |
| 92 | 95 |
| 93 void GetResponse() { | 96 void GetResponse() { |
| 94 base::RunLoop run_loop; | 97 base::RunLoop run_loop; |
| (...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 291 | 294 |
| 292 const BackgroundFetchRequestInfo& request_info = | 295 const BackgroundFetchRequestInfo& request_info = |
| 293 data_manager->GetNextBackgroundFetchRequestInfo(job_guid); | 296 data_manager->GetNextBackgroundFetchRequestInfo(job_guid); |
| 294 EXPECT_FALSE(data_manager->UpdateRequestState( | 297 EXPECT_FALSE(data_manager->UpdateRequestState( |
| 295 job_guid, request_info.guid(), DownloadItem::DownloadState::COMPLETE, | 298 job_guid, request_info.guid(), DownloadItem::DownloadState::COMPLETE, |
| 296 DownloadInterruptReason::DOWNLOAD_INTERRUPT_REASON_FILE_NO_SPACE)); | 299 DownloadInterruptReason::DOWNLOAD_INTERRUPT_REASON_FILE_NO_SPACE)); |
| 297 EXPECT_TRUE(data_manager->IsComplete(job_guid)); | 300 EXPECT_TRUE(data_manager->IsComplete(job_guid)); |
| 298 } | 301 } |
| 299 | 302 |
| 300 } // namespace content | 303 } // namespace content |
| OLD | NEW |