Add an IPC channel between the NaCl loader process and the renderer.

chrome/nacl/nacl_ipc_adapter.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/nacl/nacl_ipc_adapter.h"
 
 #include <limits.h>
 #include <string.h>
 
 #include "base/basictypes.h"
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/memory/scoped_ptr.h"
 #include "build/build_config.h"
+#include "ipc/ipc_channel_proxy.h"
 
 namespace {
 
 enum BufferSizeStatus {
   // The buffer contains a full message with no extra bytes.
   MESSAGE_IS_COMPLETE,
 
   // The message doesn't fit and the buffer contains only some of it.
   MESSAGE_IS_TRUNCATED,
 
@@ skipping 86 matching lines @@
 }
 
 NaClIPCAdapter::NaClIPCAdapter(const IPC::ChannelHandle& handle,
                                base::TaskRunner* runner)
     : lock_(),
       cond_var_(&lock_),
       task_runner_(runner),
       locked_data_() {
   io_thread_data_.channel_.reset(
       new IPC::Channel(handle, IPC::Channel::MODE_SERVER, this));
+  DCHECK(io_thread_data_.channel_->Connect());

[dmichael (off chromium), 2012/05/07 20:30:19]

You don't want to do this inside DCHECK, since it will only run in debug builds.

[bbudge, 2012/05/07 21:39:18]

I think that's OK. I've seen it in other calls to connect. I don't think there's
much we can do if it fails.
On 2012/05/07 20:30:19, dmichael wrote:

 }
 
 NaClIPCAdapter::NaClIPCAdapter(scoped_ptr<IPC::Channel> channel,
                                base::TaskRunner* runner)
     : lock_(),
       cond_var_(&lock_),
       task_runner_(runner),
       locked_data_() {
   io_thread_data_.channel_ = channel.Pass();
 }
@@ skipping 196 matching lines @@
   locked_data_.to_be_sent_.swap(empty);
 }
 
 void NaClIPCAdapter::CloseChannelOnIOThread() {
   io_thread_data_.channel_->Close();
 }
 
 void NaClIPCAdapter::SendMessageOnIOThread(scoped_ptr<IPC::Message> message) {
   io_thread_data_.channel_->Send(message.release());
 }