| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/search_engines/search_provider_install_data.h" | 5 #include "chrome/browser/search_engines/search_provider_install_data.h" |
| 6 | 6 |
| 7 #include <algorithm> |
| 8 #include <functional> |
| 7 #include <vector> | 9 #include <vector> |
| 8 | 10 |
| 9 #include "base/basictypes.h" | 11 #include "base/basictypes.h" |
| 12 #include "base/bind.h" |
| 10 #include "base/logging.h" | 13 #include "base/logging.h" |
| 11 #include "base/memory/ref_counted.h" | 14 #include "base/memory/ref_counted.h" |
| 12 #include "base/task.h" | |
| 13 #include "chrome/browser/search_engines/search_host_to_urls_map.h" | 15 #include "chrome/browser/search_engines/search_host_to_urls_map.h" |
| 14 #include "chrome/browser/search_engines/search_terms_data.h" | 16 #include "chrome/browser/search_engines/search_terms_data.h" |
| 15 #include "chrome/browser/search_engines/template_url.h" | 17 #include "chrome/browser/search_engines/template_url.h" |
| 16 #include "chrome/browser/search_engines/template_url_service.h" | 18 #include "chrome/browser/search_engines/template_url_service.h" |
| 17 #include "chrome/browser/search_engines/util.h" | 19 #include "chrome/browser/search_engines/util.h" |
| 18 #include "chrome/browser/webdata/web_data_service.h" | 20 #include "chrome/browser/webdata/web_data_service.h" |
| 19 #include "chrome/common/chrome_notification_types.h" | 21 #include "chrome/common/chrome_notification_types.h" |
| 20 #include "content/public/browser/browser_thread.h" | 22 #include "content/public/browser/browser_thread.h" |
| 21 #include "content/public/browser/notification_observer.h" | 23 #include "content/public/browser/notification_observer.h" |
| 22 #include "content/public/browser/notification_registrar.h" | 24 #include "content/public/browser/notification_registrar.h" |
| (...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 131 registrar_.Add(this, chrome::NOTIFICATION_GOOGLE_URL_UPDATED, | 133 registrar_.Add(this, chrome::NOTIFICATION_GOOGLE_URL_UPDATED, |
| 132 content::NotificationService::AllSources()); | 134 content::NotificationService::AllSources()); |
| 133 registrar_.Add(this, ui_death_notification, ui_death_source); | 135 registrar_.Add(this, ui_death_notification, ui_death_source); |
| 134 } | 136 } |
| 135 | 137 |
| 136 void GoogleURLObserver::Observe(int type, | 138 void GoogleURLObserver::Observe(int type, |
| 137 const content::NotificationSource& source, | 139 const content::NotificationSource& source, |
| 138 const content::NotificationDetails& details) { | 140 const content::NotificationDetails& details) { |
| 139 if (type == chrome::NOTIFICATION_GOOGLE_URL_UPDATED) { | 141 if (type == chrome::NOTIFICATION_GOOGLE_URL_UPDATED) { |
| 140 BrowserThread::PostTask(BrowserThread::IO, FROM_HERE, | 142 BrowserThread::PostTask(BrowserThread::IO, FROM_HERE, |
| 141 NewRunnableMethod(change_notifier_.get(), | 143 base::Bind(&GoogleURLChangeNotifier::OnChange, |
| 142 &GoogleURLChangeNotifier::OnChange, | 144 change_notifier_.get(), |
| 143 UIThreadSearchTermsData().GoogleBaseURLValue())); | 145 UIThreadSearchTermsData().GoogleBaseURLValue())); |
| 144 } else { | 146 } else { |
| 145 // This must be the death notification. | 147 // This must be the death notification. |
| 146 delete this; | 148 delete this; |
| 147 } | 149 } |
| 148 } | 150 } |
| 149 | 151 |
| 150 // Indicates if the two inputs have the same security origin. | 152 // Indicates if the two inputs have the same security origin. |
| 151 // |requested_origin| should only be a security origin (no path, etc.). | 153 // |requested_origin| should only be a security origin (no path, etc.). |
| 152 // It is ok if |template_url| is NULL. | 154 // It is ok if |template_url| is NULL. |
| 153 static bool IsSameOrigin(const GURL& requested_origin, | 155 static bool IsSameOrigin(const GURL& requested_origin, |
| (...skipping 24 matching lines...) Expand all Loading... |
| 178 | 180 |
| 179 SearchProviderInstallData::~SearchProviderInstallData() { | 181 SearchProviderInstallData::~SearchProviderInstallData() { |
| 180 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 182 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
| 181 | 183 |
| 182 if (load_handle_) { | 184 if (load_handle_) { |
| 183 DCHECK(web_service_.get()); | 185 DCHECK(web_service_.get()); |
| 184 web_service_->CancelRequest(load_handle_); | 186 web_service_->CancelRequest(load_handle_); |
| 185 } | 187 } |
| 186 } | 188 } |
| 187 | 189 |
| 188 void SearchProviderInstallData::CallWhenLoaded(Task* task) { | 190 void SearchProviderInstallData::CallWhenLoaded(const base::Closure& closure) { |
| 189 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 191 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
| 190 | 192 |
| 191 if (provider_map_.get()) { | 193 if (provider_map_.get()) { |
| 192 task->Run(); | 194 closure.Run(); |
| 193 delete task; | |
| 194 return; | 195 return; |
| 195 } | 196 } |
| 196 | 197 |
| 197 task_queue_.Push(task); | 198 closure_queue_.push_back(closure); |
| 198 if (load_handle_) | 199 if (load_handle_) |
| 199 return; | 200 return; |
| 200 | 201 |
| 201 if (web_service_.get()) | 202 if (web_service_.get()) |
| 202 load_handle_ = web_service_->GetKeywords(this); | 203 load_handle_ = web_service_->GetKeywords(this); |
| 203 else | 204 else |
| 204 OnLoadFailed(); | 205 OnLoadFailed(); |
| 205 } | 206 } |
| 206 | 207 |
| 207 SearchProviderInstallData::State SearchProviderInstallData::GetInstallState( | 208 SearchProviderInstallData::State SearchProviderInstallData::GetInstallState( |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 293 provider_map_.reset(new SearchHostToURLsMap()); | 294 provider_map_.reset(new SearchHostToURLsMap()); |
| 294 IOThreadSearchTermsData search_terms_data(google_base_url_); | 295 IOThreadSearchTermsData search_terms_data(google_base_url_); |
| 295 provider_map_->Init(template_urls_.get(), search_terms_data); | 296 provider_map_->Init(template_urls_.get(), search_terms_data); |
| 296 SetDefault(NULL); | 297 SetDefault(NULL); |
| 297 NotifyLoaded(); | 298 NotifyLoaded(); |
| 298 } | 299 } |
| 299 | 300 |
| 300 void SearchProviderInstallData::NotifyLoaded() { | 301 void SearchProviderInstallData::NotifyLoaded() { |
| 301 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 302 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
| 302 | 303 |
| 303 task_queue_.Run(); | 304 std::vector<base::Closure> closure_queue; |
| 305 closure_queue.swap(closure_queue_); |
| 306 |
| 307 std::for_each(closure_queue.begin(), |
| 308 closure_queue.end(), |
| 309 std::mem_fun_ref(&base::Closure::Run)); |
| 304 | 310 |
| 305 // Since we expect this request to be rare, clear out the information. This | 311 // Since we expect this request to be rare, clear out the information. This |
| 306 // also keeps the responses current as the search providers change. | 312 // also keeps the responses current as the search providers change. |
| 307 provider_map_.reset(); | 313 provider_map_.reset(); |
| 308 SetDefault(NULL); | 314 SetDefault(NULL); |
| 309 } | 315 } |
| OLD | NEW |