IPC: Fix attachment brokering race condition.

remoting/host/ipc_util_posix.cc

 // Copyright 2013 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 "remoting/host/ipc_util.h"
 
 #include <fcntl.h>
 #include <sys/socket.h>
 #include <sys/types.h>
 #include <unistd.h>
 
 #include "base/files/file.h"
 #include "base/logging.h"
 #include "base/posix/eintr_wrapper.h"
 #include "base/single_thread_task_runner.h"
+#include "ipc/attachment_broker.h"
 #include "ipc/ipc_channel.h"
 #include "ipc/ipc_channel_proxy.h"
 
 namespace remoting {
 
 bool CreateConnectedIpcChannel(
     scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
     IPC::Listener* listener,
     base::File* client_out,
     std::unique_ptr<IPC::ChannelProxy>* server_out) {
@@ skipping 12 matching lines @@
       PLOG(ERROR) << "close()";
     if (IGNORE_EINTR(close(pipe_fds[1])) < 0)
       PLOG(ERROR) << "close()";
     return false;
   }
 
   std::string socket_name = "Chromoting socket";
 
   // Wrap the pipe into an IPC channel.
   base::FileDescriptor fd(pipe_fds[0], false);
-  IPC::ChannelHandle handle(socket_name, fd);
-  *server_out = IPC::ChannelProxy::Create(IPC::ChannelHandle(socket_name, fd),
-                                          IPC::Channel::MODE_SERVER, listener,
-                                          io_task_runner.get());
+  server_out->reset(new IPC::ChannelProxy(listener, io_task_runner));
+  if (IPC::AttachmentBroker::GetGlobal()) {
+    IPC::AttachmentBroker::GetGlobal()->RegisterCommunicationChannel(
+        server_out->get(), io_task_runner);
+  }
+  (*server_out)
+      ->Init(IPC::ChannelHandle(socket_name, fd), IPC::Channel::MODE_SERVER,
+             true);
 
   *client_out = base::File(pipe_fds[1]);
   return true;
 }
 
 } // namespace remoting