attachment broker wip

chrome/browser/printing/cloud_print/test/cloud_print_proxy_process_browsertest.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.
 
 // Create a service process that uses a Mock to respond to the browser in order
 // to test launching the browser using the cloud print policy check command
 // line switch.
 
 #include "base/bind.h"
 #include "base/command_line.h"
@@ skipping 250 matching lines @@
 
   // Connect up the parent/child IPC channel to signal that the test can
   // continue.
   TestStartupClientChannelListener listener;
   EXPECT_TRUE(base::CommandLine::ForCurrentProcess()->HasSwitch(
       switches::kProcessChannelID));
   std::string startup_channel_name =
       base::CommandLine::ForCurrentProcess()->GetSwitchValueASCII(
           switches::kProcessChannelID);
   scoped_ptr<IPC::ChannelProxy> startup_channel;
-  startup_channel =
-      IPC::ChannelProxy::Create(startup_channel_name,
-                                IPC::Channel::MODE_CLIENT,
-                                &listener,
-                                service_process.IOMessageLoopProxy());
+  startup_channel = IPC::ChannelProxy::Create(
+      startup_channel_name, IPC::Channel::MODE_CLIENT, &listener,
+      service_process.IOMessageLoopProxy(), nullptr);
 
   main_message_loop.Run();
   if (!Mock::VerifyAndClearExpectations(&server))
     return kExpectationsNotMet;
   if (!g_good_shutdown)
     return kShutdownNotGood;
   return 0;
 }
 
 void SetServiceEnabledExpectations(MockServiceIPCServer* server) {
@@ skipping 148 matching lines @@
 }
 
 base::Process CloudPrintProxyPolicyStartupTest::Launch(
     const std::string& name) {
   EXPECT_FALSE(CheckServiceProcessReady());
 
   startup_channel_id_ =
       base::StringPrintf("%d.%p.%d",
                          base::GetCurrentProcId(), this,
                          base::RandInt(0, std::numeric_limits<int>::max()));
-  startup_channel_ = IPC::ChannelProxy::Create(startup_channel_id_,
-                                               IPC::Channel::MODE_SERVER,
-                                               this,
-                                               IOTaskRunner());
+  startup_channel_ =
+      IPC::ChannelProxy::Create(startup_channel_id_, IPC::Channel::MODE_SERVER,
+                                this, IOTaskRunner(), nullptr);
 
 #if defined(OS_POSIX)
   base::FileHandleMappingVector ipc_file_list;
   ipc_file_list.push_back(std::make_pair(
       startup_channel_->TakeClientFileDescriptor().release(),
       kPrimaryIPCChannel + base::GlobalDescriptors::kBaseDescriptor));
   base::LaunchOptions options;
   options.fds_to_remap = &ipc_file_list;
   base::Process process = SpawnChildWithOptions(name, options);
 #else
   base::Process process = SpawnChild(name);
 #endif
   EXPECT_TRUE(process.IsValid());
   return process.Pass();
 }
 
 void CloudPrintProxyPolicyStartupTest::WaitForConnect() {
   observer_.Wait();
   EXPECT_TRUE(CheckServiceProcessReady());
   EXPECT_TRUE(base::ThreadTaskRunnerHandle::Get().get());
-  ServiceProcessControl::GetInstance()->SetChannel(
-      IPC::ChannelProxy::Create(GetServiceProcessChannel(),
-                                IPC::Channel::MODE_NAMED_CLIENT,
-                                ServiceProcessControl::GetInstance(),
-                                IOTaskRunner()));
+  ServiceProcessControl::GetInstance()->SetChannel(IPC::ChannelProxy::Create(
+      GetServiceProcessChannel(), IPC::Channel::MODE_NAMED_CLIENT,
+      ServiceProcessControl::GetInstance(), IOTaskRunner(), nullptr));
 }
 
 bool CloudPrintProxyPolicyStartupTest::Send(IPC::Message* message) {
   return ServiceProcessControl::GetInstance()->Send(message);
 }
 
 void CloudPrintProxyPolicyStartupTest::ShutdownAndWaitForExitWithTimeout(
     base::Process process) {
   ASSERT_TRUE(Send(new ServiceMsg_Shutdown()));
 
@@ skipping 37 matching lines @@
 }
 
 KeyedService* CloudPrintProxyServiceFactoryForPolicyTest(
     content::BrowserContext* profile) {
   CloudPrintProxyService* service =
       new CloudPrintProxyService(static_cast<Profile*>(profile));
   service->Initialize();
   return service;
 }