ChannelMojo: Handle errors in pending message processing.

ipc/mojo/ipc_channel_mojo_readers.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_channel_mojo_readers.h"
 
 #include "ipc/mojo/ipc_channel_mojo.h"
 #include "mojo/embedder/embedder.h"
 
 #if defined(OS_POSIX) && !defined(OS_NACL)
@@ skipping 128 matching lines @@
 #if defined(OS_POSIX) && !defined(OS_NACL)
   MojoResult read_result =
       ChannelMojo::ReadFromFileDescriptorSet(*message, &handles);
   if (read_result != MOJO_RESULT_OK) {
     std::for_each(handles.begin(), handles.end(), &MojoClose);
     CloseWithError(read_result);
     return false;
   }
 #endif
   MojoResult write_result =
-      MojoWriteMessage(handle(),
-                       message->data(),
-                       static_cast<uint32>(message->size()),
-                       handles.empty() ? NULL : &handles[0],
-                       static_cast<uint32>(handles.size()),
-                       MOJO_WRITE_MESSAGE_FLAG_NONE);
+      WriteMessageToPipe(message->data(),
+                         static_cast<uint32>(message->size()),
+                         handles.empty() ? NULL : &handles[0],
+                         static_cast<uint32>(handles.size()),
+                         MOJO_WRITE_MESSAGE_FLAG_NONE);
   if (MOJO_RESULT_OK != write_result) {
     std::for_each(handles.begin(), handles.end(), &MojoClose);
     CloseWithError(write_result);
     return false;
   }
 
   return true;
 }
 
+MojoResult MessageReader::WriteMessageToPipe(
+    const void* bytes,
+    uint32_t num_bytes,
+    const MojoHandle* handles,
+    uint32_t num_handles,
+    MojoWriteMessageFlags flags) {
+  return MojoWriteMessage(handle(),
+                          bytes, num_bytes,
+                          handles, num_handles,
+                          flags);
+}
+
 //------------------------------------------------------------------------------
 
 ControlReader::ControlReader(mojo::ScopedMessagePipeHandle pipe,
                              ChannelMojo* owner)
     : internal::MessagePipeReader(pipe.Pass()), owner_(owner) {
 }
 
 void ControlReader::OnPipeClosed() {
   if (!owner_)
     return;
@@ skipping 138 matching lines @@
 
   MojoResult result = RespondHelloRequest(handle_buffer[0]);
   if (result != MOJO_RESULT_OK) {
     DLOG(ERROR) << "Failed to respond Hello request. Closing: " << result;
     CloseWithError(result);
   }
 }
 
 }  // namespace internal
 }  // namespace IPC