| OLD | NEW |
| 1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2009 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 // The history system runs on a background thread so that potentially slow | 5 // The history system runs on a background thread so that potentially slow |
| 6 // database operations don't delay the browser. This backend processing is | 6 // database operations don't delay the browser. This backend processing is |
| 7 // represented by HistoryBackend. The HistoryService's job is to dispatch to | 7 // represented by HistoryBackend. The HistoryService's job is to dispatch to |
| 8 // that thread. | 8 // that thread. |
| 9 // | 9 // |
| 10 // Main thread History thread | 10 // Main thread History thread |
| (...skipping 112 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 123 scoped_refptr<HistoryService> history_service_; | 123 scoped_refptr<HistoryService> history_service_; |
| 124 MessageLoop* message_loop_; | 124 MessageLoop* message_loop_; |
| 125 }; | 125 }; |
| 126 | 126 |
| 127 // static | 127 // static |
| 128 const history::StarID HistoryService::kBookmarkBarID = 1; | 128 const history::StarID HistoryService::kBookmarkBarID = 1; |
| 129 | 129 |
| 130 HistoryService::HistoryService() | 130 HistoryService::HistoryService() |
| 131 : thread_(new ChromeHistoryThread()), | 131 : thread_(new ChromeHistoryThread()), |
| 132 profile_(NULL), | 132 profile_(NULL), |
| 133 backend_loaded_(false) { | 133 backend_loaded_(false), |
| 134 bookmark_service_(NULL), |
| 135 no_db_(false) { |
| 134 // Is NULL when running generate_profile. | 136 // Is NULL when running generate_profile. |
| 135 if (NotificationService::current()) { | 137 if (NotificationService::current()) { |
| 136 registrar_.Add(this, NotificationType::HISTORY_URLS_DELETED, | 138 registrar_.Add(this, NotificationType::HISTORY_URLS_DELETED, |
| 137 Source<Profile>(profile_)); | 139 Source<Profile>(profile_)); |
| 138 } | 140 } |
| 139 } | 141 } |
| 140 | 142 |
| 141 HistoryService::HistoryService(Profile* profile) | 143 HistoryService::HistoryService(Profile* profile) |
| 142 : thread_(new ChromeHistoryThread()), | 144 : thread_(new ChromeHistoryThread()), |
| 143 profile_(profile), | 145 profile_(profile), |
| 144 backend_loaded_(false) { | 146 backend_loaded_(false), |
| 147 bookmark_service_(NULL), |
| 148 no_db_(false) { |
| 145 registrar_.Add(this, NotificationType::HISTORY_URLS_DELETED, | 149 registrar_.Add(this, NotificationType::HISTORY_URLS_DELETED, |
| 146 Source<Profile>(profile_)); | 150 Source<Profile>(profile_)); |
| 147 } | 151 } |
| 148 | 152 |
| 149 HistoryService::~HistoryService() { | 153 HistoryService::~HistoryService() { |
| 150 // Shutdown the backend. This does nothing if Cleanup was already invoked. | 154 // Shutdown the backend. This does nothing if Cleanup was already invoked. |
| 151 Cleanup(); | 155 Cleanup(); |
| 152 } | 156 } |
| 153 | 157 |
| 154 bool HistoryService::Init(const FilePath& history_dir, | |
| 155 BookmarkService* bookmark_service) { | |
| 156 if (!thread_->Start()) { | |
| 157 Cleanup(); | |
| 158 return false; | |
| 159 } | |
| 160 | |
| 161 history_dir_ = history_dir; | |
| 162 bookmark_service_ = bookmark_service; | |
| 163 | |
| 164 // Create the history backend. | |
| 165 LoadBackendIfNecessary(); | |
| 166 return true; | |
| 167 } | |
| 168 | |
| 169 bool HistoryService::BackendLoaded() { | 158 bool HistoryService::BackendLoaded() { |
| 170 // NOTE: We start the backend loading even though it completes asynchronously | 159 // NOTE: We start the backend loading even though it completes asynchronously |
| 171 // and thus won't affect the return value of this function. This is because | 160 // and thus won't affect the return value of this function. This is because |
| 172 // callers of this assume that if the backend isn't yet loaded it will be | 161 // callers of this assume that if the backend isn't yet loaded it will be |
| 173 // soon, so they will either listen for notifications or just retry this call | 162 // soon, so they will either listen for notifications or just retry this call |
| 174 // later. If we've purged the backend, we haven't necessarily restarted it | 163 // later. If we've purged the backend, we haven't necessarily restarted it |
| 175 // loading by now, so we need to trigger the load in order to maintain that | 164 // loading by now, so we need to trigger the load in order to maintain that |
| 176 // expectation. | 165 // expectation. |
| 177 LoadBackendIfNecessary(); | 166 LoadBackendIfNecessary(); |
| 178 return backend_loaded_; | 167 return backend_loaded_; |
| (...skipping 434 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 613 Details<history::URLsDeletedDetails> deleted_details(details); | 602 Details<history::URLsDeletedDetails> deleted_details(details); |
| 614 VisitedLinkMaster* visited_links = profile_->GetVisitedLinkMaster(); | 603 VisitedLinkMaster* visited_links = profile_->GetVisitedLinkMaster(); |
| 615 if (!visited_links) | 604 if (!visited_links) |
| 616 return; // Nobody to update. | 605 return; // Nobody to update. |
| 617 if (deleted_details->all_history) | 606 if (deleted_details->all_history) |
| 618 visited_links->DeleteAllURLs(); | 607 visited_links->DeleteAllURLs(); |
| 619 else // Delete individual ones. | 608 else // Delete individual ones. |
| 620 visited_links->DeleteURLs(deleted_details->urls); | 609 visited_links->DeleteURLs(deleted_details->urls); |
| 621 } | 610 } |
| 622 | 611 |
| 612 bool HistoryService::Init(const FilePath& history_dir, |
| 613 BookmarkService* bookmark_service, |
| 614 bool no_db) { |
| 615 if (!thread_->Start()) { |
| 616 Cleanup(); |
| 617 return false; |
| 618 } |
| 619 |
| 620 history_dir_ = history_dir; |
| 621 bookmark_service_ = bookmark_service; |
| 622 no_db_ = no_db; |
| 623 |
| 624 // Create the history backend. |
| 625 LoadBackendIfNecessary(); |
| 626 return true; |
| 627 } |
| 628 |
| 623 void HistoryService::ScheduleAutocomplete(HistoryURLProvider* provider, | 629 void HistoryService::ScheduleAutocomplete(HistoryURLProvider* provider, |
| 624 HistoryURLProviderParams* params) { | 630 HistoryURLProviderParams* params) { |
| 625 ScheduleAndForget(PRIORITY_UI, &HistoryBackend::ScheduleAutocomplete, | 631 ScheduleAndForget(PRIORITY_UI, &HistoryBackend::ScheduleAutocomplete, |
| 626 scoped_refptr<HistoryURLProvider>(provider), params); | 632 scoped_refptr<HistoryURLProvider>(provider), params); |
| 627 } | 633 } |
| 628 | 634 |
| 629 void HistoryService::ScheduleTask(SchedulePriority priority, | 635 void HistoryService::ScheduleTask(SchedulePriority priority, |
| 630 Task* task) { | 636 Task* task) { |
| 631 // FIXME(brettw) do prioritization. | 637 // FIXME(brettw) do prioritization. |
| 632 thread_->message_loop()->PostTask(FROM_HERE, task); | 638 thread_->message_loop()->PostTask(FROM_HERE, task); |
| (...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 715 void HistoryService::LoadBackendIfNecessary() { | 721 void HistoryService::LoadBackendIfNecessary() { |
| 716 if (!thread_ || history_backend_) | 722 if (!thread_ || history_backend_) |
| 717 return; // Failed to init, or already started loading. | 723 return; // Failed to init, or already started loading. |
| 718 | 724 |
| 719 scoped_refptr<HistoryBackend> backend( | 725 scoped_refptr<HistoryBackend> backend( |
| 720 new HistoryBackend(history_dir_, | 726 new HistoryBackend(history_dir_, |
| 721 new BackendDelegate(this), | 727 new BackendDelegate(this), |
| 722 bookmark_service_)); | 728 bookmark_service_)); |
| 723 history_backend_.swap(backend); | 729 history_backend_.swap(backend); |
| 724 | 730 |
| 725 ScheduleAndForget(PRIORITY_UI, &HistoryBackend::Init); | 731 ScheduleAndForget(PRIORITY_UI, &HistoryBackend::Init, no_db_); |
| 726 } | 732 } |
| 727 | 733 |
| 728 void HistoryService::OnDBLoaded() { | 734 void HistoryService::OnDBLoaded() { |
| 729 LOG(INFO) << "History backend finished loading"; | 735 LOG(INFO) << "History backend finished loading"; |
| 730 backend_loaded_ = true; | 736 backend_loaded_ = true; |
| 731 NotificationService::current()->Notify(NotificationType::HISTORY_LOADED, | 737 NotificationService::current()->Notify(NotificationType::HISTORY_LOADED, |
| 732 Source<Profile>(profile_), | 738 Source<Profile>(profile_), |
| 733 Details<HistoryService>(this)); | 739 Details<HistoryService>(this)); |
| 734 } | 740 } |
| OLD | NEW |