| OLD | NEW |
| 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 #ifndef CHROME_BROWSER_AUTOCOMPLETE_NETWORK_ACTION_PREDICTOR_H_ | 5 #ifndef CHROME_BROWSER_PREDICTORS_AUTOCOMPLETE_ACTION_PREDICTOR_H_ |
| 6 #define CHROME_BROWSER_AUTOCOMPLETE_NETWORK_ACTION_PREDICTOR_H_ | 6 #define CHROME_BROWSER_PREDICTORS_AUTOCOMPLETE_ACTION_PREDICTOR_H_ |
| 7 #pragma once | 7 #pragma once |
| 8 | 8 |
| 9 #include <map> | 9 #include <map> |
| 10 | 10 |
| 11 #include "base/gtest_prod_util.h" | 11 #include "base/gtest_prod_util.h" |
| 12 #include "base/memory/scoped_ptr.h" | 12 #include "base/memory/scoped_ptr.h" |
| 13 #include "base/memory/weak_ptr.h" | 13 #include "base/memory/weak_ptr.h" |
| 14 #include "base/string16.h" | 14 #include "base/string16.h" |
| 15 #include "chrome/browser/autocomplete/network_action_predictor_database.h" | 15 #include "chrome/browser/predictors/predictor_database.h" |
| 16 #include "chrome/browser/profiles/profile_keyed_service.h" | 16 #include "chrome/browser/profiles/profile_keyed_service.h" |
| 17 #include "content/public/browser/notification_observer.h" | 17 #include "content/public/browser/notification_observer.h" |
| 18 #include "content/public/browser/notification_registrar.h" | 18 #include "content/public/browser/notification_registrar.h" |
| 19 #include "googleurl/src/gurl.h" | 19 #include "googleurl/src/gurl.h" |
| 20 | 20 |
| 21 struct AutocompleteLog; | 21 struct AutocompleteLog; |
| 22 struct AutocompleteMatch; | 22 struct AutocompleteMatch; |
| 23 class AutocompleteResult; | 23 class AutocompleteResult; |
| 24 class HistoryService; | 24 class HistoryService; |
| 25 class PredictorsDOMHandler; |
| 25 class Profile; | 26 class Profile; |
| 26 | 27 |
| 27 namespace history { | 28 namespace history { |
| 28 class URLDatabase; | 29 class URLDatabase; |
| 29 } | 30 } |
| 30 | 31 |
| 32 namespace predictors { |
| 33 |
| 31 // This class is responsible for determining the correct predictive network | 34 // This class is responsible for determining the correct predictive network |
| 32 // action to take given for a given AutocompleteMatch and entered text. it uses | 35 // action to take given for a given AutocompleteMatch and entered text. it uses |
| 33 // a NetworkActionPredictorDatabase accessed asynchronously on the DB thread to | 36 // a AutocompleteActionPredictorTable accessed asynchronously on the DB thread |
| 34 // permanently store the data used to make predictions, and keeps local caches | 37 // to permanently store the data used to make predictions, and keeps local |
| 35 // of that data to be able to make predictions synchronously on the UI thread | 38 // caches of that data to be able to make predictions synchronously on the UI |
| 36 // where it lives. It can be accessed as a weak pointer so that it can safely | 39 // thread where it lives. It can be accessed as a weak pointer so that it can |
| 37 // use PostTaskAndReply without fear of crashes if it is destroyed before the | 40 // safely use PostTaskAndReply without fear of crashes if it is destroyed before |
| 38 // reply triggers. This is necessary during initialization. | 41 // the reply triggers. This is necessary during initialization. |
| 39 class NetworkActionPredictor | 42 class AutocompleteActionPredictor |
| 40 : public ProfileKeyedService, | 43 : public ProfileKeyedService, |
| 41 public content::NotificationObserver, | 44 public content::NotificationObserver, |
| 42 public base::SupportsWeakPtr<NetworkActionPredictor> { | 45 public base::SupportsWeakPtr<AutocompleteActionPredictor> { |
| 43 public: | 46 public: |
| 44 enum Action { | 47 enum Action { |
| 45 ACTION_PRERENDER = 0, | 48 ACTION_PRERENDER = 0, |
| 46 ACTION_PRECONNECT, | 49 ACTION_PRECONNECT, |
| 47 ACTION_NONE, | 50 ACTION_NONE, |
| 48 LAST_PREDICT_ACTION = ACTION_NONE | 51 LAST_PREDICT_ACTION = ACTION_NONE |
| 49 }; | 52 }; |
| 50 | 53 |
| 51 explicit NetworkActionPredictor(Profile* profile); | 54 explicit AutocompleteActionPredictor(Profile* profile); |
| 52 virtual ~NetworkActionPredictor(); | 55 virtual ~AutocompleteActionPredictor(); |
| 53 | 56 |
| 54 static void set_hit_weight(double weight) { hit_weight_ = weight; } | 57 static void set_hit_weight(double weight) { hit_weight_ = weight; } |
| 55 static double get_hit_weight() { return hit_weight_; } | 58 static double get_hit_weight() { return hit_weight_; } |
| 56 | 59 |
| 57 // Registers an AutocompleteResult for a given |user_text|. This will be used | 60 // Registers an AutocompleteResult for a given |user_text|. This will be used |
| 58 // when the user navigates from the Omnibox to determine early opportunities | 61 // when the user navigates from the Omnibox to determine early opportunities |
| 59 // to predict their actions. | 62 // to predict their actions. |
| 60 void RegisterTransitionalMatches(const string16& user_text, | 63 void RegisterTransitionalMatches(const string16& user_text, |
| 61 const AutocompleteResult& result); | 64 const AutocompleteResult& result); |
| 62 | 65 |
| 63 // Clears any transitional matches that have been registered. Called when, for | 66 // Clears any transitional matches that have been registered. Called when, for |
| 64 // example, the AutocompleteEditModel is reverted. | 67 // example, the AutocompleteEditModel is reverted. |
| 65 void ClearTransitionalMatches(); | 68 void ClearTransitionalMatches(); |
| 66 | 69 |
| 67 // Return the recommended action given |user_text|, the text the user has | 70 // Return the recommended action given |user_text|, the text the user has |
| 68 // entered in the Omnibox, and |match|, the suggestion from Autocomplete. | 71 // entered in the Omnibox, and |match|, the suggestion from Autocomplete. |
| 69 // This method uses information from the ShortcutsBackend including how much | 72 // This method uses information from the ShortcutsBackend including how much |
| 70 // of the matching entry the user typed, and how long it's been since the user | 73 // of the matching entry the user typed, and how long it's been since the user |
| 71 // visited the matching URL, to calculate a score between 0 and 1. This score | 74 // visited the matching URL, to calculate a score between 0 and 1. This score |
| 72 // is then mapped to an Action. | 75 // is then mapped to an Action. |
| 73 Action RecommendAction(const string16& user_text, | 76 Action RecommendAction(const string16& user_text, |
| 74 const AutocompleteMatch& match) const; | 77 const AutocompleteMatch& match) const; |
| 75 | 78 |
| 76 // Return true if the suggestion type warrants a TCP/IP preconnection. | 79 // Return true if the suggestion type warrants a TCP/IP preconnection. |
| 77 // i.e., it is now quite likely that the user will select the related domain. | 80 // i.e., it is now quite likely that the user will select the related domain. |
| 78 static bool IsPreconnectable(const AutocompleteMatch& match); | 81 static bool IsPreconnectable(const AutocompleteMatch& match); |
| 79 | 82 |
| 80 private: | 83 private: |
| 81 friend class NetworkActionPredictorTest; | 84 friend class AutocompleteActionPredictorTest; |
| 82 friend class NetworkActionPredictorDOMHandler; | 85 friend class ::PredictorsDOMHandler; |
| 83 | 86 |
| 84 struct TransitionalMatch { | 87 struct TransitionalMatch { |
| 85 TransitionalMatch(); | 88 TransitionalMatch(); |
| 86 ~TransitionalMatch(); | 89 ~TransitionalMatch(); |
| 87 | 90 |
| 88 string16 user_text; | 91 string16 user_text; |
| 89 std::vector<GURL> urls; | 92 std::vector<GURL> urls; |
| 90 | 93 |
| 91 bool operator==(const string16& other_user_text) const { | 94 bool operator==(const string16& other_user_text) const { |
| 92 return user_text == other_user_text; | 95 return user_text == other_user_text; |
| (...skipping 13 matching lines...) Expand all Loading... |
| 106 return (user_text == rhs.user_text) && (url == rhs.url); | 109 return (user_text == rhs.user_text) && (url == rhs.url); |
| 107 } | 110 } |
| 108 }; | 111 }; |
| 109 | 112 |
| 110 struct DBCacheValue { | 113 struct DBCacheValue { |
| 111 int number_of_hits; | 114 int number_of_hits; |
| 112 int number_of_misses; | 115 int number_of_misses; |
| 113 }; | 116 }; |
| 114 | 117 |
| 115 typedef std::map<DBCacheKey, DBCacheValue> DBCacheMap; | 118 typedef std::map<DBCacheKey, DBCacheValue> DBCacheMap; |
| 116 typedef std::map<DBCacheKey, NetworkActionPredictorDatabase::Row::Id> | 119 typedef std::map<DBCacheKey, AutocompleteActionPredictorTable::Row::Id> |
| 117 DBIdCacheMap; | 120 DBIdCacheMap; |
| 118 | 121 |
| 119 static const int kMaximumDaysToKeepEntry; | 122 static const int kMaximumDaysToKeepEntry; |
| 120 | 123 |
| 121 // Multiplying factor applied to the |number_of_hits| for a database entry | 124 // Multiplying factor applied to the |number_of_hits| for a database entry |
| 122 // when calculating the confidence. It is currently set by a field trial so is | 125 // when calculating the confidence. It is currently set by a field trial so is |
| 123 // static. Once the field trial ends, this will be a constant value. | 126 // static. Once the field trial ends, this will be a constant value. |
| 124 static double hit_weight_; | 127 static double hit_weight_; |
| 125 | 128 |
| 126 // ProfileKeyedService | 129 // ProfileKeyedService |
| 127 virtual void Shutdown() OVERRIDE; | 130 virtual void Shutdown() OVERRIDE; |
| 128 | 131 |
| 129 // NotificationObserver | 132 // NotificationObserver |
| 130 virtual void Observe(int type, | 133 virtual void Observe(int type, |
| 131 const content::NotificationSource& source, | 134 const content::NotificationSource& source, |
| 132 const content::NotificationDetails& details) OVERRIDE; | 135 const content::NotificationDetails& details) OVERRIDE; |
| 133 | 136 |
| 134 // Called when NOTIFICATION_OMNIBOX_OPENED_URL is observed. | 137 // Called when NOTIFICATION_OMNIBOX_OPENED_URL is observed. |
| 135 void OnOmniboxOpenedUrl(const AutocompleteLog& log); | 138 void OnOmniboxOpenedUrl(const AutocompleteLog& log); |
| 136 | 139 |
| 137 // Deletes any old or invalid entries from the local caches. |url_db| and | 140 // Deletes any old or invalid entries from the local caches. |url_db| and |
| 138 // |id_list| must not be NULL. Every row id deleted will be added to id_list. | 141 // |id_list| must not be NULL. Every row id deleted will be added to id_list. |
| 139 void DeleteOldIdsFromCaches( | 142 void DeleteOldIdsFromCaches( |
| 140 history::URLDatabase* url_db, | 143 history::URLDatabase* url_db, |
| 141 std::vector<NetworkActionPredictorDatabase::Row::Id>* id_list); | 144 std::vector<AutocompleteActionPredictorTable::Row::Id>* id_list); |
| 142 | 145 |
| 143 // Called to delete any old or invalid entries from the database. Called after | 146 // Called to delete any old or invalid entries from the database. Called after |
| 144 // the local caches are created once the history service is available. | 147 // the local caches are created once the history service is available. |
| 145 void DeleteOldEntries(history::URLDatabase* url_db); | 148 void DeleteOldEntries(history::URLDatabase* url_db); |
| 146 | 149 |
| 147 // Called to populate the local caches. This also calls DeleteOldEntries | 150 // Called to populate the local caches. This also calls DeleteOldEntries |
| 148 // if the history service is available, or registers for the notification of | 151 // if the history service is available, or registers for the notification of |
| 149 // it becoming available. | 152 // it becoming available. |
| 150 void CreateCaches( | 153 void CreateCaches( |
| 151 std::vector<NetworkActionPredictorDatabase::Row>* row_buffer); | 154 std::vector<AutocompleteActionPredictorTable::Row>* row_buffer); |
| 152 | 155 |
| 153 // Attempts to call DeleteOldEntries if the in-memory database has been loaded | 156 // Attempts to call DeleteOldEntries if the in-memory database has been loaded |
| 154 // by |service|. Returns success as a boolean. | 157 // by |service|. Returns success as a boolean. |
| 155 bool TryDeleteOldEntries(HistoryService* service); | 158 bool TryDeleteOldEntries(HistoryService* service); |
| 156 | 159 |
| 157 // Uses local caches to calculate an exact percentage prediction that the user | 160 // Uses local caches to calculate an exact percentage prediction that the user |
| 158 // will take a particular match given what they have typed. |is_in_db| is set | 161 // will take a particular match given what they have typed. |is_in_db| is set |
| 159 // to differentiate trivial zero results resulting from a match not being | 162 // to differentiate trivial zero results resulting from a match not being |
| 160 // found from actual zero results where the calculation returns 0.0. | 163 // found from actual zero results where the calculation returns 0.0. |
| 161 double CalculateConfidence(const string16& user_text, | 164 double CalculateConfidence(const string16& user_text, |
| 162 const AutocompleteMatch& match, | 165 const AutocompleteMatch& match, |
| 163 bool* is_in_db) const; | 166 bool* is_in_db) const; |
| 164 | 167 |
| 165 // Calculates the confidence for an entry in the DBCacheMap. | 168 // Calculates the confidence for an entry in the DBCacheMap. |
| 166 double CalculateConfidenceForDbEntry(DBCacheMap::const_iterator iter) const; | 169 double CalculateConfidenceForDbEntry(DBCacheMap::const_iterator iter) const; |
| 167 | 170 |
| 168 // Adds a row to the database and caches. | 171 // Adds a row to the database and caches. |
| 169 void AddRow(const DBCacheKey& key, | 172 void AddRow(const DBCacheKey& key, |
| 170 const NetworkActionPredictorDatabase::Row& row); | 173 const AutocompleteActionPredictorTable::Row& row); |
| 171 | 174 |
| 172 // Updates a row in the database and the caches. | 175 // Updates a row in the database and the caches. |
| 173 void UpdateRow(DBCacheMap::iterator it, | 176 void UpdateRow(DBCacheMap::iterator it, |
| 174 const NetworkActionPredictorDatabase::Row& row); | 177 const AutocompleteActionPredictorTable::Row& row); |
| 175 | 178 |
| 176 // Removes all rows from the database and caches. | 179 // Removes all rows from the database and caches. |
| 177 void DeleteAllRows(); | 180 void DeleteAllRows(); |
| 178 | 181 |
| 179 // Removes rows from the database and caches that contain a URL in |urls|. | 182 // Removes rows from the database and caches that contain a URL in |urls|. |
| 180 void DeleteRowsWithURLs(const std::set<GURL>& urls); | 183 void DeleteRowsWithURLs(const std::set<GURL>& urls); |
| 181 | 184 |
| 182 // Used to batch operations on the database. | |
| 183 void BeginTransaction(); | |
| 184 void CommitTransaction(); | |
| 185 | |
| 186 Profile* profile_; | 185 Profile* profile_; |
| 187 scoped_refptr<NetworkActionPredictorDatabase> db_; | 186 scoped_refptr<AutocompleteActionPredictorTable> db_; |
| 188 content::NotificationRegistrar notification_registrar_; | 187 content::NotificationRegistrar notification_registrar_; |
| 189 | 188 |
| 190 // This is cleared after every Omnibox navigation. | 189 // This is cleared after every Omnibox navigation. |
| 191 std::vector<TransitionalMatch> transitional_matches_; | 190 std::vector<TransitionalMatch> transitional_matches_; |
| 192 | 191 |
| 193 // This allows us to predict the effect of confidence threshold changes on | 192 // This allows us to predict the effect of confidence threshold changes on |
| 194 // accuracy. | 193 // accuracy. |
| 195 mutable std::vector<std::pair<GURL, double> > tracked_urls_; | 194 mutable std::vector<std::pair<GURL, double> > tracked_urls_; |
| 196 | 195 |
| 197 DBCacheMap db_cache_; | 196 DBCacheMap db_cache_; |
| 198 DBIdCacheMap db_id_cache_; | 197 DBIdCacheMap db_id_cache_; |
| 199 | 198 |
| 200 bool initialized_; | 199 bool initialized_; |
| 201 | 200 |
| 202 DISALLOW_COPY_AND_ASSIGN(NetworkActionPredictor); | 201 DISALLOW_COPY_AND_ASSIGN(AutocompleteActionPredictor); |
| 203 }; | 202 }; |
| 204 | 203 |
| 205 #endif // CHROME_BROWSER_AUTOCOMPLETE_NETWORK_ACTION_PREDICTOR_H_ | 204 } // namespace predictors |
| 205 |
| 206 #endif // CHROME_BROWSER_PREDICTORS_AUTOCOMPLETE_ACTION_PREDICTOR_H_ |
| OLD | NEW |