Switch IPC::ChannelProxy to use MessageLoopProxy instead of MessageLoop. This allows us to remov...

chrome/browser/service/service_process_control.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/service/service_process_control.h"
 
 #include "base/command_line.h"
 #include "base/file_path.h"
 #include "base/process_util.h"
 #include "base/stl_util-inl.h"
 #include "base/threading/thread.h"
 #include "base/threading/thread_restrictions.h"
 #include "chrome/browser/browser_process.h"
-#include "chrome/browser/io_thread.h"
 #include "chrome/browser/upgrade_detector.h"
 #include "chrome/common/chrome_switches.h"
 #include "chrome/common/service_messages.h"
 #include "chrome/common/service_process_util.h"
 #include "content/browser/browser_thread.h"
 #include "content/common/child_process_host.h"
 #include "content/common/notification_service.h"
 #include "ui/base/ui_base_switches.h"
 
 
@@ skipping 11 matching lines @@
 void ServiceProcessControl::ConnectInternal() {
   // If the channel has already been established then we run the task
   // and return.
   if (channel_.get()) {
     RunConnectDoneTasks();
     return;
   }
 
   // Actually going to connect.
   VLOG(1) << "Connecting to Service Process IPC Server";
-  // Run the IPC channel on the shared IO thread.
-  base::Thread* io_thread = g_browser_process->io_thread();
 
   // TODO(hclam): Handle error connecting to channel.
   const IPC::ChannelHandle channel_id = GetServiceProcessChannel();
-  channel_.reset(
-      new IPC::SyncChannel(channel_id, IPC::Channel::MODE_NAMED_CLIENT, this,
-                           io_thread->message_loop(), true,
-                           g_browser_process->shutdown_event()));
+  channel_.reset(new IPC::SyncChannel(
+      channel_id, IPC::Channel::MODE_NAMED_CLIENT, this,
+      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO), true,
+      g_browser_process->shutdown_event()));
 }
 
 void ServiceProcessControl::RunConnectDoneTasks() {
   // The tasks executed here may add more tasks to the vector. So copy
   // them to the stack before executing them. This way recursion is
   // avoided.
   TaskList tasks;
   tasks.swap(connect_done_tasks_);
   RunAllTasksHelper(&tasks);
   DCHECK(tasks.empty());
@@ skipping 294 matching lines @@
   if (base::LaunchApp(*cmd_line_, false, true, NULL)) {
     BrowserThread::PostTask(BrowserThread::IO, FROM_HERE,
                             NewRunnableMethod(this,
                                               &Launcher::DoDetectLaunched));
   } else {
     BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
                             NewRunnableMethod(this, &Launcher::Notify));
   }
 }
 #endif  // !OS_MACOSX