Async Safe Browsing check, on mobile

chrome/browser/renderer_host/data_reduction_proxy_resource_throttle_android.cc

 // Copyright 2015 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/renderer_host/data_reduction_proxy_resource_throttle_android.h"
 
 #include "base/logging.h"
 #include "chrome/browser/browser_process.h"
 #include "chrome/browser/prerender/prerender_contents.h"
 #include "chrome/browser/renderer_host/safe_browsing_resource_throttle_factory.h"
@@ skipping 25 matching lines @@
 const char* DataReductionProxyResourceThrottle::kUnsafeUrlProceedHeader =
       "X-Unsafe-Url-Proceed";
 
 ResourceThrottle*
 DataReductionProxyResourceThrottleFactory::CreateResourceThrottle(
     net::URLRequest* request,
     content::ResourceContext* resource_context,
     content::ResourceType resource_type,
     SafeBrowsingService* service) {
 #if defined(SAFE_BROWSING_DB_LOCAL) || defined(SAFE_BROWSING_DB_REMOTE)
+  // Send requests through Safe Browsing if we can't process them.
   ProfileIOData* io_data = ProfileIOData::FromResourceContext(resource_context);
   if (io_data->IsOffTheRecord() || !io_data->IsDataReductionProxyEnabled() ||
-      request->url().SchemeIsSecure())
-    return new SafeBrowsingResourceThrottle(request, resource_type, service);
+      request->url().SchemeIsSecure()) {
+    // *this is already registered as the SafeBrowsingResourceThrottleFactory,
+    // so need to bypass that and use its base implementation.
+    return SafeBrowsingResourceThrottleFactory::CreateWithoutRegisteredFactory(
+        request, resource_type, service);
+  }
 #endif
   return new DataReductionProxyResourceThrottle(request, resource_type,
                                                 service);
 }
 
 DataReductionProxyResourceThrottle::DataReductionProxyResourceThrottle(
     net::URLRequest* request,
     content::ResourceType resource_type,
     SafeBrowsingService* safe_browsing)
     : state_(STATE_NONE),
@@ skipping 112 matching lines @@
   return result;
 }
 
 void DataReductionProxyResourceThrottle::ResumeRequest() {
   CHECK(state_ == STATE_NONE);
 
   // Inject the header before resuming the request.
   request_->SetExtraRequestHeaderByName(kUnsafeUrlProceedHeader, "1", true);
   controller()->Resume();
 }