Switch the first thread in a child process to be the main thread...

chrome/plugin/plugin_thread.cc

Index: chrome/plugin/plugin_thread.cc
===================================================================
--- chrome/plugin/plugin_thread.cc	(revision 21342)
+++ chrome/plugin/plugin_thread.cc	(working copy)
@@ -6,11 +6,6 @@
 
 #include "build/build_config.h"
 
-#if defined(OS_WIN)
-#include <windows.h>
-#include <objbase.h>
-#endif
-
 #include "base/command_line.h"
 #include "base/lazy_instance.h"
 #include "base/process_util.h"
@@ -18,7 +13,6 @@
 #include "chrome/common/child_process.h"
 #include "chrome/common/chrome_plugin_lib.h"
 #include "chrome/common/chrome_switches.h"
-#include "chrome/common/notification_service.h"
 #include "chrome/common/plugin_messages.h"
 #include "chrome/common/render_messages.h"
 #include "chrome/plugin/chrome_plugin_host.h"
@@ -32,27 +26,10 @@
     base::LINKER_INITIALIZED);
 
 PluginThread::PluginThread()
-    : ChildThread(base::Thread::Options(MessageLoop::TYPE_UI, 0)),
-      preloaded_plugin_module_(NULL) {
+    : preloaded_plugin_module_(NULL) {
   plugin_path_ = FilePath::FromWStringHack(
       CommandLine::ForCurrentProcess()->GetSwitchValue(switches::kPluginPath));
-}
 
-PluginThread::~PluginThread() {
-}
-
-PluginThread* PluginThread::current() {
-  return lazy_tls.Pointer()->Get();
-}
-
-void PluginThread::OnControlMessageReceived(const IPC::Message& msg) {
-  IPC_BEGIN_MESSAGE_MAP(PluginThread, msg)
-    IPC_MESSAGE_HANDLER(PluginProcessMsg_CreateChannel, OnCreateChannel)
-    IPC_MESSAGE_HANDLER(PluginProcessMsg_PluginMessage, OnPluginMessage)
-  IPC_END_MESSAGE_MAP()
-}
-
-void PluginThread::Init() {
   lazy_tls.Pointer()->Set(this);
 #if defined(OS_LINUX)
   {
@@ -75,15 +52,9 @@
     }
   }
 #endif
-  ChildThread::Init();
 
   PatchNPNFunctions();
-#if defined(OS_WIN)
-  CoInitialize(NULL);
-#endif
 
-  notification_service_.reset(new NotificationService);
-
   // Preload the library to avoid loading, unloading then reloading
   preloaded_plugin_module_ = base::LoadNativeLibrary(plugin_path_);
 
@@ -100,7 +71,7 @@
   message_loop()->set_exception_restoration(true);
 }
 
-void PluginThread::CleanUp() {
+PluginThread::~PluginThread() {
   if (preloaded_plugin_module_) {
     base::UnloadNativeLibrary(preloaded_plugin_module_);
     preloaded_plugin_module_ = NULL;
@@ -108,26 +79,29 @@
   PluginChannelBase::CleanupChannels();
   NPAPI::PluginLib::UnloadAllPlugins();
   ChromePluginLib::UnloadAllPlugins();
-  notification_service_.reset();
-#if defined(OS_WIN)
-  CoUninitialize();
-#endif
 
   if (webkit_glue::ShouldForcefullyTerminatePluginProcess())
     base::KillProcess(base::GetCurrentProcessHandle(), 0, /* wait= */ false);
 
-  // Call this last because it deletes the ResourceDispatcher, which is used
-  // in some of the above cleanup.
-  // See http://code.google.com/p/chromium/issues/detail?id=8980
-  ChildThread::CleanUp();
   lazy_tls.Pointer()->Set(NULL);
 }
 
+PluginThread* PluginThread::current() {
+  return lazy_tls.Pointer()->Get();
+}
+
+void PluginThread::OnControlMessageReceived(const IPC::Message& msg) {
+  IPC_BEGIN_MESSAGE_MAP(PluginThread, msg)
+    IPC_MESSAGE_HANDLER(PluginProcessMsg_CreateChannel, OnCreateChannel)
+    IPC_MESSAGE_HANDLER(PluginProcessMsg_PluginMessage, OnPluginMessage)
+  IPC_END_MESSAGE_MAP()
+}
+
 void PluginThread::OnCreateChannel(
     int process_id,
     bool off_the_record) {
-  scoped_refptr<PluginChannel> channel =
-      PluginChannel::GetPluginChannel(process_id, owner_loop());
+  scoped_refptr<PluginChannel> channel = PluginChannel::GetPluginChannel(
+      process_id, ChildProcess::current()->io_message_loop());
   IPC::ChannelHandle channel_handle;
   if (channel.get()) {
     channel_handle.name = channel->channel_name();