| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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_model.h" | 5 #include "components/offline_pages/offline_page_model.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
| (...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 105 scoped_ptr<OfflinePageArchiver> archiver, | 105 scoped_ptr<OfflinePageArchiver> archiver, |
| 106 const SavePageCallback& callback) { | 106 const SavePageCallback& callback) { |
| 107 DCHECK(is_loaded_); | 107 DCHECK(is_loaded_); |
| 108 DCHECK(archiver.get()); | 108 DCHECK(archiver.get()); |
| 109 archiver->CreateArchive(base::Bind(&OfflinePageModel::OnCreateArchiveDone, | 109 archiver->CreateArchive(base::Bind(&OfflinePageModel::OnCreateArchiveDone, |
| 110 weak_ptr_factory_.GetWeakPtr(), url, | 110 weak_ptr_factory_.GetWeakPtr(), url, |
| 111 bookmark_id, callback)); | 111 bookmark_id, callback)); |
| 112 pending_archivers_.push_back(archiver.Pass()); | 112 pending_archivers_.push_back(archiver.Pass()); |
| 113 } | 113 } |
| 114 | 114 |
| 115 void OfflinePageModel::MarkPageAccessed(int64 bookmark_id) { |
| 116 DCHECK(is_loaded_); |
| 117 auto iter = offline_pages_.find(bookmark_id); |
| 118 if (iter == offline_pages_.end()) |
| 119 return; |
| 120 |
| 121 iter->second.last_access_time = base::Time::Now(); |
| 122 iter->second.access_count++; |
| 123 store_->AddOrUpdateOfflinePage( |
| 124 iter->second, |
| 125 base::Bind(&OfflinePageModel::OnUpdateOfflinePageDone, |
| 126 weak_ptr_factory_.GetWeakPtr())); |
| 127 } |
| 128 |
| 115 void OfflinePageModel::DeletePageByBookmarkId( | 129 void OfflinePageModel::DeletePageByBookmarkId( |
| 116 int64 bookmark_id, | 130 int64 bookmark_id, |
| 117 const DeletePageCallback& callback) { | 131 const DeletePageCallback& callback) { |
| 118 DCHECK(is_loaded_); | 132 DCHECK(is_loaded_); |
| 119 std::vector<int64> bookmark_ids_to_delete; | 133 std::vector<int64> bookmark_ids_to_delete; |
| 120 bookmark_ids_to_delete.push_back(bookmark_id); | 134 bookmark_ids_to_delete.push_back(bookmark_id); |
| 121 DeletePagesByBookmarkId(bookmark_ids_to_delete, callback); | 135 DeletePagesByBookmarkId(bookmark_ids_to_delete, callback); |
| 122 } | 136 } |
| 123 | 137 |
| 124 void OfflinePageModel::DeletePagesByBookmarkId( | 138 void OfflinePageModel::DeletePagesByBookmarkId( |
| (...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 209 | 223 |
| 210 if (archiver_result != ArchiverResult::SUCCESSFULLY_CREATED) { | 224 if (archiver_result != ArchiverResult::SUCCESSFULLY_CREATED) { |
| 211 SavePageResult result = ToSavePageResult(archiver_result); | 225 SavePageResult result = ToSavePageResult(archiver_result); |
| 212 InformSavePageDone(callback, result); | 226 InformSavePageDone(callback, result); |
| 213 DeletePendingArchiver(archiver); | 227 DeletePendingArchiver(archiver); |
| 214 return; | 228 return; |
| 215 } | 229 } |
| 216 | 230 |
| 217 OfflinePageItem offline_page_item(url, bookmark_id, file_path, file_size, | 231 OfflinePageItem offline_page_item(url, bookmark_id, file_path, file_size, |
| 218 base::Time::Now()); | 232 base::Time::Now()); |
| 219 store_->AddOfflinePage( | 233 store_->AddOrUpdateOfflinePage( |
| 220 offline_page_item, | 234 offline_page_item, |
| 221 base::Bind(&OfflinePageModel::OnAddOfflinePageDone, | 235 base::Bind(&OfflinePageModel::OnAddOfflinePageDone, |
| 222 weak_ptr_factory_.GetWeakPtr(), archiver, callback, | 236 weak_ptr_factory_.GetWeakPtr(), archiver, callback, |
| 223 offline_page_item)); | 237 offline_page_item)); |
| 224 } | 238 } |
| 225 | 239 |
| 226 void OfflinePageModel::OnAddOfflinePageDone(OfflinePageArchiver* archiver, | 240 void OfflinePageModel::OnAddOfflinePageDone(OfflinePageArchiver* archiver, |
| 227 const SavePageCallback& callback, | 241 const SavePageCallback& callback, |
| 228 const OfflinePageItem& offline_page, | 242 const OfflinePageItem& offline_page, |
| 229 bool success) { | 243 bool success) { |
| 230 SavePageResult result; | 244 SavePageResult result; |
| 231 if (success) { | 245 if (success) { |
| 232 offline_pages_[offline_page.bookmark_id] = offline_page; | 246 offline_pages_[offline_page.bookmark_id] = offline_page; |
| 233 result = SavePageResult::SUCCESS; | 247 result = SavePageResult::SUCCESS; |
| 234 UMA_HISTOGRAM_MEMORY_KB( | 248 UMA_HISTOGRAM_MEMORY_KB( |
| 235 "OfflinePages.PageSize", offline_page.file_size / 1024); | 249 "OfflinePages.PageSize", offline_page.file_size / 1024); |
| 236 } else { | 250 } else { |
| 237 result = SavePageResult::STORE_FAILURE; | 251 result = SavePageResult::STORE_FAILURE; |
| 238 } | 252 } |
| 239 InformSavePageDone(callback, result); | 253 InformSavePageDone(callback, result); |
| 240 DeletePendingArchiver(archiver); | 254 DeletePendingArchiver(archiver); |
| 241 } | 255 } |
| 242 | 256 |
| 257 void OfflinePageModel::OnUpdateOfflinePageDone(bool success) { |
| 258 } |
| 259 |
| 243 void OfflinePageModel::BookmarkModelChanged() { | 260 void OfflinePageModel::BookmarkModelChanged() { |
| 244 } | 261 } |
| 245 | 262 |
| 246 void OfflinePageModel::BookmarkNodeRemoved( | 263 void OfflinePageModel::BookmarkNodeRemoved( |
| 247 bookmarks::BookmarkModel* model, | 264 bookmarks::BookmarkModel* model, |
| 248 const bookmarks::BookmarkNode* parent, | 265 const bookmarks::BookmarkNode* parent, |
| 249 int old_index, | 266 int old_index, |
| 250 const bookmarks::BookmarkNode* node, | 267 const bookmarks::BookmarkNode* node, |
| 251 const std::set<GURL>& removed_urls) { | 268 const std::set<GURL>& removed_urls) { |
| 252 if (!is_loaded_) { | 269 if (!is_loaded_) { |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 338 void OfflinePageModel::InformDeletePageDone(const DeletePageCallback& callback, | 355 void OfflinePageModel::InformDeletePageDone(const DeletePageCallback& callback, |
| 339 DeletePageResult result) { | 356 DeletePageResult result) { |
| 340 UMA_HISTOGRAM_ENUMERATION( | 357 UMA_HISTOGRAM_ENUMERATION( |
| 341 "OfflinePages.DeletePageResult", | 358 "OfflinePages.DeletePageResult", |
| 342 static_cast<int>(result), | 359 static_cast<int>(result), |
| 343 static_cast<int>(DeletePageResult::RESULT_COUNT)); | 360 static_cast<int>(DeletePageResult::RESULT_COUNT)); |
| 344 callback.Run(result); | 361 callback.Run(result); |
| 345 } | 362 } |
| 346 | 363 |
| 347 } // namespace offline_pages | 364 } // namespace offline_pages |
| OLD | NEW |