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 UpdateNetParamsOnIOThread(
+      net::HttpNetworkSession::ParamsUpdate params_update);
+
  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::UpdateNetParamsOnIOThread(
+    net::HttpNetworkSession::ParamsUpdate params_update) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  if (http_network_session_)
+    http_network_session_->UpdateParams(params_update);
+}
+
 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 134 matching lines @@
   return false;
 #endif
 }
 
 scoped_refptr<net::URLRequestContextGetter>
 SafeBrowsingService::url_request_context() {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   return url_request_context_getter_;
 }
 
+void SafeBrowsingService::UpdateNetParams(
+    net::HttpNetworkSession::ParamsUpdate params_update) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      base::Bind(
+          &SafeBrowsingURLRequestContextGetter::UpdateNetParamsOnIOThread,
+          base::RetainedRef(url_request_context_getter_), params_update));
+}
+
+// TODO(ntfschr): componentize this once BaseSafeBrowsingUIManager contains a
+// SafeBrowsingService
 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 334 matching lines @@
     ping_manager()->ReportThreatDetails(report);
 }
 
 void SafeBrowsingService::ProcessResourceRequest(
     const ResourceRequestInfo& request) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   services_delegate_->ProcessResourceRequest(&request);
 }
 
 }  // namespace safe_browsing