| Index: content/browser/background_fetch/background_fetch_data_manager_unittest.cc
|
| diff --git a/content/browser/background_fetch/background_fetch_data_manager_unittest.cc b/content/browser/background_fetch/background_fetch_data_manager_unittest.cc
|
| index 11fac5bd651cb2cd601f9367383c6fa39197e66f..dfb89344cc59113fef1c8e8fa95cdcb667914518 100644
|
| --- a/content/browser/background_fetch/background_fetch_data_manager_unittest.cc
|
| +++ b/content/browser/background_fetch/background_fetch_data_manager_unittest.cc
|
| @@ -6,28 +6,19 @@
|
|
|
| #include <memory>
|
| #include <string>
|
| -#include <vector>
|
|
|
| #include "base/bind_helpers.h"
|
| #include "base/callback_helpers.h"
|
| #include "base/memory/ptr_util.h"
|
| #include "base/run_loop.h"
|
| -#include "content/browser/background_fetch/background_fetch_job_info.h"
|
| -#include "content/browser/background_fetch/background_fetch_job_response_data.h"
|
| #include "content/browser/background_fetch/background_fetch_request_info.h"
|
| #include "content/browser/background_fetch/background_fetch_test_base.h"
|
| -#include "content/common/service_worker/service_worker_types.h"
|
| #include "content/public/browser/browser_thread.h"
|
| -#include "content/public/browser/download_interrupt_reasons.h"
|
| -#include "content/public/browser/download_item.h"
|
|
|
| namespace content {
|
| namespace {
|
|
|
| -const char kResource[] = "https://example.com/resource.html";
|
| -const char kTag[] = "TestRequestTag";
|
| -const char kJobOrigin[] = "https://example.com";
|
| -const int64_t kServiceWorkerRegistrationId = 9001;
|
| +const char kExampleTag[] = "my-example-tag";
|
|
|
| } // namespace
|
|
|
| @@ -71,62 +62,6 @@ class BackgroundFetchDataManagerTest : public BackgroundFetchTestBase {
|
| run_loop.Run();
|
| }
|
|
|
| - void CreateRequests(int num_requests) {
|
| - DCHECK_GT(num_requests, 0);
|
| - // Create |num_requests| BackgroundFetchRequestInfo's.
|
| - std::vector<std::unique_ptr<BackgroundFetchRequestInfo>> request_infos;
|
| - for (int i = 0; i < num_requests; i++) {
|
| - ServiceWorkerHeaderMap headers;
|
| - ServiceWorkerFetchRequest request(GURL(kResource), "GET", headers,
|
| - Referrer(), false /* is_reload */);
|
| - request_infos.push_back(
|
| - base::MakeUnique<BackgroundFetchRequestInfo>(i, request));
|
| - }
|
| - std::unique_ptr<BackgroundFetchJobInfo> job_info =
|
| - base::MakeUnique<BackgroundFetchJobInfo>(
|
| - kTag, url::Origin(GURL(kJobOrigin)), kServiceWorkerRegistrationId);
|
| - job_info->set_num_requests(num_requests);
|
| -
|
| - job_guid_ = job_info->guid();
|
| -
|
| - background_fetch_data_manager_->WriteJobToStorage(std::move(job_info),
|
| - std::move(request_infos));
|
| - }
|
| -
|
| - void GetResponse() {
|
| - base::RunLoop run_loop;
|
| - BackgroundFetchResponseCompleteCallback callback =
|
| - base::Bind(&BackgroundFetchDataManagerTest::DidGetResponse,
|
| - base::Unretained(this), run_loop.QuitClosure());
|
| - BrowserThread::PostTask(
|
| - BrowserThread::IO, FROM_HERE,
|
| - base::Bind(&BackgroundFetchDataManager::GetJobResponse,
|
| - base::Unretained(background_fetch_data_manager()), job_guid_,
|
| - base::Bind(&BackgroundFetchDataManagerTest::DidGetResponse,
|
| - base::Unretained(this), run_loop.QuitClosure())));
|
| - run_loop.Run();
|
| - }
|
| -
|
| - void DidGetResponse(base::Closure closure,
|
| - std::vector<ServiceWorkerResponse> responses,
|
| - std::vector<std::unique_ptr<BlobHandle>> blobs) {
|
| - responses_ = std::move(responses);
|
| - blobs_ = std::move(blobs);
|
| - BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, closure);
|
| - }
|
| -
|
| - const std::string& job_guid() const { return job_guid_; }
|
| - BackgroundFetchDataManager* background_fetch_data_manager() {
|
| - return background_fetch_data_manager_.get();
|
| - }
|
| -
|
| - const std::vector<ServiceWorkerResponse>& responses() const {
|
| - return responses_;
|
| - }
|
| - const std::vector<std::unique_ptr<BlobHandle>>& blobs() const {
|
| - return blobs_;
|
| - }
|
| -
|
| private:
|
| void DidCreateRegistration(
|
| base::Closure quit_closure,
|
| @@ -150,8 +85,6 @@ class BackgroundFetchDataManagerTest : public BackgroundFetchTestBase {
|
|
|
| std::string job_guid_;
|
| std::unique_ptr<BackgroundFetchDataManager> background_fetch_data_manager_;
|
| - std::vector<ServiceWorkerResponse> responses_;
|
| - std::vector<std::unique_ptr<BlobHandle>> blobs_;
|
| };
|
|
|
| TEST_F(BackgroundFetchDataManagerTest, NoDuplicateRegistrations) {
|
| @@ -159,7 +92,7 @@ TEST_F(BackgroundFetchDataManagerTest, NoDuplicateRegistrations) {
|
| // registration that's already known to the system.
|
|
|
| BackgroundFetchRegistrationId registration_id;
|
| - ASSERT_TRUE(CreateRegistrationId(kTag, ®istration_id));
|
| + ASSERT_TRUE(CreateRegistrationId(kExampleTag, ®istration_id));
|
|
|
| std::vector<ServiceWorkerFetchRequest> requests;
|
| BackgroundFetchOptions options;
|
| @@ -191,117 +124,4 @@ TEST_F(BackgroundFetchDataManagerTest, NoDuplicateRegistrations) {
|
| EXPECT_EQ(error, blink::mojom::BackgroundFetchError::NONE);
|
| }
|
|
|
| -TEST_F(BackgroundFetchDataManagerTest, OutOfOrderCompletion) {
|
| - CreateRequests(10);
|
| - BackgroundFetchDataManager* data_manager = background_fetch_data_manager();
|
| - const std::string& job_guid = BackgroundFetchDataManagerTest::job_guid();
|
| - std::vector<std::string> request_guids;
|
| -
|
| - // Start half of the fetch requests.
|
| - for (int i = 0; i < 5; i++) {
|
| - ASSERT_TRUE(data_manager->HasRequestsRemaining(job_guid));
|
| - const BackgroundFetchRequestInfo& request_info =
|
| - data_manager->GetNextBackgroundFetchRequestInfo(job_guid);
|
| - request_guids.push_back(request_info.guid());
|
| - }
|
| -
|
| - // Complete all of the fetches out of order except for #1.
|
| - DownloadItem::DownloadState complete = DownloadItem::DownloadState::COMPLETE;
|
| - DownloadInterruptReason no_interrupt =
|
| - DownloadInterruptReason::DOWNLOAD_INTERRUPT_REASON_NONE;
|
| - EXPECT_TRUE(data_manager->UpdateRequestState(job_guid, request_guids[3],
|
| - complete, no_interrupt));
|
| - EXPECT_TRUE(data_manager->UpdateRequestState(job_guid, request_guids[2],
|
| - complete, no_interrupt));
|
| - EXPECT_TRUE(data_manager->UpdateRequestState(job_guid, request_guids[4],
|
| - complete, no_interrupt));
|
| - EXPECT_TRUE(data_manager->UpdateRequestState(job_guid, request_guids[0],
|
| - complete, no_interrupt));
|
| -
|
| - EXPECT_TRUE(data_manager->HasRequestsRemaining(job_guid));
|
| - EXPECT_FALSE(data_manager->IsComplete(job_guid));
|
| -
|
| - // Start and complete the remaining requests.
|
| - for (int i = 5; i < 10; i++) {
|
| - const BackgroundFetchRequestInfo& request_info =
|
| - data_manager->GetNextBackgroundFetchRequestInfo(job_guid);
|
| - request_guids.push_back(request_info.guid());
|
| - data_manager->UpdateRequestState(job_guid, request_guids[i], complete,
|
| - no_interrupt);
|
| - }
|
| -
|
| - EXPECT_FALSE(data_manager->IsComplete(job_guid));
|
| - EXPECT_FALSE(data_manager->HasRequestsRemaining(job_guid));
|
| -
|
| - // Complete the final request.
|
| - EXPECT_FALSE(data_manager->UpdateRequestState(job_guid, request_guids[1],
|
| - complete, no_interrupt));
|
| - EXPECT_TRUE(data_manager->IsComplete(job_guid));
|
| -}
|
| -
|
| -TEST_F(BackgroundFetchDataManagerTest, PauseAndResume) {
|
| - CreateRequests(1);
|
| - BackgroundFetchDataManager* data_manager = background_fetch_data_manager();
|
| - const std::string& job_guid = BackgroundFetchDataManagerTest::job_guid();
|
| -
|
| - // Start the request.
|
| - ASSERT_TRUE(data_manager->HasRequestsRemaining(job_guid));
|
| - const BackgroundFetchRequestInfo& request_info =
|
| - data_manager->GetNextBackgroundFetchRequestInfo(job_guid);
|
| -
|
| - EXPECT_FALSE(data_manager->HasRequestsRemaining(job_guid));
|
| - EXPECT_FALSE(data_manager->IsComplete(job_guid));
|
| -
|
| - // Set the request state to be paused. This should not complete the job.
|
| - EXPECT_FALSE(data_manager->UpdateRequestState(
|
| - job_guid, request_info.guid(), DownloadItem::DownloadState::INTERRUPTED,
|
| - DownloadInterruptReason::DOWNLOAD_INTERRUPT_REASON_USER_SHUTDOWN));
|
| - EXPECT_FALSE(data_manager->IsComplete(job_guid));
|
| -
|
| - // Unpause the request.
|
| - EXPECT_FALSE(data_manager->UpdateRequestState(
|
| - job_guid, request_info.guid(), DownloadItem::DownloadState::IN_PROGRESS,
|
| - DownloadInterruptReason::DOWNLOAD_INTERRUPT_REASON_NONE));
|
| - EXPECT_FALSE(data_manager->IsComplete(job_guid));
|
| -
|
| - // Complete the request.
|
| - EXPECT_FALSE(data_manager->UpdateRequestState(
|
| - job_guid, request_info.guid(), DownloadItem::DownloadState::COMPLETE,
|
| - DownloadInterruptReason::DOWNLOAD_INTERRUPT_REASON_NONE));
|
| - EXPECT_TRUE(data_manager->IsComplete(job_guid));
|
| -}
|
| -
|
| -TEST_F(BackgroundFetchDataManagerTest, CancelledRequest) {
|
| - CreateRequests(1);
|
| - BackgroundFetchDataManager* data_manager = background_fetch_data_manager();
|
| - const std::string& job_guid = BackgroundFetchDataManagerTest::job_guid();
|
| -
|
| - // Start the request.
|
| - ASSERT_TRUE(data_manager->HasRequestsRemaining(job_guid));
|
| - const BackgroundFetchRequestInfo& request_info =
|
| - data_manager->GetNextBackgroundFetchRequestInfo(job_guid);
|
| -
|
| - EXPECT_FALSE(data_manager->HasRequestsRemaining(job_guid));
|
| - EXPECT_FALSE(data_manager->IsComplete(job_guid));
|
| -
|
| - // Cancel the request.
|
| - EXPECT_FALSE(data_manager->UpdateRequestState(
|
| - job_guid, request_info.guid(), DownloadItem::DownloadState::CANCELLED,
|
| - DownloadInterruptReason::DOWNLOAD_INTERRUPT_REASON_FILE_NO_SPACE));
|
| - EXPECT_TRUE(data_manager->IsComplete(job_guid));
|
| -}
|
| -
|
| -TEST_F(BackgroundFetchDataManagerTest, PrepareResponse) {
|
| - CreateRequests(1);
|
| - BackgroundFetchDataManager* data_manager = background_fetch_data_manager();
|
| - const std::string& job_guid = BackgroundFetchDataManagerTest::job_guid();
|
| -
|
| - const BackgroundFetchRequestInfo& request_info =
|
| - data_manager->GetNextBackgroundFetchRequestInfo(job_guid);
|
| - EXPECT_FALSE(data_manager->UpdateRequestState(
|
| - job_guid, request_info.guid(), DownloadItem::DownloadState::COMPLETE,
|
| - DownloadInterruptReason::DOWNLOAD_INTERRUPT_REASON_FILE_NO_SPACE));
|
| - EXPECT_TRUE(data_manager->IsComplete(job_guid));
|
| -}
|
| -
|
| } // namespace content
|
|
|