attachment broker wip

chrome/browser/service_process/service_process_control.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/service_process/service_process_control.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/command_line.h"
 #include "base/files/file_path.h"
 #include "base/location.h"
 #include "base/metrics/histogram_base.h"
 #include "base/metrics/histogram_delta_serialization.h"
 #include "base/process/kill.h"
 #include "base/process/launch.h"
 #include "base/single_thread_task_runner.h"
 #include "base/stl_util.h"
 #include "base/thread_task_runner_handle.h"
 #include "base/threading/thread.h"
 #include "base/threading/thread_restrictions.h"
 #include "chrome/browser/browser_process.h"
 #include "chrome/browser/chrome_notification_types.h"
 #include "chrome/browser/upgrade_detector.h"
 #include "chrome/common/service_messages.h"
 #include "chrome/common/service_process_util.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/notification_service.h"
+#include "content/public/common/child_process_host.h"
 
 using content::BrowserThread;
 
 // ServiceProcessControl implementation.
 ServiceProcessControl::ServiceProcessControl() {
 }
 
 ServiceProcessControl::~ServiceProcessControl() {
 }
 
 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.
   DVLOG(1) << "Connecting to Service Process IPC Server";
 
   // TODO(hclam): Handle error connecting to channel.
   const IPC::ChannelHandle channel_id = GetServiceProcessChannel();
   SetChannel(IPC::ChannelProxy::Create(
-      channel_id,
-      IPC::Channel::MODE_NAMED_CLIENT,
-      this,
-      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO).get()));
+      channel_id, IPC::Channel::MODE_NAMED_CLIENT, this,
+      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO).get(),
+      content::ChildProcessHost::GetAttachmentBroker()));
 }
 
 void ServiceProcessControl::SetChannel(scoped_ptr<IPC::ChannelProxy> channel) {
   channel_ = channel.Pass();
 }
 
 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.
@@ skipping 316 matching lines @@
   if (process_.IsValid()) {
     BrowserThread::PostTask(
         BrowserThread::IO, FROM_HERE,
         base::Bind(&Launcher::DoDetectLaunched, this));
   } else {
     BrowserThread::PostTask(
         BrowserThread::UI, FROM_HERE, base::Bind(&Launcher::Notify, this));
   }
 }
 #endif  // !OS_MACOSX