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/offline_page_storage_manager.h" | 5 #include "components/offline_pages/offline_page_storage_manager.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/time/clock.h" | 10 #include "base/time/clock.h" |
11 #include "base/time/default_clock.h" | 11 #include "base/time/default_clock.h" |
12 #include "components/offline_pages/client_policy_controller.h" | 12 #include "components/offline_pages/client_policy_controller.h" |
13 #include "components/offline_pages/offline_page_client_policy.h" | 13 #include "components/offline_pages/offline_page_client_policy.h" |
14 #include "components/offline_pages/offline_page_item.h" | 14 #include "components/offline_pages/offline_page_item.h" |
| 15 #include "components/offline_pages/offline_page_model.h" |
15 | 16 |
16 namespace offline_pages { | 17 namespace offline_pages { |
17 | 18 |
18 OfflinePageStorageManager::OfflinePageStorageManager( | 19 OfflinePageStorageManager::OfflinePageStorageManager( |
19 Client* client, | 20 OfflinePageModel* model, |
20 ClientPolicyController* policy_controller, | 21 ClientPolicyController* policy_controller, |
21 ArchiveManager* archive_manager) | 22 ArchiveManager* archive_manager) |
22 : client_(client), | 23 : model_(model), |
23 policy_controller_(policy_controller), | 24 policy_controller_(policy_controller), |
24 archive_manager_(archive_manager), | 25 archive_manager_(archive_manager), |
25 clock_(new base::DefaultClock()), | 26 clock_(new base::DefaultClock()), |
26 weak_ptr_factory_(this) {} | 27 weak_ptr_factory_(this) {} |
27 | 28 |
28 OfflinePageStorageManager::~OfflinePageStorageManager() {} | 29 OfflinePageStorageManager::~OfflinePageStorageManager() {} |
29 | 30 |
30 void OfflinePageStorageManager::ClearPagesIfNeeded( | 31 void OfflinePageStorageManager::ClearPagesIfNeeded( |
31 const ClearStorageCallback& callback) { | 32 const ClearStorageCallback& callback) { |
32 if (IsInProgress()) | 33 if (IsInProgress()) |
(...skipping 12 matching lines...) Expand all Loading... |
45 void OfflinePageStorageManager::OnGetStorageStatsDoneForClearingPages( | 46 void OfflinePageStorageManager::OnGetStorageStatsDoneForClearingPages( |
46 const ClearStorageCallback& callback, | 47 const ClearStorageCallback& callback, |
47 const ArchiveManager::StorageStats& stats) { | 48 const ArchiveManager::StorageStats& stats) { |
48 DCHECK(IsInProgress()); | 49 DCHECK(IsInProgress()); |
49 ClearMode mode = ShouldClearPages(stats); | 50 ClearMode mode = ShouldClearPages(stats); |
50 if (mode == ClearMode::NOT_NEEDED) { | 51 if (mode == ClearMode::NOT_NEEDED) { |
51 last_clear_time_ = clear_time_; | 52 last_clear_time_ = clear_time_; |
52 callback.Run(0, ClearStorageResult::UNNECESSARY); | 53 callback.Run(0, ClearStorageResult::UNNECESSARY); |
53 return; | 54 return; |
54 } | 55 } |
55 client_->GetAllPages( | 56 model_->GetAllPages( |
56 base::Bind(&OfflinePageStorageManager::OnGetAllPagesDoneForClearingPages, | 57 base::Bind(&OfflinePageStorageManager::OnGetAllPagesDoneForClearingPages, |
57 weak_ptr_factory_.GetWeakPtr(), callback, stats)); | 58 weak_ptr_factory_.GetWeakPtr(), callback, stats)); |
58 } | 59 } |
59 | 60 |
60 void OfflinePageStorageManager::OnGetAllPagesDoneForClearingPages( | 61 void OfflinePageStorageManager::OnGetAllPagesDoneForClearingPages( |
61 const ClearStorageCallback& callback, | 62 const ClearStorageCallback& callback, |
62 const ArchiveManager::StorageStats& stats, | 63 const ArchiveManager::StorageStats& stats, |
63 const MultipleOfflinePageItemResult& pages) { | 64 const MultipleOfflinePageItemResult& pages) { |
64 std::vector<int64_t> page_ids_to_expire; | 65 std::vector<int64_t> page_ids_to_expire; |
65 std::vector<int64_t> page_ids_to_remove; | 66 std::vector<int64_t> page_ids_to_remove; |
66 GetPageIdsToClear(pages, stats, &page_ids_to_expire, &page_ids_to_remove); | 67 GetPageIdsToClear(pages, stats, &page_ids_to_expire, &page_ids_to_remove); |
67 client_->ExpirePages( | 68 model_->ExpirePages( |
68 page_ids_to_expire, clear_time_, | 69 page_ids_to_expire, clear_time_, |
69 base::Bind(&OfflinePageStorageManager::OnPagesExpired, | 70 base::Bind(&OfflinePageStorageManager::OnPagesExpired, |
70 weak_ptr_factory_.GetWeakPtr(), callback, | 71 weak_ptr_factory_.GetWeakPtr(), callback, |
71 page_ids_to_expire.size(), page_ids_to_remove)); | 72 page_ids_to_expire.size(), page_ids_to_remove)); |
72 } | 73 } |
73 | 74 |
74 void OfflinePageStorageManager::OnPagesExpired( | 75 void OfflinePageStorageManager::OnPagesExpired( |
75 const ClearStorageCallback& callback, | 76 const ClearStorageCallback& callback, |
76 size_t pages_expired, | 77 size_t pages_expired, |
77 const std::vector<int64_t>& page_ids_to_remove, | 78 const std::vector<int64_t>& page_ids_to_remove, |
78 bool expiration_succeeded) { | 79 bool expiration_succeeded) { |
79 // We want to delete the outdated page records regardless the expiration | 80 // We want to delete the outdated page records regardless the expiration |
80 // succeeded or not. | 81 // succeeded or not. |
81 client_->DeletePagesByOfflineId( | 82 model_->DeletePagesByOfflineId( |
82 page_ids_to_remove, | 83 page_ids_to_remove, |
83 base::Bind(&OfflinePageStorageManager::OnOutdatedPagesCleared, | 84 base::Bind(&OfflinePageStorageManager::OnOutdatedPagesCleared, |
84 weak_ptr_factory_.GetWeakPtr(), callback, pages_expired, | 85 weak_ptr_factory_.GetWeakPtr(), callback, pages_expired, |
85 expiration_succeeded)); | 86 expiration_succeeded)); |
86 } | 87 } |
87 | 88 |
88 void OfflinePageStorageManager::OnOutdatedPagesCleared( | 89 void OfflinePageStorageManager::OnOutdatedPagesCleared( |
89 const ClearStorageCallback& callback, | 90 const ClearStorageCallback& callback, |
90 size_t pages_cleared, | 91 size_t pages_cleared, |
91 bool expiration_succeeded, | 92 bool expiration_succeeded, |
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
200 const LifetimePolicy& policy = | 201 const LifetimePolicy& policy = |
201 policy_controller_->GetPolicy(page.client_id.name_space).lifetime_policy; | 202 policy_controller_->GetPolicy(page.client_id.name_space).lifetime_policy; |
202 return clear_time_ - page.last_access_time >= policy.expiration_period; | 203 return clear_time_ - page.last_access_time >= policy.expiration_period; |
203 } | 204 } |
204 | 205 |
205 bool OfflinePageStorageManager::IsInProgress() const { | 206 bool OfflinePageStorageManager::IsInProgress() const { |
206 return clear_time_ > last_clear_time_; | 207 return clear_time_ > last_clear_time_; |
207 } | 208 } |
208 | 209 |
209 } // namespace offline_pages | 210 } // namespace offline_pages |
OLD | NEW |