ChannelProxy: Send() from UI thread when ChannelMojo is used.

ipc/mojo/ipc_message_pipe_reader.cc

 // Copyright 2014 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 "ipc/mojo/ipc_message_pipe_reader.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/location.h"
 #include "base/logging.h"
@@ skipping 20 matching lines @@
   StopWaiting();
   pipe_.reset();
   OnPipeClosed();
 }
 
 void MessagePipeReader::CloseWithError(MojoResult error) {
   OnPipeError(error);
   Close();
 }
 
-bool MessagePipeReader::Send(scoped_ptr<Message> message) {
+MojoResult MessagePipeReader::Send(scoped_ptr<Message> message) {
   DCHECK(IsValid());
 
   message->TraceMessageBegin();
   std::vector<MojoHandle> handles;
   MojoResult result = MOJO_RESULT_OK;
 #if defined(OS_POSIX) && !defined(OS_NACL)
   result = ChannelMojo::ReadFromFileDescriptorSet(message.get(), &handles);
 #endif
   if (result == MOJO_RESULT_OK) {
     result = MojoWriteMessage(handle(),
                               message->data(),
                               static_cast<uint32>(message->size()),
                               handles.empty() ? nullptr : &handles[0],
                               static_cast<uint32>(handles.size()),
                               MOJO_WRITE_MESSAGE_FLAG_NONE);
   }
 
-  if (result != MOJO_RESULT_OK) {
+  if (result != MOJO_RESULT_OK)
     std::for_each(handles.begin(), handles.end(), &MojoClose);
-    CloseWithError(result);
-    return false;
-  }
-
-  return true;
+  return result;
 }
 
 // static
 void MessagePipeReader::InvokePipeIsReady(void* closure, MojoResult result) {
   reinterpret_cast<MessagePipeReader*>(closure)->PipeIsReady(result);
 }
 
 void MessagePipeReader::OnMessageReceived() {
   Message message(data_buffer().empty() ? "" : &data_buffer()[0],
                   static_cast<uint32>(data_buffer().size()));
@@ skipping 123 matching lines @@
 
 void MessagePipeReader::DelayedDeleter::operator()(
     MessagePipeReader* ptr) const {
   ptr->Close();
   base::MessageLoopProxy::current()->PostTask(
       FROM_HERE, base::Bind(&DeleteNow, ptr));
 }
 
 }  // namespace internal
 }  // namespace IPC