Add PrerenderLocalPredictor, which will eventually perform

chrome/browser/history/history.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 // The history system runs on a background thread so that potentially slow
 // database operations don't delay the browser. This backend processing is
 // represented by HistoryBackend. The HistoryService's job is to dispatch to
 // that thread.
 //
 // Main thread                       History thread
@@ skipping 22 matching lines @@
 #include "base/threading/thread.h"
 #include "chrome/browser/autocomplete/history_url_provider.h"
 #include "chrome/browser/browser_process.h"
 #include "chrome/browser/history/history_backend.h"
 #include "chrome/browser/history/history_notifications.h"
 #include "chrome/browser/history/history_types.h"
 #include "chrome/browser/history/in_memory_database.h"
 #include "chrome/browser/history/in_memory_history_backend.h"
 #include "chrome/browser/history/in_memory_url_index.h"
 #include "chrome/browser/history/top_sites.h"
+#include "chrome/browser/history/visit_database.h"
 #include "chrome/browser/history/visit_filter.h"
 #include "chrome/browser/prefs/pref_service.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/browser/ui/profile_error_dialog.h"
 #include "chrome/browser/visitedlink/visitedlink_master.h"
 #include "chrome/common/chrome_constants.h"
 #include "chrome/common/chrome_notification_types.h"
 #include "chrome/common/chrome_switches.h"
 #include "chrome/common/pref_names.h"
 #include "chrome/common/thumbnail_score.h"
@@ skipping 67 matching lines @@
                    backend_id));
   }
 
   virtual void StartTopSitesMigration(int backend_id) OVERRIDE {
     message_loop_->PostTask(
         FROM_HERE,
         base::Bind(&HistoryService::StartTopSitesMigration,
                    history_service_.get(), backend_id));
   }
 
+  virtual void NotifyVisitDBObserversOnAddVisit(
+      const history::BriefVisitInfo& info) OVERRIDE {
+    // Since the notification method can be run on any thread, we can
+    // call it right away.
+    history_service_->NotifyVisitDBObserversOnAddVisit(info);
+  }
+
  private:
   scoped_refptr<HistoryService> history_service_;
   MessageLoop* message_loop_;
   Profile* profile_;
 };
 
 // The history thread is intentionally not a BrowserThread because the
 // sync integration unit tests depend on being able to create more than one
 // history thread.
 HistoryService::HistoryService()
     : thread_(new base::Thread(kHistoryThreadName)),
       profile_(NULL),
       backend_loaded_(false),
       current_backend_id_(-1),
       bookmark_service_(NULL),
       no_db_(false),
-      needs_top_sites_migration_(false) {
+      needs_top_sites_migration_(false),
+      visit_database_observers_(
+          new ObserverListThreadSafe<history::VisitDatabaseObserver>()) {
 }
 
 HistoryService::HistoryService(Profile* profile)
     : thread_(new base::Thread(kHistoryThreadName)),
       profile_(profile),
       backend_loaded_(false),
       current_backend_id_(-1),
       bookmark_service_(NULL),
       no_db_(false),
-      needs_top_sites_migration_(false) {
+      needs_top_sites_migration_(false),
+      visit_database_observers_(
+          new ObserverListThreadSafe<history::VisitDatabaseObserver>()) {
   DCHECK(profile_);
   registrar_.Add(this, chrome::NOTIFICATION_HISTORY_URLS_DELETED,
                  content::Source<Profile>(profile_));
   registrar_.Add(this, chrome::NOTIFICATION_TEMPLATE_URL_REMOVED,
                  content::Source<Profile>(profile_));
 }
 
 HistoryService::~HistoryService() {
   // Shutdown the backend. This does nothing if Cleanup was already invoked.
   Cleanup();
@@ skipping 718 matching lines @@
     history::TopSites* ts = profile_->GetTopSitesWithoutCreating();
     if (ts)
       ts->MigrateFromHistory();
   }
 }
 
 void HistoryService::OnTopSitesReady() {
   ScheduleAndForget(PRIORITY_NORMAL,
                     &HistoryBackend::MigrateThumbnailsDatabase);
 }
+
+void HistoryService::AddVisitDatabaseObserver(
+    history::VisitDatabaseObserver* observer) {
+  visit_database_observers_->AddObserver(observer);
+}
+
+void HistoryService::RemoveVisitDatabaseObserver(
+    history::VisitDatabaseObserver* observer) {
+  visit_database_observers_->RemoveObserver(observer);
+}
+
+void HistoryService::NotifyVisitDBObserversOnAddVisit(
+    const history::BriefVisitInfo& info) {
+  visit_database_observers_->Notify(
+      &history::VisitDatabaseObserver::OnAddVisit, info);
+}