Move creation and ownership of ResourceDispatcherHost and PluginService to content. This gives a ...

chrome/browser/browser_process_impl.cc

 // Copyright (c) 2011 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/browser_process_impl.h"
 
 #include <map>
 #include <set>
 #include <vector>
 
@@ skipping 51 matching lines @@
 #include "chrome/common/chrome_switches.h"
 #include "chrome/common/extensions/extension_l10n_util.h"
 #include "chrome/common/extensions/extension_resource.h"
 #include "chrome/common/json_pref_store.h"
 #include "chrome/common/pref_names.h"
 #include "chrome/common/switch_utils.h"
 #include "chrome/common/url_constants.h"
 #include "chrome/installer/util/google_update_constants.h"
 #include "content/browser/browser_child_process_host.h"
 #include "content/browser/child_process_security_policy.h"
-#include "content/browser/download/download_file_manager.h"
 #include "content/browser/download/download_status_updater.h"
 #include "content/browser/download/mhtml_generation_manager.h"
-#include "content/browser/download/save_file_manager.h"
 #include "content/browser/gpu/gpu_process_host_ui_shim.h"
 #include "content/browser/net/browser_online_state_observer.h"
 #include "content/browser/renderer_host/resource_dispatcher_host.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/notification_details.h"
 #include "content/public/browser/plugin_service.h"
 #include "content/public/browser/render_process_host.h"
 #include "content/public/common/url_fetcher.h"
 #include "media/audio/audio_manager.h"
 #include "net/socket/client_socket_pool_manager.h"
@@ skipping 30 matching lines @@
 // How long to wait for the File thread to complete during EndSession, on
 // Linux. We have a timeout here because we're unable to run the UI messageloop
 // and there's some deadlock risk. Our only option is to exit anyway.
 static const int kEndSessionTimeoutSeconds = 10;
 #endif
 
 using content::BrowserThread;
 using content::PluginService;
 
 BrowserProcessImpl::BrowserProcessImpl(const CommandLine& command_line)
-    : created_resource_dispatcher_host_(false),
-      created_metrics_service_(false),
+    : created_metrics_service_(false),
       created_watchdog_thread_(false),
       created_profile_manager_(false),
       created_local_state_(false),
       created_icon_manager_(false),
       created_sidebar_manager_(false),
       created_browser_policy_connector_(false),
       created_notification_ui_manager_(false),
       created_safe_browsing_service_(false),
       module_ref_count_(0),
       did_start_(false),
@@ skipping 13 matching lines @@
       chrome::kExtensionScheme);
 
   extension_event_router_forwarder_ = new ExtensionEventRouterForwarder;
 
   ExtensionTabIdMap::GetInstance()->Init();
 
   online_state_observer_.reset(new BrowserOnlineStateObserver);
 }
 
 BrowserProcessImpl::~BrowserProcessImpl() {
-  // See StartTearDown and PreStopThread functions below, this is where
-  // most destruction happens so that it can be interleaved with threads
-  // going away.
-
   // Wait for the pending print jobs to finish.
   print_job_manager_->OnQuit();
   print_job_manager_.reset();
 
   tracked_objects::ThreadData::EnsureCleanupWasCalled(4);
 
+#if defined(OS_CHROMEOS)
+  chromeos::WebSocketProxyController::Shutdown();
+#endif
+
   g_browser_process = NULL;
 }
 
 void BrowserProcessImpl::StartTearDown() {
   // Delete the AutomationProviderList before NotificationService,
   // since it may try to unregister notifications
   // Both NotificationService and AutomationProvider are singleton instances in
   // the BrowserProcess. Since AutomationProvider may have some active
   // notification observers, it is essential that it gets destroyed before the
   // NotificationService. NotificationService won't be destroyed until after
@@ skipping 34 matching lines @@
   // to be cancelled too. Remove this when DefaultRequestContext goes away.
   BrowserThread::PostTask(BrowserThread::IO, FROM_HERE,
                           base::Bind(&content::URLFetcher::CancelAll));
 
   // Need to clear profiles (download managers) before the io_thread_.
   profile_manager_.reset();
 
   // Debugger must be cleaned up before IO thread and NotificationService.
   remote_debugging_server_.reset();
 
-  if (resource_dispatcher_host_.get()) {
-    // Cancel pending requests and prevent new requests.
-    resource_dispatcher_host()->Shutdown();
-  }
-
   ExtensionTabIdMap::GetInstance()->Shutdown();
 
   // The policy providers managed by |browser_policy_connector_| need to shut
   // down while the IO and FILE threads are still alive.
   browser_policy_connector_.reset();
 
   // Destroying the GpuProcessHostUIShims on the UI thread posts a task to
   // delete related objects on the GPU thread. This must be done before
   // stopping the GPU thread. The GPU thread will close IPC channels to renderer
   // processes so this has to happen before stopping the IO thread.
   GpuProcessHostUIShim::DestroyAll();
 
   // Stop the watchdog thread before stopping other threads.
   watchdog_thread_.reset();
 }
 
-void BrowserProcessImpl::PreStartThread(BrowserThread::ID thread_id) {
-  switch (thread_id) {
-    case BrowserThread::IO:
-      CreateIOThreadState();
-      break;
+void BrowserProcessImpl::PostDestroyThreads() {
+  // With the file_thread_ flushed, we can release any icon resources.
+  icon_manager_.reset();
 
-    default:
-      break;
-  }
-}
-
-void BrowserProcessImpl::PostStartThread(BrowserThread::ID thread_id) {
-}
-
-void BrowserProcessImpl::PreStopThread(BrowserThread::ID thread_id) {
-  switch (thread_id) {
-#if defined(OS_CHROMEOS)
-    case BrowserThread::WEB_SOCKET_PROXY:
-      chromeos::WebSocketProxyController::Shutdown();
-      break;
-#endif
-    case BrowserThread::FILE:
-      // Clean up state that lives on or uses the file_thread_ before
-      // it goes away.
-      if (resource_dispatcher_host_.get()) {
-        resource_dispatcher_host()->download_file_manager()->Shutdown();
-        resource_dispatcher_host()->save_file_manager()->Shutdown();
-      }
-      break;
-    case BrowserThread::WEBKIT_DEPRECATED:
-      // Need to destroy ResourceDispatcherHost before PluginService
-      // and SafeBrowsingService, since it caches a pointer to
-      // it.
-      resource_dispatcher_host_.reset();
-      break;
-    default:
-      break;
-  }
-}
-
-void BrowserProcessImpl::PostStopThread(BrowserThread::ID thread_id) {
-  switch (thread_id) {
-    case BrowserThread::FILE:
-      // With the file_thread_ flushed, we can release any icon resources.
-      icon_manager_.reset();
-      break;
-    case BrowserThread::IO:
-      // Reset associated state right after actual thread is stopped,
-      // as io_thread_.global_ cleanup happens in CleanUp on the IO
-      // thread, i.e. as the thread exits its message loop.
-      //
-      // This is important also because in various places, the
-      // IOThread object being NULL is considered synonymous with the
-      // IO thread having stopped.
-      io_thread_.reset();
-      break;
-    default:
-      break;
-  }
+  // Reset associated state right after actual thread is stopped,
+  // as io_thread_.global_ cleanup happens in CleanUp on the IO
+  // thread, i.e. as the thread exits its message loop.
+  //
+  // This is important also because in various places, the
+  // IOThread object being NULL is considered synonymous with the
+  // IO thread having stopped.
+  io_thread_.reset();
 }
 
 #if defined(OS_WIN)
 // Send a QuitTask to the given MessageLoop when the (file) thread has processed
 // our (other) recent requests (to save preferences).
 // Change the boolean so that the receiving thread will know that we did indeed
 // send the QuitTask that terminated the message loop.
 static void PostQuit(MessageLoop* message_loop) {
   g_end_session_file_thread_has_completed = true;
   message_loop->PostTask(FROM_HERE, MessageLoop::QuitClosure());
@@ skipping 78 matching lines @@
     ++quits_received;
   } while (!g_end_session_file_thread_has_completed);
   // If we did get extra quits, then we should re-post them to the message loop.
   while (--quits_received > 0)
     MessageLoop::current()->PostTask(FROM_HERE, MessageLoop::QuitClosure());
 #else
   NOTIMPLEMENTED();
 #endif
 }
 
-ResourceDispatcherHost* BrowserProcessImpl::resource_dispatcher_host() {
-  DCHECK(CalledOnValidThread());
-  if (!created_resource_dispatcher_host_)
-    CreateResourceDispatcherHost();
-  return resource_dispatcher_host_.get();
-}
-
 MetricsService* BrowserProcessImpl::metrics_service() {
   DCHECK(CalledOnValidThread());
   if (!created_metrics_service_)
     CreateMetricsService();
   return metrics_service_.get();
 }
 
 IOThread* BrowserProcessImpl::io_thread() {
   DCHECK(CalledOnValidThread());
   DCHECK(io_thread_.get());
@@ skipping 285 matching lines @@
 }
 
 AudioManager* BrowserProcessImpl::audio_manager() {
   DCHECK(CalledOnValidThread());
   if (!audio_manager_)
     audio_manager_ = AudioManager::Create();
 
   return audio_manager_;
 }
 
-void BrowserProcessImpl::CreateResourceDispatcherHost() {
-  DCHECK(!created_resource_dispatcher_host_ &&
-         resource_dispatcher_host_.get() == NULL);
-  created_resource_dispatcher_host_ = true;
-
+void BrowserProcessImpl::ResourceDispatcherHostCreated() {
   // UserScriptListener and NetworkDelayListener will delete themselves.
-  ResourceQueue::DelegateSet resource_queue_delegates;
-  resource_queue_delegates.insert(new UserScriptListener());
-  resource_queue_delegates.insert(new NetworkDelayListener());
-
-  resource_dispatcher_host_.reset(
-      new ResourceDispatcherHost(resource_queue_delegates));
-  resource_dispatcher_host_->Initialize();
+  ResourceDispatcherHost* rdh = ResourceDispatcherHost::Get();
+  rdh->AddResourceQueueDelegate(new UserScriptListener());
+  rdh->AddResourceQueueDelegate(new NetworkDelayListener());
 
   resource_dispatcher_host_delegate_.reset(
-      new ChromeResourceDispatcherHostDelegate(resource_dispatcher_host_.get(),
-                                               prerender_tracker()));
-  resource_dispatcher_host_->set_delegate(
-      resource_dispatcher_host_delegate_.get());
+      new ChromeResourceDispatcherHostDelegate(rdh, prerender_tracker()));
+  rdh->set_delegate(resource_dispatcher_host_delegate_.get());
 
   pref_change_registrar_.Add(prefs::kAllowCrossOriginAuthPrompt, this);
   ApplyAllowCrossOriginAuthPromptPolicy();
 }
 
 void BrowserProcessImpl::CreateMetricsService() {
   DCHECK(!created_metrics_service_ && metrics_service_.get() == NULL);
   created_metrics_service_ = true;
 
   metrics_service_.reset(new MetricsService);
 }
 
-void BrowserProcessImpl::CreateIOThreadState() {
-  // Prior to any processing happening on the io thread, we create the
-  // plugin service as it is predominantly used from the io thread,
-  // but must be created on the main thread. The service ctor is
-  // inexpensive and does not invoke the io_thread() accessor.
-  PluginService* plugin_service = PluginService::GetInstance();
-  plugin_service->Init();
-  plugin_service->SetFilter(ChromePluginServiceFilter::GetInstance());
-  plugin_service->StartWatchingPlugins();
-
-  // Register the internal Flash if available.
-  FilePath path;
-  if (!CommandLine::ForCurrentProcess()->HasSwitch(
-          switches::kDisableInternalFlash) &&
-      PathService::Get(chrome::FILE_FLASH_PLUGIN, &path)) {
-    plugin_service->AddExtraPluginPath(path);
-  }
-
-#if defined(OS_POSIX)
-  // Also find plugins in a user-specific plugins dir,
-  // e.g. ~/.config/chromium/Plugins.
-  FilePath user_data_dir;
-  if (PathService::Get(chrome::DIR_USER_DATA, &user_data_dir)) {
-    plugin_service->AddExtraPluginPath(user_data_dir.Append("Plugins"));
-  }
-#endif
-
-  scoped_ptr<IOThread> thread(new IOThread(
-      local_state(), net_log_.get(), extension_event_router_forwarder_.get()));
-  io_thread_.swap(thread);
-}
-
 void BrowserProcessImpl::CreateWatchdogThread() {
   DCHECK(!created_watchdog_thread_ && watchdog_thread_.get() == NULL);
   created_watchdog_thread_ = true;
 
   scoped_ptr<WatchDogThread> thread(new WatchDogThread());
   if (!thread->Start())
     return;
   watchdog_thread_.swap(thread);
 }
 
@@ skipping 46 matching lines @@
 
   // This is observed by ChildProcessSecurityPolicy, which lives in content/
   // though, so it can't register itself.
   local_state_->RegisterListPref(prefs::kDisabledSchemes);
   pref_change_registrar_.Add(prefs::kDisabledSchemes, this);
   ApplyDisabledSchemesPolicy();
 
   local_state_->RegisterBooleanPref(prefs::kAllowCrossOriginAuthPrompt, false);
 }
 
+void BrowserProcessImpl::PreCreateThreads() {
+  io_thread_.reset(new IOThread(
+      local_state(), net_log_.get(), extension_event_router_forwarder_.get()));
+}
+
 void BrowserProcessImpl::PreMainMessageLoopRun() {
+  PluginService* plugin_service = PluginService::GetInstance();
+  plugin_service->SetFilter(ChromePluginServiceFilter::GetInstance());
+  plugin_service->StartWatchingPlugins();
+
+  // Register the internal Flash if available.
+  FilePath path;
+  if (!CommandLine::ForCurrentProcess()->HasSwitch(
+          switches::kDisableInternalFlash) &&
+      PathService::Get(chrome::FILE_FLASH_PLUGIN, &path)) {
+    plugin_service->AddExtraPluginPath(path);
+  }
+
+#if defined(OS_POSIX)
+  // Also find plugins in a user-specific plugins dir,
+  // e.g. ~/.config/chromium/Plugins.
+  FilePath user_data_dir;
+  if (PathService::Get(chrome::DIR_USER_DATA, &user_data_dir)) {
+    plugin_service->AddExtraPluginPath(user_data_dir.Append("Plugins"));
+  }
+#endif
+
   if (local_state_->IsManagedPreference(prefs::kDefaultBrowserSettingEnabled))
     ApplyDefaultBrowserPolicy();
 }
 
 void BrowserProcessImpl::CreateIconManager() {
   DCHECK(!created_icon_manager_ && icon_manager_.get() == NULL);
   created_icon_manager_ = true;
   icon_manager_.reset(new IconManager);
 }
 
@@ skipping 75 matching lines @@
 void BrowserProcessImpl::ApplyDefaultBrowserPolicy() {
   if (local_state_->GetBoolean(prefs::kDefaultBrowserSettingEnabled)) {
     scoped_refptr<ShellIntegration::DefaultWebClientWorker>
         set_browser_worker = new ShellIntegration::DefaultBrowserWorker(NULL);
     set_browser_worker->StartSetAsDefault();
   }
 }
 
 void BrowserProcessImpl::ApplyAllowCrossOriginAuthPromptPolicy() {
   bool value = local_state()->GetBoolean(prefs::kAllowCrossOriginAuthPrompt);
-  resource_dispatcher_host()->set_allow_cross_origin_auth_prompt(value);
+  ResourceDispatcherHost::Get()->set_allow_cross_origin_auth_prompt(value);
 }
 
 // Mac is currently not supported.
 #if (defined(OS_WIN) || defined(OS_LINUX)) && !defined(OS_CHROMEOS)
 
 bool BrowserProcessImpl::CanAutorestartForUpdate() const {
   // Check if browser is in the background and if it needs to be restarted to
   // apply a pending update.
   return BrowserList::size() == 0 && BrowserList::WillKeepAlive() &&
          upgrade_util::IsUpdatePendingRestart();
@@ skipping 39 matching lines @@
 }
 
 void BrowserProcessImpl::OnAutoupdateTimer() {
   if (CanAutorestartForUpdate()) {
     DLOG(WARNING) << "Detected update.  Restarting browser.";
     RestartBackgroundInstance();
   }
 }
 
 #endif  // (defined(OS_WIN) || defined(OS_LINUX)) && !defined(OS_CHROMEOS)