Speculatively launch Service Workers on mouse/touch events. [3/5]

chrome/browser/renderer_host/chrome_render_message_filter.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_render_message_filter.h"
 
 #include <stdint.h>
 
 #include <string>
 
@@ skipping 13 matching lines @@
 #include "chrome/common/render_messages.h"
 #include "components/content_settings/content/common/content_settings_messages.h"
 #include "components/content_settings/core/browser/cookie_settings.h"
 #include "components/network_hints/common/network_hints_common.h"
 #include "components/network_hints/common/network_hints_messages.h"
 #include "components/rappor/rappor_service.h"
 #include "components/rappor/rappor_utils.h"
 #include "components/web_cache/browser/web_cache_manager.h"
 #include "content/public/browser/notification_service.h"
 #include "content/public/browser/render_process_host.h"
+#include "content/public/browser/service_worker_context.h"
 
 #if defined(ENABLE_EXTENSIONS)
 #include "extensions/browser/guest_view/web_view/web_view_permission_helper.h"
 #include "extensions/browser/guest_view/web_view/web_view_renderer_state.h"
 #include "extensions/common/manifest_handlers/default_locale_handler.h"
 #endif
 
 using content::BrowserThread;
 
 namespace {
 
 const uint32_t kFilteredMessageClasses[] = {
     ChromeMsgStart, ContentSettingsMsgStart, NetworkHintsMsgStart,
 };
 
+void DidStartServiceWorkerForNavigationHint(bool success) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+}
+
 }  // namespace
 
-ChromeRenderMessageFilter::ChromeRenderMessageFilter(int render_process_id,
-                                                     Profile* profile)
+ChromeRenderMessageFilter::ChromeRenderMessageFilter(
+    int render_process_id,
+    Profile* profile,
+    content::ServiceWorkerContext* service_worker_context)
     : BrowserMessageFilter(kFilteredMessageClasses,
                            arraysize(kFilteredMessageClasses)),
       render_process_id_(render_process_id),
       profile_(profile),
       predictor_(profile_->GetNetworkPredictor()),
-      cookie_settings_(CookieSettingsFactory::GetForProfile(profile)) {
-}
+      cookie_settings_(CookieSettingsFactory::GetForProfile(profile)),
+      service_worker_context_(service_worker_context) {}
 
 ChromeRenderMessageFilter::~ChromeRenderMessageFilter() {
 }
 
 bool ChromeRenderMessageFilter::OnMessageReceived(const IPC::Message& message) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(ChromeRenderMessageFilter, message)
     IPC_MESSAGE_HANDLER(NetworkHintsMsg_DNSPrefetch, OnDnsPrefetch)
     IPC_MESSAGE_HANDLER(NetworkHintsMsg_Preconnect, OnPreconnect)
     IPC_MESSAGE_HANDLER(NetworkHintsMsg_NavigationHint, OnNavigationHint)
@@ skipping 17 matching lines @@
     IPC_MESSAGE_HANDLER(ChromeViewHostMsg_RecordRapporURL, OnRecordRapporURL)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
 
   return handled;
 }
 
 void ChromeRenderMessageFilter::OverrideThreadForMessage(
     const IPC::Message& message, BrowserThread::ID* thread) {
   switch (message.type()) {
+    case NetworkHintsMsg_NavigationHint::ID:
 #if defined(ENABLE_PLUGINS)
     case ChromeViewHostMsg_IsCrashReportingEnabled::ID:
 #endif
     case ChromeViewHostMsg_UpdatedCacheStats::ID:
     case ChromeViewHostMsg_RecordRappor::ID:
     case ChromeViewHostMsg_RecordRapporURL::ID:
       *thread = BrowserThread::UI;
       break;
     default:
       break;
@@ skipping 20 matching lines @@
                               chrome_browser_net::UrlInfo::EARLY_LOAD_MOTIVATED,
                               allow_credentials, count);
   }
 }
 
 void ChromeRenderMessageFilter::OnNavigationHint(
     const GURL& url,
     blink::WebNavigationHintType type) {
   // TODO(horo): We don't need to have this method in //chrome. Move it to
   // //content while mojoifing network_hints. (crbug.com/610750)
-  // TODO(horo): Implement this.
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  service_worker_context_->StartServiceWorkerForNavigationHint(
+      url, type, render_process_id_,
+      base::Bind(&DidStartServiceWorkerForNavigationHint));
 }
 
 void ChromeRenderMessageFilter::OnUpdatedCacheStats(
     uint64_t min_dead_capacity,
     uint64_t max_dead_capacity,
     uint64_t capacity,
     uint64_t live_size,
     uint64_t dead_size) {
   web_cache::WebCacheManager::GetInstance()->ObserveStats(
       render_process_id_, min_dead_capacity, max_dead_capacity, capacity,
@@ skipping 212 matching lines @@
   rappor::SampleString(g_browser_process->rappor_service(), metric,
                        rappor::ETLD_PLUS_ONE_RAPPOR_TYPE, sample);
 }
 
 void ChromeRenderMessageFilter::OnRecordRapporURL(const std::string& metric,
                                                   const GURL& sample) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   rappor::SampleDomainAndRegistryFromGURL(g_browser_process->rappor_service(),
                                           metric, sample);
 }