| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 "components/offline_pages/background/update_request_task.h" | 5 #include "components/offline_pages/background/update_request_task.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/time/time.h" | 10 #include "base/time/time.h" |
| (...skipping 16 matching lines...) Expand all Loading... |
| 27 } | 27 } |
| 28 | 28 |
| 29 void UpdateRequestTask::ReadRequest() { | 29 void UpdateRequestTask::ReadRequest() { |
| 30 std::vector<int64_t> request_ids{request_id_}; | 30 std::vector<int64_t> request_ids{request_id_}; |
| 31 store_->GetRequestsByIds(request_ids, | 31 store_->GetRequestsByIds(request_ids, |
| 32 base::Bind(&UpdateRequestTask::UpdateRequestImpl, | 32 base::Bind(&UpdateRequestTask::UpdateRequestImpl, |
| 33 weak_ptr_factory_.GetWeakPtr())); | 33 weak_ptr_factory_.GetWeakPtr())); |
| 34 } | 34 } |
| 35 | 35 |
| 36 void UpdateRequestTask::CompleteWithResult( | 36 void UpdateRequestTask::CompleteWithResult( |
| 37 std::unique_ptr<UpdateRequestsResult> result) { | 37 std::unique_ptr<QueueResults::UpdateRequestsResult> result) { |
| 38 callback_.Run(std::move(result)); | 38 callback_.Run(std::move(result)); |
| 39 TaskComplete(); | 39 TaskComplete(); |
| 40 } | 40 } |
| 41 | 41 |
| 42 bool UpdateRequestTask::ValidateReadResult(UpdateRequestsResult* result) { | 42 bool UpdateRequestTask::ValidateReadResult( |
| 43 QueueResults::UpdateRequestsResult* result) { |
| 43 return result->store_state == StoreState::LOADED && | 44 return result->store_state == StoreState::LOADED && |
| 44 result->item_statuses.at(0).first == request_id() && | 45 result->item_statuses.at(0).first == request_id() && |
| 45 result->item_statuses.at(0).second == ItemActionStatus::SUCCESS && | 46 result->item_statuses.at(0).second == ItemActionStatus::SUCCESS && |
| 46 result->updated_items.size() == 1 && | 47 result->updated_items.size() == 1 && |
| 47 result->updated_items.at(0).request_id() == request_id(); | 48 result->updated_items.at(0).request_id() == request_id(); |
| 48 } | 49 } |
| 49 | 50 |
| 50 } // namespace offline_pages | 51 } // namespace offline_pages |
| OLD | NEW |