Respect QuicAllowed policy for new streams

chrome/browser/safe_browsing/safe_browsing_service.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.
 
 #include "chrome/browser/safe_browsing/safe_browsing_service.h"
 
 #include <stddef.h>
 
 #include <vector>
 
@@ skipping 121 matching lines @@
 
   // Implementation for net::UrlRequestContextGetter.
   net::URLRequestContext* GetURLRequestContext() override;
   scoped_refptr<base::SingleThreadTaskRunner> GetNetworkTaskRunner()
       const override;
 
   // Shuts down any pending requests using the getter, and sets |shut_down_| to
   // true.
   void ServiceShuttingDown();
 
+  void SetQuicEnabledOnIOThread(bool quic_enabled);
+
  protected:
   ~SafeBrowsingURLRequestContextGetter() override;
 
  private:
   bool shut_down_;
 
   scoped_refptr<net::URLRequestContextGetter> system_context_getter_;
 
   std::unique_ptr<net::CookieStore> safe_browsing_cookie_store_;
 
@@ skipping 80 matching lines @@
 }
 
 void SafeBrowsingURLRequestContextGetter::ServiceShuttingDown() {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 
   shut_down_ = true;
   URLRequestContextGetter::NotifyContextShuttingDown();
   safe_browsing_request_context_.reset();
 }
 
+void SafeBrowsingURLRequestContextGetter::SetQuicEnabledOnIOThread(
+    bool quic_enabled) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  if (!http_network_session_)
+    return;
+
+  http_network_session_->SetQuicEnabled(quic_enabled);
+}
+
 SafeBrowsingURLRequestContextGetter::~SafeBrowsingURLRequestContextGetter() {}
 
 // static
 SafeBrowsingServiceFactory* SafeBrowsingService::factory_ = NULL;
 
 // The default SafeBrowsingServiceFactory.  Global, made a singleton so we
 // don't leak it.
 class SafeBrowsingServiceFactoryImpl : public SafeBrowsingServiceFactory {
  public:
   SafeBrowsingService* CreateSafeBrowsingService() override {
@@ skipping 130 matching lines @@
 #else
   return false;
 #endif
 }
 
 net::URLRequestContextGetter* SafeBrowsingService::url_request_context() {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   return url_request_context_getter_.get();
 }
 
+void SafeBrowsingService::UpdateNetParams(
+    NetPrefObserver::NetParamsChange net_params_change) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      base::Bind(&SafeBrowsingURLRequestContextGetter::SetQuicEnabledOnIOThread,
+                 url_request_context_getter_,
+                 net_params_change.quic_enabled_new));
+}
+
 const scoped_refptr<SafeBrowsingUIManager>&
 SafeBrowsingService::ui_manager() const {
   return ui_manager_;
 }
 
 const scoped_refptr<SafeBrowsingDatabaseManager>&
 SafeBrowsingService::database_manager() const {
   return enabled_v4_only_ ? v4_local_database_manager() : database_manager_;
 }
 
@@ skipping 327 matching lines @@
     ping_manager()->ReportThreatDetails(report);
 }
 
 void SafeBrowsingService::ProcessResourceRequest(
     const ResourceRequestInfo& request) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   services_delegate_->ProcessResourceRequest(&request);
 }
 
 }  // namespace safe_browsing