Request Picker task

components/offline_pages/background/mark_attempt_aborted_task_unittest.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/offline_pages/background/mark_attempt_aborted_task.h"
 
 #include <memory>
 
 #include "base/bind.h"
 #include "base/test/test_simple_task_runner.h"
@@ skipping 15 matching lines @@
   MarkAttemptAbortedTaskTest();
   ~MarkAttemptAbortedTaskTest() override;
 
   void PumpLoop();
 
   void AddItemToStore(RequestQueueStore* store);
 
   void AddRequestDone(ItemActionStatus status);
 
   void ChangeRequestsStateCallback(
-      std::unique_ptr<UpdateRequestsResult> result);
+      std::unique_ptr<QueueResults::UpdateRequestsResult> result);
 
   void ClearResults();
 
-  UpdateRequestsResult* last_result() const { return result_.get(); }
+  QueueResults::UpdateRequestsResult* last_result() const {
+    return result_.get();
+  }
 
  private:
-  std::unique_ptr<UpdateRequestsResult> result_;
+  std::unique_ptr<QueueResults::UpdateRequestsResult> result_;
   scoped_refptr<base::TestSimpleTaskRunner> task_runner_;
   base::ThreadTaskRunnerHandle task_runner_handle_;
 };
 
 MarkAttemptAbortedTaskTest::MarkAttemptAbortedTaskTest()
     : task_runner_(new base::TestSimpleTaskRunner),
       task_runner_handle_(task_runner_) {}
 
 MarkAttemptAbortedTaskTest::~MarkAttemptAbortedTaskTest() {}
 
 void MarkAttemptAbortedTaskTest::PumpLoop() {
   task_runner_->RunUntilIdle();
 }
 
 void MarkAttemptAbortedTaskTest::AddItemToStore(RequestQueueStore* store) {
   base::Time creation_time = base::Time::Now();
   SavePageRequest request_1(kRequestId1, kUrl1, kClientId1, creation_time,
                             true);
   store->AddRequest(request_1,
                     base::Bind(&MarkAttemptAbortedTaskTest::AddRequestDone,
                                base::Unretained(this)));
   PumpLoop();
 }
 
 void MarkAttemptAbortedTaskTest::AddRequestDone(ItemActionStatus status) {
   ASSERT_EQ(ItemActionStatus::SUCCESS, status);
 }
 
 void MarkAttemptAbortedTaskTest::ChangeRequestsStateCallback(
-    std::unique_ptr<UpdateRequestsResult> result) {
+    std::unique_ptr<QueueResults::UpdateRequestsResult> result) {
   result_ = std::move(result);
 }
 
 void MarkAttemptAbortedTaskTest::ClearResults() {
   result_.reset(nullptr);
 }
 
 TEST_F(MarkAttemptAbortedTaskTest, MarkAttemptAbortedWhenStoreEmpty) {
   RequestQueueInMemoryStore store;
   MarkAttemptAbortedTask task(
@@ skipping 51 matching lines @@
   PumpLoop();
   ASSERT_TRUE(last_result());
   EXPECT_EQ(1UL, last_result()->item_statuses.size());
   EXPECT_EQ(kRequestId2, last_result()->item_statuses.at(0).first);
   EXPECT_EQ(ItemActionStatus::NOT_FOUND,
             last_result()->item_statuses.at(0).second);
   EXPECT_EQ(0UL, last_result()->updated_items.size());
 }
 
 }  // namespace offline_pages