Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(487)

Side by Side Diff: chrome/browser/history/expire_history_backend.cc

Issue 14113053: chrome: Use base::MessageLoop. (Part 3) (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebase again Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 "chrome/browser/history/expire_history_backend.h" 5 #include "chrome/browser/history/expire_history_backend.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 #include <functional> 8 #include <functional>
9 #include <limits> 9 #include <limits>
10 10
(...skipping 617 matching lines...) Expand 10 before | Expand all | Expand 10 after
628 TimeDelta delay; 628 TimeDelta delay;
629 if (work_queue_.empty()) { 629 if (work_queue_.empty()) {
630 // If work queue is empty, reset the work queue to contain all tasks and 630 // If work queue is empty, reset the work queue to contain all tasks and
631 // schedule next iteration after a longer delay. 631 // schedule next iteration after a longer delay.
632 InitWorkQueue(); 632 InitWorkQueue();
633 delay = TimeDelta::FromMinutes(kExpirationEmptyDelayMin); 633 delay = TimeDelta::FromMinutes(kExpirationEmptyDelayMin);
634 } else { 634 } else {
635 delay = TimeDelta::FromSeconds(kExpirationDelaySec); 635 delay = TimeDelta::FromSeconds(kExpirationDelaySec);
636 } 636 }
637 637
638 MessageLoop::current()->PostDelayedTask( 638 base::MessageLoop::current()->PostDelayedTask(
639 FROM_HERE, 639 FROM_HERE,
640 base::Bind(&ExpireHistoryBackend::DoArchiveIteration, 640 base::Bind(&ExpireHistoryBackend::DoArchiveIteration,
641 weak_factory_.GetWeakPtr()), 641 weak_factory_.GetWeakPtr()),
642 delay); 642 delay);
643 } 643 }
644 644
645 void ExpireHistoryBackend::DoArchiveIteration() { 645 void ExpireHistoryBackend::DoArchiveIteration() {
646 DCHECK(!work_queue_.empty()) << "queue has to be non-empty"; 646 DCHECK(!work_queue_.empty()) << "queue has to be non-empty";
647 647
648 const ExpiringVisitsReader* reader = work_queue_.front(); 648 const ExpiringVisitsReader* reader = work_queue_.front();
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after
724 } 724 }
725 725
726 void ExpireHistoryBackend::ScheduleExpireHistoryIndexFiles() { 726 void ExpireHistoryBackend::ScheduleExpireHistoryIndexFiles() {
727 if (!text_db_) { 727 if (!text_db_) {
728 // Can't expire old history index files because we 728 // Can't expire old history index files because we
729 // don't know where they're located. 729 // don't know where they're located.
730 return; 730 return;
731 } 731 }
732 732
733 TimeDelta delay = TimeDelta::FromMinutes(kIndexExpirationDelayMin); 733 TimeDelta delay = TimeDelta::FromMinutes(kIndexExpirationDelayMin);
734 MessageLoop::current()->PostDelayedTask( 734 base::MessageLoop::current()->PostDelayedTask(
735 FROM_HERE, 735 FROM_HERE,
736 base::Bind(&ExpireHistoryBackend::DoExpireHistoryIndexFiles, 736 base::Bind(&ExpireHistoryBackend::DoExpireHistoryIndexFiles,
737 weak_factory_.GetWeakPtr()), 737 weak_factory_.GetWeakPtr()),
738 delay); 738 delay);
739 } 739 }
740 740
741 void ExpireHistoryBackend::DoExpireHistoryIndexFiles() { 741 void ExpireHistoryBackend::DoExpireHistoryIndexFiles() {
742 if (!text_db_) { 742 if (!text_db_) {
743 // The text database may have been closed since the task was scheduled. 743 // The text database may have been closed since the task was scheduled.
744 return; 744 return;
(...skipping 24 matching lines...) Expand all
769 // We use the bookmark service to determine if a URL is bookmarked. The 769 // We use the bookmark service to determine if a URL is bookmarked. The
770 // bookmark service is loaded on a separate thread and may not be done by the 770 // bookmark service is loaded on a separate thread and may not be done by the
771 // time we get here. We therefor block until the bookmarks have finished 771 // time we get here. We therefor block until the bookmarks have finished
772 // loading. 772 // loading.
773 if (bookmark_service_) 773 if (bookmark_service_)
774 bookmark_service_->BlockTillLoaded(); 774 bookmark_service_->BlockTillLoaded();
775 return bookmark_service_; 775 return bookmark_service_;
776 } 776 }
777 777
778 } // namespace history 778 } // namespace history
OLDNEW
« no previous file with comments | « chrome/browser/history/android/sqlite_cursor_unittest.cc ('k') | chrome/browser/history/expire_history_backend_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698