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

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: Created 7 years, 8 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 614 matching lines...) Expand 10 before | Expand all | Expand 10 after
625 TimeDelta delay; 625 TimeDelta delay;
626 if (work_queue_.empty()) { 626 if (work_queue_.empty()) {
627 // If work queue is empty, reset the work queue to contain all tasks and 627 // If work queue is empty, reset the work queue to contain all tasks and
628 // schedule next iteration after a longer delay. 628 // schedule next iteration after a longer delay.
629 InitWorkQueue(); 629 InitWorkQueue();
630 delay = TimeDelta::FromMinutes(kExpirationEmptyDelayMin); 630 delay = TimeDelta::FromMinutes(kExpirationEmptyDelayMin);
631 } else { 631 } else {
632 delay = TimeDelta::FromSeconds(kExpirationDelaySec); 632 delay = TimeDelta::FromSeconds(kExpirationDelaySec);
633 } 633 }
634 634
635 MessageLoop::current()->PostDelayedTask( 635 base::MessageLoop::current()->PostDelayedTask(
636 FROM_HERE, 636 FROM_HERE,
637 base::Bind(&ExpireHistoryBackend::DoArchiveIteration, 637 base::Bind(&ExpireHistoryBackend::DoArchiveIteration,
638 weak_factory_.GetWeakPtr()), 638 weak_factory_.GetWeakPtr()),
639 delay); 639 delay);
640 } 640 }
641 641
642 void ExpireHistoryBackend::DoArchiveIteration() { 642 void ExpireHistoryBackend::DoArchiveIteration() {
643 DCHECK(!work_queue_.empty()) << "queue has to be non-empty"; 643 DCHECK(!work_queue_.empty()) << "queue has to be non-empty";
644 644
645 const ExpiringVisitsReader* reader = work_queue_.front(); 645 const ExpiringVisitsReader* reader = work_queue_.front();
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after
721 } 721 }
722 722
723 void ExpireHistoryBackend::ScheduleExpireHistoryIndexFiles() { 723 void ExpireHistoryBackend::ScheduleExpireHistoryIndexFiles() {
724 if (!text_db_) { 724 if (!text_db_) {
725 // Can't expire old history index files because we 725 // Can't expire old history index files because we
726 // don't know where they're located. 726 // don't know where they're located.
727 return; 727 return;
728 } 728 }
729 729
730 TimeDelta delay = TimeDelta::FromMinutes(kIndexExpirationDelayMin); 730 TimeDelta delay = TimeDelta::FromMinutes(kIndexExpirationDelayMin);
731 MessageLoop::current()->PostDelayedTask( 731 base::MessageLoop::current()->PostDelayedTask(
732 FROM_HERE, 732 FROM_HERE,
733 base::Bind(&ExpireHistoryBackend::DoExpireHistoryIndexFiles, 733 base::Bind(&ExpireHistoryBackend::DoExpireHistoryIndexFiles,
734 weak_factory_.GetWeakPtr()), 734 weak_factory_.GetWeakPtr()),
735 delay); 735 delay);
736 } 736 }
737 737
738 void ExpireHistoryBackend::DoExpireHistoryIndexFiles() { 738 void ExpireHistoryBackend::DoExpireHistoryIndexFiles() {
739 if (!text_db_) { 739 if (!text_db_) {
740 // The text database may have been closed since the task was scheduled. 740 // The text database may have been closed since the task was scheduled.
741 return; 741 return;
(...skipping 24 matching lines...) Expand all
766 // We use the bookmark service to determine if a URL is bookmarked. The 766 // We use the bookmark service to determine if a URL is bookmarked. The
767 // bookmark service is loaded on a separate thread and may not be done by the 767 // bookmark service is loaded on a separate thread and may not be done by the
768 // time we get here. We therefor block until the bookmarks have finished 768 // time we get here. We therefor block until the bookmarks have finished
769 // loading. 769 // loading.
770 if (bookmark_service_) 770 if (bookmark_service_)
771 bookmark_service_->BlockTillLoaded(); 771 bookmark_service_->BlockTillLoaded();
772 return bookmark_service_; 772 return bookmark_service_;
773 } 773 }
774 774
775 } // namespace history 775 } // namespace history
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698