| 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 #include "chrome/browser/custom_handlers/protocol_handler_registry.h" | 5 #include "chrome/browser/custom_handlers/protocol_handler_registry.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/command_line.h" | 10 #include "base/command_line.h" |
| (...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 108 | 108 |
| 109 DISALLOW_COPY_AND_ASSIGN(IOThreadDelegate); | 109 DISALLOW_COPY_AND_ASSIGN(IOThreadDelegate); |
| 110 }; | 110 }; |
| 111 | 111 |
| 112 ProtocolHandlerRegistry::IOThreadDelegate::IOThreadDelegate(bool) | 112 ProtocolHandlerRegistry::IOThreadDelegate::IOThreadDelegate(bool) |
| 113 : enabled_(true) {} | 113 : enabled_(true) {} |
| 114 ProtocolHandlerRegistry::IOThreadDelegate::~IOThreadDelegate() {} | 114 ProtocolHandlerRegistry::IOThreadDelegate::~IOThreadDelegate() {} |
| 115 | 115 |
| 116 bool ProtocolHandlerRegistry::IOThreadDelegate::IsHandledProtocol( | 116 bool ProtocolHandlerRegistry::IOThreadDelegate::IsHandledProtocol( |
| 117 const std::string& scheme) const { | 117 const std::string& scheme) const { |
| 118 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 118 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 119 return enabled_ && !LookupHandler(default_handlers_, scheme).IsEmpty(); | 119 return enabled_ && !LookupHandler(default_handlers_, scheme).IsEmpty(); |
| 120 } | 120 } |
| 121 | 121 |
| 122 void ProtocolHandlerRegistry::IOThreadDelegate::ClearDefault( | 122 void ProtocolHandlerRegistry::IOThreadDelegate::ClearDefault( |
| 123 const std::string& scheme) { | 123 const std::string& scheme) { |
| 124 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 124 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 125 default_handlers_.erase(scheme); | 125 default_handlers_.erase(scheme); |
| 126 } | 126 } |
| 127 | 127 |
| 128 void ProtocolHandlerRegistry::IOThreadDelegate::SetDefault( | 128 void ProtocolHandlerRegistry::IOThreadDelegate::SetDefault( |
| 129 const ProtocolHandler& handler) { | 129 const ProtocolHandler& handler) { |
| 130 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 130 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 131 ClearDefault(handler.protocol()); | 131 ClearDefault(handler.protocol()); |
| 132 default_handlers_.insert(std::make_pair(handler.protocol(), handler)); | 132 default_handlers_.insert(std::make_pair(handler.protocol(), handler)); |
| 133 } | 133 } |
| 134 | 134 |
| 135 // Create a new job for the supplied |URLRequest| if a default handler | 135 // Create a new job for the supplied |URLRequest| if a default handler |
| 136 // is registered and the associated handler is able to interpret | 136 // is registered and the associated handler is able to interpret |
| 137 // the url from |request|. | 137 // the url from |request|. |
| 138 net::URLRequestJob* ProtocolHandlerRegistry::IOThreadDelegate::MaybeCreateJob( | 138 net::URLRequestJob* ProtocolHandlerRegistry::IOThreadDelegate::MaybeCreateJob( |
| 139 net::URLRequest* request, net::NetworkDelegate* network_delegate) const { | 139 net::URLRequest* request, net::NetworkDelegate* network_delegate) const { |
| 140 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 140 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 141 | 141 |
| 142 ProtocolHandler handler = LookupHandler(default_handlers_, | 142 ProtocolHandler handler = LookupHandler(default_handlers_, |
| 143 request->url().scheme()); | 143 request->url().scheme()); |
| 144 if (handler.IsEmpty()) | 144 if (handler.IsEmpty()) |
| 145 return NULL; | 145 return NULL; |
| 146 | 146 |
| 147 GURL translated_url(handler.TranslateUrl(request->url())); | 147 GURL translated_url(handler.TranslateUrl(request->url())); |
| 148 if (!translated_url.is_valid()) | 148 if (!translated_url.is_valid()) |
| 149 return NULL; | 149 return NULL; |
| 150 | 150 |
| (...skipping 23 matching lines...) Expand all Loading... |
| 174 scoped_ptr<net::URLRequestJobFactory> job_factory) { | 174 scoped_ptr<net::URLRequestJobFactory> job_factory) { |
| 175 job_factory_ = job_factory.Pass(); | 175 job_factory_ = job_factory.Pass(); |
| 176 } | 176 } |
| 177 | 177 |
| 178 net::URLRequestJob* | 178 net::URLRequestJob* |
| 179 ProtocolHandlerRegistry::JobInterceptorFactory:: | 179 ProtocolHandlerRegistry::JobInterceptorFactory:: |
| 180 MaybeCreateJobWithProtocolHandler( | 180 MaybeCreateJobWithProtocolHandler( |
| 181 const std::string& scheme, | 181 const std::string& scheme, |
| 182 net::URLRequest* request, | 182 net::URLRequest* request, |
| 183 net::NetworkDelegate* network_delegate) const { | 183 net::NetworkDelegate* network_delegate) const { |
| 184 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 184 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 185 net::URLRequestJob* job = io_thread_delegate_->MaybeCreateJob( | 185 net::URLRequestJob* job = io_thread_delegate_->MaybeCreateJob( |
| 186 request, network_delegate); | 186 request, network_delegate); |
| 187 if (job) | 187 if (job) |
| 188 return job; | 188 return job; |
| 189 return job_factory_->MaybeCreateJobWithProtocolHandler( | 189 return job_factory_->MaybeCreateJobWithProtocolHandler( |
| 190 scheme, request, network_delegate); | 190 scheme, request, network_delegate); |
| 191 } | 191 } |
| 192 | 192 |
| 193 net::URLRequestJob* | 193 net::URLRequestJob* |
| 194 ProtocolHandlerRegistry::JobInterceptorFactory::MaybeInterceptRedirect( | 194 ProtocolHandlerRegistry::JobInterceptorFactory::MaybeInterceptRedirect( |
| 195 net::URLRequest* request, | 195 net::URLRequest* request, |
| 196 net::NetworkDelegate* network_delegate, | 196 net::NetworkDelegate* network_delegate, |
| 197 const GURL& location) const { | 197 const GURL& location) const { |
| 198 return job_factory_->MaybeInterceptRedirect( | 198 return job_factory_->MaybeInterceptRedirect( |
| 199 request, network_delegate, location); | 199 request, network_delegate, location); |
| 200 } | 200 } |
| 201 | 201 |
| 202 net::URLRequestJob* | 202 net::URLRequestJob* |
| 203 ProtocolHandlerRegistry::JobInterceptorFactory::MaybeInterceptResponse( | 203 ProtocolHandlerRegistry::JobInterceptorFactory::MaybeInterceptResponse( |
| 204 net::URLRequest* request, | 204 net::URLRequest* request, |
| 205 net::NetworkDelegate* network_delegate) const { | 205 net::NetworkDelegate* network_delegate) const { |
| 206 return job_factory_->MaybeInterceptResponse(request, network_delegate); | 206 return job_factory_->MaybeInterceptResponse(request, network_delegate); |
| 207 } | 207 } |
| 208 | 208 |
| 209 bool ProtocolHandlerRegistry::JobInterceptorFactory::IsHandledProtocol( | 209 bool ProtocolHandlerRegistry::JobInterceptorFactory::IsHandledProtocol( |
| 210 const std::string& scheme) const { | 210 const std::string& scheme) const { |
| 211 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 211 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 212 return io_thread_delegate_->IsHandledProtocol(scheme) || | 212 return io_thread_delegate_->IsHandledProtocol(scheme) || |
| 213 job_factory_->IsHandledProtocol(scheme); | 213 job_factory_->IsHandledProtocol(scheme); |
| 214 } | 214 } |
| 215 | 215 |
| 216 bool ProtocolHandlerRegistry::JobInterceptorFactory::IsHandledURL( | 216 bool ProtocolHandlerRegistry::JobInterceptorFactory::IsHandledURL( |
| 217 const GURL& url) const { | 217 const GURL& url) const { |
| 218 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 218 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 219 return (url.is_valid() && | 219 return (url.is_valid() && |
| 220 io_thread_delegate_->IsHandledProtocol(url.scheme())) || | 220 io_thread_delegate_->IsHandledProtocol(url.scheme())) || |
| 221 job_factory_->IsHandledURL(url); | 221 job_factory_->IsHandledURL(url); |
| 222 } | 222 } |
| 223 | 223 |
| 224 bool ProtocolHandlerRegistry::JobInterceptorFactory::IsSafeRedirectTarget( | 224 bool ProtocolHandlerRegistry::JobInterceptorFactory::IsSafeRedirectTarget( |
| 225 const GURL& location) const { | 225 const GURL& location) const { |
| 226 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 226 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 227 return job_factory_->IsSafeRedirectTarget(location); | 227 return job_factory_->IsSafeRedirectTarget(location); |
| 228 } | 228 } |
| 229 | 229 |
| 230 // DefaultClientObserver ------------------------------------------------------ | 230 // DefaultClientObserver ------------------------------------------------------ |
| 231 | 231 |
| 232 ProtocolHandlerRegistry::DefaultClientObserver::DefaultClientObserver( | 232 ProtocolHandlerRegistry::DefaultClientObserver::DefaultClientObserver( |
| 233 ProtocolHandlerRegistry* registry) | 233 ProtocolHandlerRegistry* registry) |
| 234 : worker_(NULL), | 234 : worker_(NULL), |
| 235 registry_(registry) { | 235 registry_(registry) { |
| 236 DCHECK(registry_); | 236 DCHECK(registry_); |
| (...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 343 return true; | 343 return true; |
| 344 | 344 |
| 345 if (AttemptReplace(handler)) | 345 if (AttemptReplace(handler)) |
| 346 return true; | 346 return true; |
| 347 | 347 |
| 348 return false; | 348 return false; |
| 349 } | 349 } |
| 350 | 350 |
| 351 void ProtocolHandlerRegistry::OnAcceptRegisterProtocolHandler( | 351 void ProtocolHandlerRegistry::OnAcceptRegisterProtocolHandler( |
| 352 const ProtocolHandler& handler) { | 352 const ProtocolHandler& handler) { |
| 353 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 353 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 354 RegisterProtocolHandler(handler, USER); | 354 RegisterProtocolHandler(handler, USER); |
| 355 SetDefault(handler); | 355 SetDefault(handler); |
| 356 Save(); | 356 Save(); |
| 357 NotifyChanged(); | 357 NotifyChanged(); |
| 358 } | 358 } |
| 359 | 359 |
| 360 void ProtocolHandlerRegistry::OnDenyRegisterProtocolHandler( | 360 void ProtocolHandlerRegistry::OnDenyRegisterProtocolHandler( |
| 361 const ProtocolHandler& handler) { | 361 const ProtocolHandler& handler) { |
| 362 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 362 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 363 RegisterProtocolHandler(handler, USER); | 363 RegisterProtocolHandler(handler, USER); |
| 364 Save(); | 364 Save(); |
| 365 NotifyChanged(); | 365 NotifyChanged(); |
| 366 } | 366 } |
| 367 | 367 |
| 368 void ProtocolHandlerRegistry::OnIgnoreRegisterProtocolHandler( | 368 void ProtocolHandlerRegistry::OnIgnoreRegisterProtocolHandler( |
| 369 const ProtocolHandler& handler) { | 369 const ProtocolHandler& handler) { |
| 370 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 370 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 371 IgnoreProtocolHandler(handler, USER); | 371 IgnoreProtocolHandler(handler, USER); |
| 372 Save(); | 372 Save(); |
| 373 NotifyChanged(); | 373 NotifyChanged(); |
| 374 } | 374 } |
| 375 | 375 |
| 376 bool ProtocolHandlerRegistry::AttemptReplace(const ProtocolHandler& handler) { | 376 bool ProtocolHandlerRegistry::AttemptReplace(const ProtocolHandler& handler) { |
| 377 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 377 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 378 ProtocolHandler old_default = GetHandlerFor(handler.protocol()); | 378 ProtocolHandler old_default = GetHandlerFor(handler.protocol()); |
| 379 bool make_new_handler_default = handler.IsSameOrigin(old_default); | 379 bool make_new_handler_default = handler.IsSameOrigin(old_default); |
| 380 ProtocolHandlerList to_replace(GetReplacedHandlers(handler)); | 380 ProtocolHandlerList to_replace(GetReplacedHandlers(handler)); |
| 381 if (to_replace.empty()) | 381 if (to_replace.empty()) |
| 382 return false; | 382 return false; |
| 383 for (ProtocolHandlerList::iterator p = to_replace.begin(); | 383 for (ProtocolHandlerList::iterator p = to_replace.begin(); |
| 384 p != to_replace.end(); ++p) { | 384 p != to_replace.end(); ++p) { |
| 385 RemoveHandler(*p); | 385 RemoveHandler(*p); |
| 386 } | 386 } |
| 387 if (make_new_handler_default) { | 387 if (make_new_handler_default) { |
| (...skipping 15 matching lines...) Expand all Loading... |
| 403 for (ProtocolHandlerList::const_iterator p = handlers->begin(); | 403 for (ProtocolHandlerList::const_iterator p = handlers->begin(); |
| 404 p != handlers->end(); p++) { | 404 p != handlers->end(); p++) { |
| 405 if (handler.IsSameOrigin(*p)) { | 405 if (handler.IsSameOrigin(*p)) { |
| 406 replaced_handlers.push_back(*p); | 406 replaced_handlers.push_back(*p); |
| 407 } | 407 } |
| 408 } | 408 } |
| 409 return replaced_handlers; | 409 return replaced_handlers; |
| 410 } | 410 } |
| 411 | 411 |
| 412 void ProtocolHandlerRegistry::ClearDefault(const std::string& scheme) { | 412 void ProtocolHandlerRegistry::ClearDefault(const std::string& scheme) { |
| 413 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 413 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 414 | 414 |
| 415 default_handlers_.erase(scheme); | 415 default_handlers_.erase(scheme); |
| 416 BrowserThread::PostTask( | 416 BrowserThread::PostTask( |
| 417 BrowserThread::IO, | 417 BrowserThread::IO, |
| 418 FROM_HERE, | 418 FROM_HERE, |
| 419 base::Bind(&IOThreadDelegate::ClearDefault, io_thread_delegate_, scheme)); | 419 base::Bind(&IOThreadDelegate::ClearDefault, io_thread_delegate_, scheme)); |
| 420 Save(); | 420 Save(); |
| 421 NotifyChanged(); | 421 NotifyChanged(); |
| 422 } | 422 } |
| 423 | 423 |
| 424 bool ProtocolHandlerRegistry::IsDefault( | 424 bool ProtocolHandlerRegistry::IsDefault( |
| 425 const ProtocolHandler& handler) const { | 425 const ProtocolHandler& handler) const { |
| 426 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 426 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 427 return GetHandlerFor(handler.protocol()) == handler; | 427 return GetHandlerFor(handler.protocol()) == handler; |
| 428 } | 428 } |
| 429 | 429 |
| 430 void ProtocolHandlerRegistry::InstallDefaultsForChromeOS() { | 430 void ProtocolHandlerRegistry::InstallDefaultsForChromeOS() { |
| 431 #if defined(OS_CHROMEOS) | 431 #if defined(OS_CHROMEOS) |
| 432 // Only chromeos has default protocol handlers at this point. | 432 // Only chromeos has default protocol handlers at this point. |
| 433 AddPredefinedHandler( | 433 AddPredefinedHandler( |
| 434 ProtocolHandler::CreateProtocolHandler( | 434 ProtocolHandler::CreateProtocolHandler( |
| 435 "mailto", | 435 "mailto", |
| 436 GURL(l10n_util::GetStringUTF8(IDS_GOOGLE_MAILTO_HANDLER_URL)))); | 436 GURL(l10n_util::GetStringUTF8(IDS_GOOGLE_MAILTO_HANDLER_URL)))); |
| 437 AddPredefinedHandler( | 437 AddPredefinedHandler( |
| 438 ProtocolHandler::CreateProtocolHandler( | 438 ProtocolHandler::CreateProtocolHandler( |
| 439 "webcal", | 439 "webcal", |
| 440 GURL(l10n_util::GetStringUTF8(IDS_GOOGLE_WEBCAL_HANDLER_URL)))); | 440 GURL(l10n_util::GetStringUTF8(IDS_GOOGLE_WEBCAL_HANDLER_URL)))); |
| 441 #else | 441 #else |
| 442 NOTREACHED(); // this method should only ever be called in chromeos. | 442 NOTREACHED(); // this method should only ever be called in chromeos. |
| 443 #endif | 443 #endif |
| 444 } | 444 } |
| 445 | 445 |
| 446 void ProtocolHandlerRegistry::InitProtocolSettings() { | 446 void ProtocolHandlerRegistry::InitProtocolSettings() { |
| 447 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 447 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 448 | 448 |
| 449 // Any further default additions to the table will get rejected from now on. | 449 // Any further default additions to the table will get rejected from now on. |
| 450 is_loaded_ = true; | 450 is_loaded_ = true; |
| 451 is_loading_ = true; | 451 is_loading_ = true; |
| 452 | 452 |
| 453 PrefService* prefs = user_prefs::UserPrefs::Get(context_); | 453 PrefService* prefs = user_prefs::UserPrefs::Get(context_); |
| 454 if (prefs->HasPrefPath(prefs::kCustomHandlersEnabled)) { | 454 if (prefs->HasPrefPath(prefs::kCustomHandlersEnabled)) { |
| 455 if (prefs->GetBoolean(prefs::kCustomHandlersEnabled)) { | 455 if (prefs->GetBoolean(prefs::kCustomHandlersEnabled)) { |
| 456 Enable(); | 456 Enable(); |
| 457 } else { | 457 } else { |
| (...skipping 19 matching lines...) Expand all Loading... |
| 477 scoped_refptr<ShellIntegration::DefaultProtocolClientWorker> worker; | 477 scoped_refptr<ShellIntegration::DefaultProtocolClientWorker> worker; |
| 478 worker = delegate_->CreateShellWorker(observer, handler.protocol()); | 478 worker = delegate_->CreateShellWorker(observer, handler.protocol()); |
| 479 observer->SetWorker(worker.get()); | 479 observer->SetWorker(worker.get()); |
| 480 default_client_observers_.push_back(observer); | 480 default_client_observers_.push_back(observer); |
| 481 worker->StartCheckIsDefault(); | 481 worker->StartCheckIsDefault(); |
| 482 } | 482 } |
| 483 } | 483 } |
| 484 } | 484 } |
| 485 | 485 |
| 486 int ProtocolHandlerRegistry::GetHandlerIndex(const std::string& scheme) const { | 486 int ProtocolHandlerRegistry::GetHandlerIndex(const std::string& scheme) const { |
| 487 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 487 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 488 const ProtocolHandler& handler = GetHandlerFor(scheme); | 488 const ProtocolHandler& handler = GetHandlerFor(scheme); |
| 489 if (handler.IsEmpty()) | 489 if (handler.IsEmpty()) |
| 490 return -1; | 490 return -1; |
| 491 const ProtocolHandlerList* handlers = GetHandlerList(scheme); | 491 const ProtocolHandlerList* handlers = GetHandlerList(scheme); |
| 492 if (!handlers) | 492 if (!handlers) |
| 493 return -1; | 493 return -1; |
| 494 | 494 |
| 495 ProtocolHandlerList::const_iterator p; | 495 ProtocolHandlerList::const_iterator p; |
| 496 int i; | 496 int i; |
| 497 for (i = 0, p = handlers->begin(); p != handlers->end(); ++p, ++i) { | 497 for (i = 0, p = handlers->begin(); p != handlers->end(); ++p, ++i) { |
| 498 if (*p == handler) | 498 if (*p == handler) |
| 499 return i; | 499 return i; |
| 500 } | 500 } |
| 501 return -1; | 501 return -1; |
| 502 } | 502 } |
| 503 | 503 |
| 504 ProtocolHandlerRegistry::ProtocolHandlerList | 504 ProtocolHandlerRegistry::ProtocolHandlerList |
| 505 ProtocolHandlerRegistry::GetHandlersFor( | 505 ProtocolHandlerRegistry::GetHandlersFor( |
| 506 const std::string& scheme) const { | 506 const std::string& scheme) const { |
| 507 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 507 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 508 ProtocolHandlerMultiMap::const_iterator p = protocol_handlers_.find(scheme); | 508 ProtocolHandlerMultiMap::const_iterator p = protocol_handlers_.find(scheme); |
| 509 if (p == protocol_handlers_.end()) { | 509 if (p == protocol_handlers_.end()) { |
| 510 return ProtocolHandlerList(); | 510 return ProtocolHandlerList(); |
| 511 } | 511 } |
| 512 return p->second; | 512 return p->second; |
| 513 } | 513 } |
| 514 | 514 |
| 515 ProtocolHandlerRegistry::ProtocolHandlerList | 515 ProtocolHandlerRegistry::ProtocolHandlerList |
| 516 ProtocolHandlerRegistry::GetIgnoredHandlers() { | 516 ProtocolHandlerRegistry::GetIgnoredHandlers() { |
| 517 return ignored_protocol_handlers_; | 517 return ignored_protocol_handlers_; |
| 518 } | 518 } |
| 519 | 519 |
| 520 void ProtocolHandlerRegistry::GetRegisteredProtocols( | 520 void ProtocolHandlerRegistry::GetRegisteredProtocols( |
| 521 std::vector<std::string>* output) const { | 521 std::vector<std::string>* output) const { |
| 522 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 522 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 523 ProtocolHandlerMultiMap::const_iterator p; | 523 ProtocolHandlerMultiMap::const_iterator p; |
| 524 for (p = protocol_handlers_.begin(); p != protocol_handlers_.end(); ++p) { | 524 for (p = protocol_handlers_.begin(); p != protocol_handlers_.end(); ++p) { |
| 525 if (!p->second.empty()) | 525 if (!p->second.empty()) |
| 526 output->push_back(p->first); | 526 output->push_back(p->first); |
| 527 } | 527 } |
| 528 } | 528 } |
| 529 | 529 |
| 530 bool ProtocolHandlerRegistry::CanSchemeBeOverridden( | 530 bool ProtocolHandlerRegistry::CanSchemeBeOverridden( |
| 531 const std::string& scheme) const { | 531 const std::string& scheme) const { |
| 532 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 532 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 533 const ProtocolHandlerList* handlers = GetHandlerList(scheme); | 533 const ProtocolHandlerList* handlers = GetHandlerList(scheme); |
| 534 // If we already have a handler for this scheme, we can add more. | 534 // If we already have a handler for this scheme, we can add more. |
| 535 if (handlers != NULL && !handlers->empty()) | 535 if (handlers != NULL && !handlers->empty()) |
| 536 return true; | 536 return true; |
| 537 // Don't override a scheme if it already has an external handler. | 537 // Don't override a scheme if it already has an external handler. |
| 538 return !delegate_->IsExternalHandlerRegistered(scheme); | 538 return !delegate_->IsExternalHandlerRegistered(scheme); |
| 539 } | 539 } |
| 540 | 540 |
| 541 bool ProtocolHandlerRegistry::IsRegistered( | 541 bool ProtocolHandlerRegistry::IsRegistered( |
| 542 const ProtocolHandler& handler) const { | 542 const ProtocolHandler& handler) const { |
| 543 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 543 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 544 const ProtocolHandlerList* handlers = GetHandlerList(handler.protocol()); | 544 const ProtocolHandlerList* handlers = GetHandlerList(handler.protocol()); |
| 545 if (!handlers) { | 545 if (!handlers) { |
| 546 return false; | 546 return false; |
| 547 } | 547 } |
| 548 return std::find(handlers->begin(), handlers->end(), handler) != | 548 return std::find(handlers->begin(), handlers->end(), handler) != |
| 549 handlers->end(); | 549 handlers->end(); |
| 550 } | 550 } |
| 551 | 551 |
| 552 bool ProtocolHandlerRegistry::IsRegisteredByUser( | 552 bool ProtocolHandlerRegistry::IsRegisteredByUser( |
| 553 const ProtocolHandler& handler) { | 553 const ProtocolHandler& handler) { |
| 554 return HandlerExists(handler, &user_protocol_handlers_); | 554 return HandlerExists(handler, &user_protocol_handlers_); |
| 555 } | 555 } |
| 556 | 556 |
| 557 bool ProtocolHandlerRegistry::HasPolicyRegisteredHandler( | 557 bool ProtocolHandlerRegistry::HasPolicyRegisteredHandler( |
| 558 const std::string& scheme) { | 558 const std::string& scheme) { |
| 559 return (policy_protocol_handlers_.find(scheme) != | 559 return (policy_protocol_handlers_.find(scheme) != |
| 560 policy_protocol_handlers_.end()); | 560 policy_protocol_handlers_.end()); |
| 561 } | 561 } |
| 562 | 562 |
| 563 bool ProtocolHandlerRegistry::IsIgnored(const ProtocolHandler& handler) const { | 563 bool ProtocolHandlerRegistry::IsIgnored(const ProtocolHandler& handler) const { |
| 564 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 564 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 565 ProtocolHandlerList::const_iterator i; | 565 ProtocolHandlerList::const_iterator i; |
| 566 for (i = ignored_protocol_handlers_.begin(); | 566 for (i = ignored_protocol_handlers_.begin(); |
| 567 i != ignored_protocol_handlers_.end(); ++i) { | 567 i != ignored_protocol_handlers_.end(); ++i) { |
| 568 if (*i == handler) { | 568 if (*i == handler) { |
| 569 return true; | 569 return true; |
| 570 } | 570 } |
| 571 } | 571 } |
| 572 return false; | 572 return false; |
| 573 } | 573 } |
| 574 | 574 |
| 575 bool ProtocolHandlerRegistry::HasRegisteredEquivalent( | 575 bool ProtocolHandlerRegistry::HasRegisteredEquivalent( |
| 576 const ProtocolHandler& handler) const { | 576 const ProtocolHandler& handler) const { |
| 577 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 577 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 578 const ProtocolHandlerList* handlers = GetHandlerList(handler.protocol()); | 578 const ProtocolHandlerList* handlers = GetHandlerList(handler.protocol()); |
| 579 if (!handlers) { | 579 if (!handlers) { |
| 580 return false; | 580 return false; |
| 581 } | 581 } |
| 582 ProtocolHandlerList::const_iterator i; | 582 ProtocolHandlerList::const_iterator i; |
| 583 for (i = handlers->begin(); i != handlers->end(); ++i) { | 583 for (i = handlers->begin(); i != handlers->end(); ++i) { |
| 584 if (handler.IsEquivalent(*i)) { | 584 if (handler.IsEquivalent(*i)) { |
| 585 return true; | 585 return true; |
| 586 } | 586 } |
| 587 } | 587 } |
| 588 return false; | 588 return false; |
| 589 } | 589 } |
| 590 | 590 |
| 591 bool ProtocolHandlerRegistry::HasIgnoredEquivalent( | 591 bool ProtocolHandlerRegistry::HasIgnoredEquivalent( |
| 592 const ProtocolHandler& handler) const { | 592 const ProtocolHandler& handler) const { |
| 593 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 593 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 594 ProtocolHandlerList::const_iterator i; | 594 ProtocolHandlerList::const_iterator i; |
| 595 for (i = ignored_protocol_handlers_.begin(); | 595 for (i = ignored_protocol_handlers_.begin(); |
| 596 i != ignored_protocol_handlers_.end(); ++i) { | 596 i != ignored_protocol_handlers_.end(); ++i) { |
| 597 if (handler.IsEquivalent(*i)) { | 597 if (handler.IsEquivalent(*i)) { |
| 598 return true; | 598 return true; |
| 599 } | 599 } |
| 600 } | 600 } |
| 601 return false; | 601 return false; |
| 602 } | 602 } |
| 603 | 603 |
| 604 void ProtocolHandlerRegistry::RemoveIgnoredHandler( | 604 void ProtocolHandlerRegistry::RemoveIgnoredHandler( |
| 605 const ProtocolHandler& handler) { | 605 const ProtocolHandler& handler) { |
| 606 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 606 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 607 bool should_notify = false; | 607 bool should_notify = false; |
| 608 if (HandlerExists(handler, ignored_protocol_handlers_) && | 608 if (HandlerExists(handler, ignored_protocol_handlers_) && |
| 609 HandlerExists(handler, user_ignored_protocol_handlers_)) { | 609 HandlerExists(handler, user_ignored_protocol_handlers_)) { |
| 610 EraseHandler(handler, &user_ignored_protocol_handlers_); | 610 EraseHandler(handler, &user_ignored_protocol_handlers_); |
| 611 Save(); | 611 Save(); |
| 612 if (!HandlerExists(handler, policy_ignored_protocol_handlers_)) { | 612 if (!HandlerExists(handler, policy_ignored_protocol_handlers_)) { |
| 613 EraseHandler(handler, &ignored_protocol_handlers_); | 613 EraseHandler(handler, &ignored_protocol_handlers_); |
| 614 should_notify = true; | 614 should_notify = true; |
| 615 } | 615 } |
| 616 } | 616 } |
| 617 if (should_notify) | 617 if (should_notify) |
| 618 NotifyChanged(); | 618 NotifyChanged(); |
| 619 } | 619 } |
| 620 | 620 |
| 621 bool ProtocolHandlerRegistry::IsHandledProtocol( | 621 bool ProtocolHandlerRegistry::IsHandledProtocol( |
| 622 const std::string& scheme) const { | 622 const std::string& scheme) const { |
| 623 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 623 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 624 return enabled_ && !GetHandlerFor(scheme).IsEmpty(); | 624 return enabled_ && !GetHandlerFor(scheme).IsEmpty(); |
| 625 } | 625 } |
| 626 | 626 |
| 627 void ProtocolHandlerRegistry::RemoveHandler( | 627 void ProtocolHandlerRegistry::RemoveHandler( |
| 628 const ProtocolHandler& handler) { | 628 const ProtocolHandler& handler) { |
| 629 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 629 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 630 ProtocolHandlerList& handlers = protocol_handlers_[handler.protocol()]; | 630 ProtocolHandlerList& handlers = protocol_handlers_[handler.protocol()]; |
| 631 bool erase_success = false; | 631 bool erase_success = false; |
| 632 if (HandlerExists(handler, handlers) && | 632 if (HandlerExists(handler, handlers) && |
| 633 HandlerExists(handler, &user_protocol_handlers_)) { | 633 HandlerExists(handler, &user_protocol_handlers_)) { |
| 634 EraseHandler(handler, &user_protocol_handlers_); | 634 EraseHandler(handler, &user_protocol_handlers_); |
| 635 erase_success = true; | 635 erase_success = true; |
| 636 if (!HandlerExists(handler, &policy_protocol_handlers_)) | 636 if (!HandlerExists(handler, &policy_protocol_handlers_)) |
| 637 EraseHandler(handler, &protocol_handlers_); | 637 EraseHandler(handler, &protocol_handlers_); |
| 638 } | 638 } |
| 639 ProtocolHandlerMap::iterator q = default_handlers_.find(handler.protocol()); | 639 ProtocolHandlerMap::iterator q = default_handlers_.find(handler.protocol()); |
| (...skipping 14 matching lines...) Expand all Loading... |
| 654 | 654 |
| 655 if (erase_success && !IsHandledProtocol(handler.protocol())) { | 655 if (erase_success && !IsHandledProtocol(handler.protocol())) { |
| 656 delegate_->DeregisterExternalHandler(handler.protocol()); | 656 delegate_->DeregisterExternalHandler(handler.protocol()); |
| 657 } | 657 } |
| 658 Save(); | 658 Save(); |
| 659 if (erase_success) | 659 if (erase_success) |
| 660 NotifyChanged(); | 660 NotifyChanged(); |
| 661 } | 661 } |
| 662 | 662 |
| 663 void ProtocolHandlerRegistry::RemoveDefaultHandler(const std::string& scheme) { | 663 void ProtocolHandlerRegistry::RemoveDefaultHandler(const std::string& scheme) { |
| 664 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 664 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 665 ProtocolHandler current_default = GetHandlerFor(scheme); | 665 ProtocolHandler current_default = GetHandlerFor(scheme); |
| 666 if (!current_default.IsEmpty()) | 666 if (!current_default.IsEmpty()) |
| 667 RemoveHandler(current_default); | 667 RemoveHandler(current_default); |
| 668 } | 668 } |
| 669 | 669 |
| 670 const ProtocolHandler& ProtocolHandlerRegistry::GetHandlerFor( | 670 const ProtocolHandler& ProtocolHandlerRegistry::GetHandlerFor( |
| 671 const std::string& scheme) const { | 671 const std::string& scheme) const { |
| 672 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 672 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 673 return LookupHandler(default_handlers_, scheme); | 673 return LookupHandler(default_handlers_, scheme); |
| 674 } | 674 } |
| 675 | 675 |
| 676 void ProtocolHandlerRegistry::Enable() { | 676 void ProtocolHandlerRegistry::Enable() { |
| 677 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 677 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 678 if (enabled_) { | 678 if (enabled_) { |
| 679 return; | 679 return; |
| 680 } | 680 } |
| 681 enabled_ = true; | 681 enabled_ = true; |
| 682 BrowserThread::PostTask( | 682 BrowserThread::PostTask( |
| 683 BrowserThread::IO, | 683 BrowserThread::IO, |
| 684 FROM_HERE, | 684 FROM_HERE, |
| 685 base::Bind(&IOThreadDelegate::Enable, io_thread_delegate_)); | 685 base::Bind(&IOThreadDelegate::Enable, io_thread_delegate_)); |
| 686 | 686 |
| 687 ProtocolHandlerMap::const_iterator p; | 687 ProtocolHandlerMap::const_iterator p; |
| 688 for (p = default_handlers_.begin(); p != default_handlers_.end(); ++p) { | 688 for (p = default_handlers_.begin(); p != default_handlers_.end(); ++p) { |
| 689 delegate_->RegisterExternalHandler(p->first); | 689 delegate_->RegisterExternalHandler(p->first); |
| 690 } | 690 } |
| 691 Save(); | 691 Save(); |
| 692 NotifyChanged(); | 692 NotifyChanged(); |
| 693 } | 693 } |
| 694 | 694 |
| 695 void ProtocolHandlerRegistry::Disable() { | 695 void ProtocolHandlerRegistry::Disable() { |
| 696 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 696 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 697 if (!enabled_) { | 697 if (!enabled_) { |
| 698 return; | 698 return; |
| 699 } | 699 } |
| 700 enabled_ = false; | 700 enabled_ = false; |
| 701 BrowserThread::PostTask( | 701 BrowserThread::PostTask( |
| 702 BrowserThread::IO, | 702 BrowserThread::IO, |
| 703 FROM_HERE, | 703 FROM_HERE, |
| 704 base::Bind(&IOThreadDelegate::Disable, io_thread_delegate_)); | 704 base::Bind(&IOThreadDelegate::Disable, io_thread_delegate_)); |
| 705 | 705 |
| 706 ProtocolHandlerMap::const_iterator p; | 706 ProtocolHandlerMap::const_iterator p; |
| 707 for (p = default_handlers_.begin(); p != default_handlers_.end(); ++p) { | 707 for (p = default_handlers_.begin(); p != default_handlers_.end(); ++p) { |
| 708 delegate_->DeregisterExternalHandler(p->first); | 708 delegate_->DeregisterExternalHandler(p->first); |
| 709 } | 709 } |
| 710 Save(); | 710 Save(); |
| 711 NotifyChanged(); | 711 NotifyChanged(); |
| 712 } | 712 } |
| 713 | 713 |
| 714 void ProtocolHandlerRegistry::Shutdown() { | 714 void ProtocolHandlerRegistry::Shutdown() { |
| 715 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 715 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 716 delegate_.reset(NULL); | 716 delegate_.reset(NULL); |
| 717 // We free these now in case there are any outstanding workers running. If | 717 // We free these now in case there are any outstanding workers running. If |
| 718 // we didn't free them they could respond to workers and try to update the | 718 // we didn't free them they could respond to workers and try to update the |
| 719 // protocol handler registry after it was deleted. | 719 // protocol handler registry after it was deleted. |
| 720 // Observers remove themselves from this list when they are deleted; so | 720 // Observers remove themselves from this list when they are deleted; so |
| 721 // we delete the last item until none are left in the list. | 721 // we delete the last item until none are left in the list. |
| 722 while (!default_client_observers_.empty()) { | 722 while (!default_client_observers_.empty()) { |
| 723 delete default_client_observers_.back(); | 723 delete default_client_observers_.back(); |
| 724 } | 724 } |
| 725 } | 725 } |
| 726 | 726 |
| 727 // static | 727 // static |
| 728 void ProtocolHandlerRegistry::RegisterProfilePrefs( | 728 void ProtocolHandlerRegistry::RegisterProfilePrefs( |
| 729 user_prefs::PrefRegistrySyncable* registry) { | 729 user_prefs::PrefRegistrySyncable* registry) { |
| 730 registry->RegisterListPref(prefs::kRegisteredProtocolHandlers, | 730 registry->RegisterListPref(prefs::kRegisteredProtocolHandlers, |
| 731 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); | 731 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); |
| 732 registry->RegisterListPref(prefs::kIgnoredProtocolHandlers, | 732 registry->RegisterListPref(prefs::kIgnoredProtocolHandlers, |
| 733 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); | 733 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); |
| 734 registry->RegisterListPref(prefs::kPolicyRegisteredProtocolHandlers, | 734 registry->RegisterListPref(prefs::kPolicyRegisteredProtocolHandlers, |
| 735 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); | 735 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); |
| 736 registry->RegisterListPref(prefs::kPolicyIgnoredProtocolHandlers, | 736 registry->RegisterListPref(prefs::kPolicyIgnoredProtocolHandlers, |
| 737 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); | 737 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); |
| 738 registry->RegisterBooleanPref( | 738 registry->RegisterBooleanPref( |
| 739 prefs::kCustomHandlersEnabled, | 739 prefs::kCustomHandlersEnabled, |
| 740 true, | 740 true, |
| 741 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); | 741 user_prefs::PrefRegistrySyncable::UNSYNCABLE_PREF); |
| 742 } | 742 } |
| 743 | 743 |
| 744 ProtocolHandlerRegistry::~ProtocolHandlerRegistry() { | 744 ProtocolHandlerRegistry::~ProtocolHandlerRegistry() { |
| 745 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 745 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 746 DCHECK(default_client_observers_.empty()); | 746 DCHECK(default_client_observers_.empty()); |
| 747 } | 747 } |
| 748 | 748 |
| 749 void ProtocolHandlerRegistry::PromoteHandler(const ProtocolHandler& handler) { | 749 void ProtocolHandlerRegistry::PromoteHandler(const ProtocolHandler& handler) { |
| 750 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 750 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 751 DCHECK(IsRegistered(handler)); | 751 DCHECK(IsRegistered(handler)); |
| 752 ProtocolHandlerMultiMap::iterator p = | 752 ProtocolHandlerMultiMap::iterator p = |
| 753 protocol_handlers_.find(handler.protocol()); | 753 protocol_handlers_.find(handler.protocol()); |
| 754 ProtocolHandlerList& list = p->second; | 754 ProtocolHandlerList& list = p->second; |
| 755 list.erase(std::find(list.begin(), list.end(), handler)); | 755 list.erase(std::find(list.begin(), list.end(), handler)); |
| 756 list.insert(list.begin(), handler); | 756 list.insert(list.begin(), handler); |
| 757 } | 757 } |
| 758 | 758 |
| 759 void ProtocolHandlerRegistry::Save() { | 759 void ProtocolHandlerRegistry::Save() { |
| 760 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 760 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 761 if (is_loading_) { | 761 if (is_loading_) { |
| 762 return; | 762 return; |
| 763 } | 763 } |
| 764 scoped_ptr<base::Value> registered_protocol_handlers( | 764 scoped_ptr<base::Value> registered_protocol_handlers( |
| 765 EncodeRegisteredHandlers()); | 765 EncodeRegisteredHandlers()); |
| 766 scoped_ptr<base::Value> ignored_protocol_handlers(EncodeIgnoredHandlers()); | 766 scoped_ptr<base::Value> ignored_protocol_handlers(EncodeIgnoredHandlers()); |
| 767 PrefService* prefs = user_prefs::UserPrefs::Get(context_); | 767 PrefService* prefs = user_prefs::UserPrefs::Get(context_); |
| 768 | 768 |
| 769 prefs->Set(prefs::kRegisteredProtocolHandlers, | 769 prefs->Set(prefs::kRegisteredProtocolHandlers, |
| 770 *registered_protocol_handlers); | 770 *registered_protocol_handlers); |
| 771 prefs->Set(prefs::kIgnoredProtocolHandlers, | 771 prefs->Set(prefs::kIgnoredProtocolHandlers, |
| 772 *ignored_protocol_handlers); | 772 *ignored_protocol_handlers); |
| 773 prefs->SetBoolean(prefs::kCustomHandlersEnabled, enabled_); | 773 prefs->SetBoolean(prefs::kCustomHandlersEnabled, enabled_); |
| 774 } | 774 } |
| 775 | 775 |
| 776 const ProtocolHandlerRegistry::ProtocolHandlerList* | 776 const ProtocolHandlerRegistry::ProtocolHandlerList* |
| 777 ProtocolHandlerRegistry::GetHandlerList( | 777 ProtocolHandlerRegistry::GetHandlerList( |
| 778 const std::string& scheme) const { | 778 const std::string& scheme) const { |
| 779 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 779 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 780 ProtocolHandlerMultiMap::const_iterator p = protocol_handlers_.find(scheme); | 780 ProtocolHandlerMultiMap::const_iterator p = protocol_handlers_.find(scheme); |
| 781 if (p == protocol_handlers_.end()) { | 781 if (p == protocol_handlers_.end()) { |
| 782 return NULL; | 782 return NULL; |
| 783 } | 783 } |
| 784 return &p->second; | 784 return &p->second; |
| 785 } | 785 } |
| 786 | 786 |
| 787 void ProtocolHandlerRegistry::SetDefault(const ProtocolHandler& handler) { | 787 void ProtocolHandlerRegistry::SetDefault(const ProtocolHandler& handler) { |
| 788 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 788 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 789 ProtocolHandlerMap::const_iterator p = default_handlers_.find( | 789 ProtocolHandlerMap::const_iterator p = default_handlers_.find( |
| 790 handler.protocol()); | 790 handler.protocol()); |
| 791 // If we're not loading, and we are setting a default for a new protocol, | 791 // If we're not loading, and we are setting a default for a new protocol, |
| 792 // register with the OS. | 792 // register with the OS. |
| 793 if (!is_loading_ && p == default_handlers_.end()) | 793 if (!is_loading_ && p == default_handlers_.end()) |
| 794 delegate_->RegisterWithOSAsDefaultClient(handler.protocol(), this); | 794 delegate_->RegisterWithOSAsDefaultClient(handler.protocol(), this); |
| 795 default_handlers_.erase(handler.protocol()); | 795 default_handlers_.erase(handler.protocol()); |
| 796 default_handlers_.insert(std::make_pair(handler.protocol(), handler)); | 796 default_handlers_.insert(std::make_pair(handler.protocol(), handler)); |
| 797 PromoteHandler(handler); | 797 PromoteHandler(handler); |
| 798 BrowserThread::PostTask( | 798 BrowserThread::PostTask( |
| 799 BrowserThread::IO, | 799 BrowserThread::IO, |
| 800 FROM_HERE, | 800 FROM_HERE, |
| 801 base::Bind(&IOThreadDelegate::SetDefault, io_thread_delegate_, handler)); | 801 base::Bind(&IOThreadDelegate::SetDefault, io_thread_delegate_, handler)); |
| 802 } | 802 } |
| 803 | 803 |
| 804 void ProtocolHandlerRegistry::InsertHandler(const ProtocolHandler& handler) { | 804 void ProtocolHandlerRegistry::InsertHandler(const ProtocolHandler& handler) { |
| 805 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 805 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 806 ProtocolHandlerMultiMap::iterator p = | 806 ProtocolHandlerMultiMap::iterator p = |
| 807 protocol_handlers_.find(handler.protocol()); | 807 protocol_handlers_.find(handler.protocol()); |
| 808 | 808 |
| 809 if (p != protocol_handlers_.end()) { | 809 if (p != protocol_handlers_.end()) { |
| 810 p->second.push_back(handler); | 810 p->second.push_back(handler); |
| 811 return; | 811 return; |
| 812 } | 812 } |
| 813 | 813 |
| 814 ProtocolHandlerList new_list; | 814 ProtocolHandlerList new_list; |
| 815 new_list.push_back(handler); | 815 new_list.push_back(handler); |
| 816 protocol_handlers_[handler.protocol()] = new_list; | 816 protocol_handlers_[handler.protocol()] = new_list; |
| 817 } | 817 } |
| 818 | 818 |
| 819 base::Value* ProtocolHandlerRegistry::EncodeRegisteredHandlers() { | 819 base::Value* ProtocolHandlerRegistry::EncodeRegisteredHandlers() { |
| 820 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 820 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 821 base::ListValue* protocol_handlers = new base::ListValue(); | 821 base::ListValue* protocol_handlers = new base::ListValue(); |
| 822 for (ProtocolHandlerMultiMap::iterator i = user_protocol_handlers_.begin(); | 822 for (ProtocolHandlerMultiMap::iterator i = user_protocol_handlers_.begin(); |
| 823 i != user_protocol_handlers_.end(); | 823 i != user_protocol_handlers_.end(); |
| 824 ++i) { | 824 ++i) { |
| 825 for (ProtocolHandlerList::iterator j = i->second.begin(); | 825 for (ProtocolHandlerList::iterator j = i->second.begin(); |
| 826 j != i->second.end(); ++j) { | 826 j != i->second.end(); ++j) { |
| 827 base::DictionaryValue* encoded = j->Encode(); | 827 base::DictionaryValue* encoded = j->Encode(); |
| 828 if (IsDefault(*j)) { | 828 if (IsDefault(*j)) { |
| 829 encoded->Set("default", new base::FundamentalValue(true)); | 829 encoded->Set("default", new base::FundamentalValue(true)); |
| 830 } | 830 } |
| 831 protocol_handlers->Append(encoded); | 831 protocol_handlers->Append(encoded); |
| 832 } | 832 } |
| 833 } | 833 } |
| 834 return protocol_handlers; | 834 return protocol_handlers; |
| 835 } | 835 } |
| 836 | 836 |
| 837 base::Value* ProtocolHandlerRegistry::EncodeIgnoredHandlers() { | 837 base::Value* ProtocolHandlerRegistry::EncodeIgnoredHandlers() { |
| 838 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 838 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 839 base::ListValue* handlers = new base::ListValue(); | 839 base::ListValue* handlers = new base::ListValue(); |
| 840 for (ProtocolHandlerList::iterator i = | 840 for (ProtocolHandlerList::iterator i = |
| 841 user_ignored_protocol_handlers_.begin(); | 841 user_ignored_protocol_handlers_.begin(); |
| 842 i != user_ignored_protocol_handlers_.end(); | 842 i != user_ignored_protocol_handlers_.end(); |
| 843 ++i) { | 843 ++i) { |
| 844 handlers->Append(i->Encode()); | 844 handlers->Append(i->Encode()); |
| 845 } | 845 } |
| 846 return handlers; | 846 return handlers; |
| 847 } | 847 } |
| 848 | 848 |
| 849 void ProtocolHandlerRegistry::NotifyChanged() { | 849 void ProtocolHandlerRegistry::NotifyChanged() { |
| 850 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 850 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 851 content::NotificationService::current()->Notify( | 851 content::NotificationService::current()->Notify( |
| 852 chrome::NOTIFICATION_PROTOCOL_HANDLER_REGISTRY_CHANGED, | 852 chrome::NOTIFICATION_PROTOCOL_HANDLER_REGISTRY_CHANGED, |
| 853 content::Source<content::BrowserContext>(context_), | 853 content::Source<content::BrowserContext>(context_), |
| 854 content::NotificationService::NoDetails()); | 854 content::NotificationService::NoDetails()); |
| 855 } | 855 } |
| 856 | 856 |
| 857 void ProtocolHandlerRegistry::RegisterProtocolHandler( | 857 void ProtocolHandlerRegistry::RegisterProtocolHandler( |
| 858 const ProtocolHandler& handler, | 858 const ProtocolHandler& handler, |
| 859 const HandlerSource source) { | 859 const HandlerSource source) { |
| 860 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 860 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 861 DCHECK(CanSchemeBeOverridden(handler.protocol())); | 861 DCHECK(CanSchemeBeOverridden(handler.protocol())); |
| 862 DCHECK(!handler.IsEmpty()); | 862 DCHECK(!handler.IsEmpty()); |
| 863 ProtocolHandlerMultiMap& map = | 863 ProtocolHandlerMultiMap& map = |
| 864 (source == POLICY) ? policy_protocol_handlers_ : user_protocol_handlers_; | 864 (source == POLICY) ? policy_protocol_handlers_ : user_protocol_handlers_; |
| 865 ProtocolHandlerList& list = map[handler.protocol()]; | 865 ProtocolHandlerList& list = map[handler.protocol()]; |
| 866 if (!HandlerExists(handler, list)) | 866 if (!HandlerExists(handler, list)) |
| 867 list.push_back(handler); | 867 list.push_back(handler); |
| 868 if (IsRegistered(handler)) { | 868 if (IsRegistered(handler)) { |
| 869 return; | 869 return; |
| 870 } | 870 } |
| 871 if (enabled_ && !delegate_->IsExternalHandlerRegistered(handler.protocol())) | 871 if (enabled_ && !delegate_->IsExternalHandlerRegistered(handler.protocol())) |
| 872 delegate_->RegisterExternalHandler(handler.protocol()); | 872 delegate_->RegisterExternalHandler(handler.protocol()); |
| 873 InsertHandler(handler); | 873 InsertHandler(handler); |
| 874 } | 874 } |
| 875 | 875 |
| 876 std::vector<const base::DictionaryValue*> | 876 std::vector<const base::DictionaryValue*> |
| 877 ProtocolHandlerRegistry::GetHandlersFromPref(const char* pref_name) const { | 877 ProtocolHandlerRegistry::GetHandlersFromPref(const char* pref_name) const { |
| 878 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 878 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 879 std::vector<const base::DictionaryValue*> result; | 879 std::vector<const base::DictionaryValue*> result; |
| 880 PrefService* prefs = user_prefs::UserPrefs::Get(context_); | 880 PrefService* prefs = user_prefs::UserPrefs::Get(context_); |
| 881 if (!prefs->HasPrefPath(pref_name)) { | 881 if (!prefs->HasPrefPath(pref_name)) { |
| 882 return result; | 882 return result; |
| 883 } | 883 } |
| 884 | 884 |
| 885 const base::ListValue* handlers = prefs->GetList(pref_name); | 885 const base::ListValue* handlers = prefs->GetList(pref_name); |
| 886 if (handlers) { | 886 if (handlers) { |
| 887 for (size_t i = 0; i < handlers->GetSize(); ++i) { | 887 for (size_t i = 0; i < handlers->GetSize(); ++i) { |
| 888 const base::DictionaryValue* dict; | 888 const base::DictionaryValue* dict; |
| (...skipping 21 matching lines...) Expand all Loading... |
| 910 bool is_default = false; | 910 bool is_default = false; |
| 911 if ((*p)->GetBoolean("default", &is_default) && is_default) { | 911 if ((*p)->GetBoolean("default", &is_default) && is_default) { |
| 912 SetDefault(handler); | 912 SetDefault(handler); |
| 913 } | 913 } |
| 914 } | 914 } |
| 915 } | 915 } |
| 916 | 916 |
| 917 void ProtocolHandlerRegistry::IgnoreProtocolHandler( | 917 void ProtocolHandlerRegistry::IgnoreProtocolHandler( |
| 918 const ProtocolHandler& handler, | 918 const ProtocolHandler& handler, |
| 919 const HandlerSource source) { | 919 const HandlerSource source) { |
| 920 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 920 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 921 ProtocolHandlerList& list = (source == POLICY) | 921 ProtocolHandlerList& list = (source == POLICY) |
| 922 ? policy_ignored_protocol_handlers_ | 922 ? policy_ignored_protocol_handlers_ |
| 923 : user_ignored_protocol_handlers_; | 923 : user_ignored_protocol_handlers_; |
| 924 if (!HandlerExists(handler, list)) | 924 if (!HandlerExists(handler, list)) |
| 925 list.push_back(handler); | 925 list.push_back(handler); |
| 926 if (HandlerExists(handler, ignored_protocol_handlers_)) | 926 if (HandlerExists(handler, ignored_protocol_handlers_)) |
| 927 return; | 927 return; |
| 928 ignored_protocol_handlers_.push_back(handler); | 928 ignored_protocol_handlers_.push_back(handler); |
| 929 } | 929 } |
| 930 | 930 |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 963 | 963 |
| 964 void ProtocolHandlerRegistry::AddPredefinedHandler( | 964 void ProtocolHandlerRegistry::AddPredefinedHandler( |
| 965 const ProtocolHandler& handler) { | 965 const ProtocolHandler& handler) { |
| 966 DCHECK(!is_loaded_); // Must be called prior InitProtocolSettings. | 966 DCHECK(!is_loaded_); // Must be called prior InitProtocolSettings. |
| 967 RegisterProtocolHandler(handler, USER); | 967 RegisterProtocolHandler(handler, USER); |
| 968 SetDefault(handler); | 968 SetDefault(handler); |
| 969 } | 969 } |
| 970 | 970 |
| 971 scoped_ptr<ProtocolHandlerRegistry::JobInterceptorFactory> | 971 scoped_ptr<ProtocolHandlerRegistry::JobInterceptorFactory> |
| 972 ProtocolHandlerRegistry::CreateJobInterceptorFactory() { | 972 ProtocolHandlerRegistry::CreateJobInterceptorFactory() { |
| 973 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 973 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| 974 // this is always created on the UI thread (in profile_io's | 974 // this is always created on the UI thread (in profile_io's |
| 975 // InitializeOnUIThread. Any method calls must be done | 975 // InitializeOnUIThread. Any method calls must be done |
| 976 // on the IO thread (this is checked). | 976 // on the IO thread (this is checked). |
| 977 return scoped_ptr<JobInterceptorFactory>( | 977 return scoped_ptr<JobInterceptorFactory>( |
| 978 new JobInterceptorFactory(io_thread_delegate_.get())); | 978 new JobInterceptorFactory(io_thread_delegate_.get())); |
| 979 } | 979 } |
| OLD | NEW |