Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(248)

Side by Side Diff: chrome/browser/safe_browsing/safe_browsing_service.cc

Issue 2675063002: Browser tests for using the new SafeBrowsing protocol (v4) (Closed)
Patch Set: Simplify V4DB creation in product code and tests Created 3 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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/safe_browsing/safe_browsing_service.h" 5 #include "chrome/browser/safe_browsing/safe_browsing_service.h"
6 6
7 #include <stddef.h> 7 #include <stddef.h>
8 8
9 #include <vector> 9 #include <vector>
10 10
(...skipping 239 matching lines...) Expand 10 before | Expand all | Expand 10 after
250 SafeBrowsingURLRequestContextGetter::~SafeBrowsingURLRequestContextGetter() {} 250 SafeBrowsingURLRequestContextGetter::~SafeBrowsingURLRequestContextGetter() {}
251 251
252 // static 252 // static
253 SafeBrowsingServiceFactory* SafeBrowsingService::factory_ = NULL; 253 SafeBrowsingServiceFactory* SafeBrowsingService::factory_ = NULL;
254 254
255 // The default SafeBrowsingServiceFactory. Global, made a singleton so we 255 // The default SafeBrowsingServiceFactory. Global, made a singleton so we
256 // don't leak it. 256 // don't leak it.
257 class SafeBrowsingServiceFactoryImpl : public SafeBrowsingServiceFactory { 257 class SafeBrowsingServiceFactoryImpl : public SafeBrowsingServiceFactory {
258 public: 258 public:
259 SafeBrowsingService* CreateSafeBrowsingService() override { 259 SafeBrowsingService* CreateSafeBrowsingService() override {
260 return new SafeBrowsingService(); 260 return new SafeBrowsingService(
261 safe_browsing::V4FeatureList::IsLocalDatabaseManagerEnabled(),
262 safe_browsing::V4FeatureList::IsV4OnlyEnabled());
261 } 263 }
262 264
263 private: 265 private:
264 friend struct base::DefaultLazyInstanceTraits<SafeBrowsingServiceFactoryImpl>; 266 friend struct base::DefaultLazyInstanceTraits<SafeBrowsingServiceFactoryImpl>;
265 267
266 SafeBrowsingServiceFactoryImpl() { } 268 SafeBrowsingServiceFactoryImpl() { }
267 269
268 DISALLOW_COPY_AND_ASSIGN(SafeBrowsingServiceFactoryImpl); 270 DISALLOW_COPY_AND_ASSIGN(SafeBrowsingServiceFactoryImpl);
269 }; 271 };
270 272
(...skipping 14 matching lines...) Expand all
285 } 287 }
286 288
287 289
288 // static 290 // static
289 SafeBrowsingService* SafeBrowsingService::CreateSafeBrowsingService() { 291 SafeBrowsingService* SafeBrowsingService::CreateSafeBrowsingService() {
290 if (!factory_) 292 if (!factory_)
291 factory_ = g_safe_browsing_service_factory_impl.Pointer(); 293 factory_ = g_safe_browsing_service_factory_impl.Pointer();
292 return factory_->CreateSafeBrowsingService(); 294 return factory_->CreateSafeBrowsingService();
293 } 295 }
294 296
295 SafeBrowsingService::SafeBrowsingService() 297 SafeBrowsingService::SafeBrowsingService(bool v4_enabled, bool use_v4_only)
296 : services_delegate_(ServicesDelegate::Create(this)), 298 : services_delegate_(ServicesDelegate::Create(this)),
297 estimated_extended_reporting_by_prefs_(SBER_LEVEL_OFF), 299 estimated_extended_reporting_by_prefs_(SBER_LEVEL_OFF),
298 enabled_(false), 300 enabled_(false),
299 enabled_by_prefs_(false), 301 enabled_by_prefs_(false),
300 enabled_v4_only_(safe_browsing::V4FeatureList::IsV4OnlyEnabled()) {} 302 use_v4_only_(use_v4_only),
303 v4_enabled_(v4_enabled) {}
301 304
302 SafeBrowsingService::~SafeBrowsingService() { 305 SafeBrowsingService::~SafeBrowsingService() {
303 // We should have already been shut down. If we're still enabled, then the 306 // We should have already been shut down. If we're still enabled, then the
304 // database isn't going to be closed properly, which could lead to corruption. 307 // database isn't going to be closed properly, which could lead to corruption.
305 DCHECK(!enabled_); 308 DCHECK(!enabled_);
306 } 309 }
307 310
308 void SafeBrowsingService::Initialize() { 311 void SafeBrowsingService::Initialize() {
309 // Ensure FileTypePolicies's Singleton is instantiated during startup. 312 // Ensure FileTypePolicies's Singleton is instantiated during startup.
310 // This guarantees we'll log UMA metrics about its state. 313 // This guarantees we'll log UMA metrics about its state.
311 FileTypePolicies::GetInstance(); 314 FileTypePolicies::GetInstance();
312 315
313 url_request_context_getter_ = new SafeBrowsingURLRequestContextGetter( 316 url_request_context_getter_ = new SafeBrowsingURLRequestContextGetter(
314 g_browser_process->system_request_context()); 317 g_browser_process->system_request_context());
315 318
316 ui_manager_ = CreateUIManager(); 319 ui_manager_ = CreateUIManager();
317 320
318 if (!enabled_v4_only_) { 321 if (!use_v4_only_) {
319 database_manager_ = CreateDatabaseManager(); 322 database_manager_ = CreateDatabaseManager();
320 } 323 }
321 324
322 if (base::FeatureList::IsEnabled( 325 if (base::FeatureList::IsEnabled(
323 SafeBrowsingNavigationObserverManager::kDownloadAttribution)) { 326 SafeBrowsingNavigationObserverManager::kDownloadAttribution)) {
324 navigation_observer_manager_ = new SafeBrowsingNavigationObserverManager(); 327 navigation_observer_manager_ = new SafeBrowsingNavigationObserverManager();
325 } 328 }
326 329
327 services_delegate_->Initialize(); 330 services_delegate_->Initialize(v4_enabled_);
328 services_delegate_->InitializeCsdService(url_request_context_getter_.get()); 331 services_delegate_->InitializeCsdService(url_request_context_getter_.get());
329 332
330 // Track the safe browsing preference of existing profiles. 333 // Track the safe browsing preference of existing profiles.
331 // The SafeBrowsingService will be started if any existing profile has the 334 // The SafeBrowsingService will be started if any existing profile has the
332 // preference enabled. It will also listen for updates to the preferences. 335 // preference enabled. It will also listen for updates to the preferences.
333 ProfileManager* profile_manager = g_browser_process->profile_manager(); 336 ProfileManager* profile_manager = g_browser_process->profile_manager();
334 if (profile_manager) { 337 if (profile_manager) {
335 std::vector<Profile*> profiles = profile_manager->GetLoadedProfiles(); 338 std::vector<Profile*> profiles = profile_manager->GetLoadedProfiles();
336 // TODO(felt): I believe this for-loop is dead code. Confirm this and 339 // TODO(felt): I believe this for-loop is dead code. Confirm this and
337 // remove in a future CL. See https://codereview.chromium.org/1341533002/ 340 // remove in a future CL. See https://codereview.chromium.org/1341533002/
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after
408 url_request_context_getter_->DisableQuicOnIOThread(); 411 url_request_context_getter_->DisableQuicOnIOThread();
409 } 412 }
410 413
411 const scoped_refptr<SafeBrowsingUIManager>& 414 const scoped_refptr<SafeBrowsingUIManager>&
412 SafeBrowsingService::ui_manager() const { 415 SafeBrowsingService::ui_manager() const {
413 return ui_manager_; 416 return ui_manager_;
414 } 417 }
415 418
416 const scoped_refptr<SafeBrowsingDatabaseManager>& 419 const scoped_refptr<SafeBrowsingDatabaseManager>&
417 SafeBrowsingService::database_manager() const { 420 SafeBrowsingService::database_manager() const {
418 return enabled_v4_only_ ? v4_local_database_manager() : database_manager_; 421 return use_v4_only_ ? v4_local_database_manager() : database_manager_;
419 } 422 }
420 423
421 scoped_refptr<SafeBrowsingNavigationObserverManager> 424 scoped_refptr<SafeBrowsingNavigationObserverManager>
422 SafeBrowsingService::navigation_observer_manager() { 425 SafeBrowsingService::navigation_observer_manager() {
423 return navigation_observer_manager_; 426 return navigation_observer_manager_;
424 } 427 }
425 428
426 SafeBrowsingProtocolManager* SafeBrowsingService::protocol_manager() const { 429 SafeBrowsingProtocolManager* SafeBrowsingService::protocol_manager() const {
427 DCHECK_CURRENTLY_ON(BrowserThread::IO); 430 DCHECK_CURRENTLY_ON(BrowserThread::IO);
428 #if defined(SAFE_BROWSING_DB_LOCAL) 431 #if defined(SAFE_BROWSING_DB_LOCAL)
429 DCHECK(!enabled_v4_only_); 432 DCHECK(!use_v4_only_);
430 return protocol_manager_.get(); 433 return protocol_manager_.get();
431 #else 434 #else
432 return nullptr; 435 return nullptr;
433 #endif 436 #endif
434 } 437 }
435 438
436 SafeBrowsingPingManager* SafeBrowsingService::ping_manager() const { 439 SafeBrowsingPingManager* SafeBrowsingService::ping_manager() const {
437 DCHECK_CURRENTLY_ON(BrowserThread::IO); 440 DCHECK_CURRENTLY_ON(BrowserThread::IO);
438 return ping_manager_.get(); 441 return ping_manager_.get();
439 } 442 }
(...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after
549 #endif // defined(OS_WIN) 552 #endif // defined(OS_WIN)
550 553
551 return client_name; 554 return client_name;
552 } 555 }
553 556
554 // Any tests that create a DatabaseManager that isn't derived from 557 // Any tests that create a DatabaseManager that isn't derived from
555 // LocalSafeBrowsingDatabaseManager should override this to return NULL. 558 // LocalSafeBrowsingDatabaseManager should override this to return NULL.
556 SafeBrowsingProtocolManagerDelegate* 559 SafeBrowsingProtocolManagerDelegate*
557 SafeBrowsingService::GetProtocolManagerDelegate() { 560 SafeBrowsingService::GetProtocolManagerDelegate() {
558 #if defined(SAFE_BROWSING_DB_LOCAL) 561 #if defined(SAFE_BROWSING_DB_LOCAL)
559 DCHECK(!enabled_v4_only_); 562 DCHECK(!use_v4_only_);
560 return static_cast<LocalSafeBrowsingDatabaseManager*>( 563 return static_cast<LocalSafeBrowsingDatabaseManager*>(
561 database_manager_.get()); 564 database_manager_.get());
562 #else 565 #else
563 NOTREACHED(); 566 NOTREACHED();
564 return NULL; 567 return NULL;
565 #endif 568 #endif
566 } 569 }
567 570
568 void SafeBrowsingService::StartOnIOThread( 571 void SafeBrowsingService::StartOnIOThread(
569 net::URLRequestContextGetter* url_request_context_getter) { 572 net::URLRequestContextGetter* url_request_context_getter) {
570 DCHECK_CURRENTLY_ON(BrowserThread::IO); 573 DCHECK_CURRENTLY_ON(BrowserThread::IO);
571 if (enabled_) 574 if (enabled_)
572 return; 575 return;
573 enabled_ = true; 576 enabled_ = true;
574 577
575 SafeBrowsingProtocolConfig config = GetProtocolConfig(); 578 SafeBrowsingProtocolConfig config = GetProtocolConfig();
576 V4ProtocolConfig v4_config = GetV4ProtocolConfig(); 579 V4ProtocolConfig v4_config = GetV4ProtocolConfig();
577 580
578 services_delegate_->StartOnIOThread(url_request_context_getter, v4_config); 581 services_delegate_->StartOnIOThread(url_request_context_getter, v4_config);
579 582
580 #if defined(SAFE_BROWSING_DB_LOCAL) || defined(SAFE_BROWSING_DB_REMOTE) 583 #if defined(SAFE_BROWSING_DB_LOCAL) || defined(SAFE_BROWSING_DB_REMOTE)
581 if (!enabled_v4_only_) { 584 if (!use_v4_only_) {
582 DCHECK(database_manager_.get()); 585 DCHECK(database_manager_.get());
583 database_manager_->StartOnIOThread(url_request_context_getter, v4_config); 586 database_manager_->StartOnIOThread(url_request_context_getter, v4_config);
584 } 587 }
585 #endif 588 #endif
586 589
587 #if defined(SAFE_BROWSING_DB_LOCAL) 590 #if defined(SAFE_BROWSING_DB_LOCAL)
588 if (!enabled_v4_only_) { 591 if (!use_v4_only_) {
589 SafeBrowsingProtocolManagerDelegate* protocol_manager_delegate = 592 SafeBrowsingProtocolManagerDelegate* protocol_manager_delegate =
590 GetProtocolManagerDelegate(); 593 GetProtocolManagerDelegate();
591 if (protocol_manager_delegate) { 594 if (protocol_manager_delegate) {
592 protocol_manager_ = SafeBrowsingProtocolManager::Create( 595 protocol_manager_ = SafeBrowsingProtocolManager::Create(
593 protocol_manager_delegate, url_request_context_getter, config); 596 protocol_manager_delegate, url_request_context_getter, config);
594 protocol_manager_->Initialize(); 597 protocol_manager_->Initialize();
595 } 598 }
596 } 599 }
597 #endif 600 #endif
598 601
599 DCHECK(!ping_manager_); 602 DCHECK(!ping_manager_);
600 ping_manager_ = SafeBrowsingPingManager::Create( 603 ping_manager_ = SafeBrowsingPingManager::Create(
601 url_request_context_getter, config); 604 url_request_context_getter, config);
602 } 605 }
603 606
604 void SafeBrowsingService::StopOnIOThread(bool shutdown) { 607 void SafeBrowsingService::StopOnIOThread(bool shutdown) {
605 DCHECK_CURRENTLY_ON(BrowserThread::IO); 608 DCHECK_CURRENTLY_ON(BrowserThread::IO);
606 609
607 #if defined(SAFE_BROWSING_DB_LOCAL) || defined(SAFE_BROWSING_DB_REMOTE) 610 #if defined(SAFE_BROWSING_DB_LOCAL) || defined(SAFE_BROWSING_DB_REMOTE)
608 if (!enabled_v4_only_) { 611 if (!use_v4_only_) {
609 database_manager_->StopOnIOThread(shutdown); 612 database_manager_->StopOnIOThread(shutdown);
610 } 613 }
611 #endif 614 #endif
612 ui_manager_->StopOnIOThread(shutdown); 615 ui_manager_->StopOnIOThread(shutdown);
613 616
614 services_delegate_->StopOnIOThread(shutdown); 617 services_delegate_->StopOnIOThread(shutdown);
615 618
616 if (enabled_) { 619 if (enabled_) {
617 enabled_ = false; 620 enabled_ = false;
618 621
(...skipping 140 matching lines...) Expand 10 before | Expand all | Expand 10 after
759 ping_manager()->ReportThreatDetails(report); 762 ping_manager()->ReportThreatDetails(report);
760 } 763 }
761 764
762 void SafeBrowsingService::ProcessResourceRequest( 765 void SafeBrowsingService::ProcessResourceRequest(
763 const ResourceRequestInfo& request) { 766 const ResourceRequestInfo& request) {
764 DCHECK_CURRENTLY_ON(BrowserThread::UI); 767 DCHECK_CURRENTLY_ON(BrowserThread::UI);
765 services_delegate_->ProcessResourceRequest(&request); 768 services_delegate_->ProcessResourceRequest(&request);
766 } 769 }
767 770
768 } // namespace safe_browsing 771 } // namespace safe_browsing
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698