Component updater on-demand logic with ResourceThrottle

chrome/browser/renderer_host/chrome_resource_dispatcher_host_delegate.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/renderer_host/chrome_resource_dispatcher_host_delegate.h"
 
 #include <string>
 
 #include "base/base64.h"
 #include "base/logging.h"
 #include "base/metrics/histogram.h"
+#include "base/strings/string_util.h"
 #include "chrome/browser/browser_process.h"
 #include "chrome/browser/chrome_notification_types.h"
+#include "chrome/browser/component_updater/component_updater_service.h"
 #include "chrome/browser/content_settings/host_content_settings_map.h"
 #include "chrome/browser/download/download_request_limiter.h"
 #include "chrome/browser/download/download_resource_throttle.h"
 #include "chrome/browser/extensions/api/streams_private/streams_private_api.h"
 #include "chrome/browser/extensions/extension_info_map.h"
 #include "chrome/browser/extensions/extension_renderer_state.h"
 #include "chrome/browser/extensions/user_script_listener.h"
 #include "chrome/browser/external_protocol/external_protocol_handler.h"
 #include "chrome/browser/google/google_util.h"
 #include "chrome/browser/metrics/variations/variations_http_header_provider.h"
@@ skipping 160 matching lines @@
   } else if (url.SchemeIs("chrome-extension")) {
     ReportPrerenderSchemeCancelReason(
         PRERENDER_SCHEME_CANCEL_REASON_CHROME_EXTENSION);
   } else if (url.SchemeIs("about")) {
     ReportPrerenderSchemeCancelReason(PRERENDER_SCHEME_CANCEL_REASON_ABOUT);
   } else {
     ReportPrerenderSchemeCancelReason(PRERENDER_SCHEME_CANCEL_REASON_UNKNOWN);
   }
 }
 
+void AppendComponentUpaterThrottles(
+    net::URLRequest* request,
+    content::ResourceContext* resource_context,
+    ResourceType::Type resource_type,
+    ScopedVector<content::ResourceThrottle>* throttles) {
+
+  char* crx_id = NULL;
+
+  // Each component can go bananas here with custom checks. Here is an
+  // example of pNaCL doing a custom check.
+  if (resource_type == ResourceType::OBJECT) {
+    if (EndsWith(request->url().ExtractFileName(), ".pexe", false))
+      crx_id = "hnimpnehoodheedghdeeijklkeaacbdc";

[darin (slow to review), 2013/10/03 21:31:43]

we probably want to base this on mime type instead of file extension. it is
possible for the file extension to be anything. the mime type is what matters.

That said, the approach you are taking nicely avoids the problem of the TCP
socket stream being left hanging for a long time. Hmm...

Perhaps we can get a more clear signal that it is NaCl requesting a PEXE.

[jvoung (off chromium), 2013/10/09 17:05:22]

Separately in a mail thread, I suggested adding something to the request
headers. E.g., could we make the NaCl pexe URLloader set "Accept:
application/x-pnacl" in the request header?

Darin, is that the appropriate use of "Accept:" ?

What is the issue about having the TCP socket stream being left hanging for a
long time?  Is it that if we try to get something based on a *response* we will
have started the stream, and that will be left hanging, while if we check
something that doesn't require a response, we won't have started the stream yet?

[cpu_(ooo_6.6-7.5), 2013/10/20 23:27:25]

Yeah, a special header sounds nice to me.
The server might close the socket or otherwise time out the request.

+  }
+
+  if (crx_id) {
+    ComponentUpdateService* cus = g_browser_process->component_updater();
+    throttles->push_back(cus->GetResourceThrottle(request, crx_id));
+  }
+}
+
 }  // end namespace
 
 ChromeResourceDispatcherHostDelegate::ChromeResourceDispatcherHostDelegate(
     prerender::PrerenderTracker* prerender_tracker)
     : download_request_limiter_(g_browser_process->download_request_limiter()),
       safe_browsing_(g_browser_process->safe_browsing_service()),
       user_script_listener_(new extensions::UserScriptListener()),
       prerender_tracker_(prerender_tracker) {
 }
 
@@ skipping 106 matching lines @@
   }
 
 #if defined(ENABLE_ONE_CLICK_SIGNIN)
   AppendChromeSyncGaiaHeader(request, resource_context);
 #endif
 
   AppendStandardResourceThrottles(request,
                                   resource_context,
                                   resource_type,
                                   throttles);
+  if (!is_prerendering) {
+    AppendComponentUpaterThrottles(request,
+                                   resource_context,
+                                   resource_type,
+                                   throttles);
+  }
 
   if (io_data->resource_prefetch_predictor_observer()) {
     io_data->resource_prefetch_predictor_observer()->OnRequestStarted(
         request, resource_type, child_id, route_id);
   }
 }
 
 void ChromeResourceDispatcherHostDelegate::WillTransferRequestToNewProcess(
     int old_child_id,
     int old_route_id,
@@ skipping 324 matching lines @@
   if (!prerender::PrerenderManager::DoesURLHaveValidScheme(redirect_url) &&
       ResourceRequestInfo::ForRequest(request)->GetAssociatedRenderView(
           &child_id, &route_id) &&
       prerender_tracker_->IsPrerenderingOnIOThread(child_id, route_id) &&
       prerender_tracker_->TryCancel(
           child_id, route_id, prerender::FINAL_STATUS_UNSUPPORTED_SCHEME)) {
     ReportUnsupportedPrerenderScheme(redirect_url);
     request->Cancel();
   }
 }