Implement IPC::ParamTraits<mojo::MessagePipeHandle>

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 27 matching lines @@
   OnPipeError(error);
   Close();
 }
 
 bool 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::ReadFromMessageAttachmentSet(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) {
     std::for_each(handles.begin(), handles.end(), &MojoClose);
     CloseWithError(result);
     return false;
   }
 
   return true;
 }
 
 void MessagePipeReader::OnMessageReceived() {
   Message message(data_buffer().empty() ? "" : &data_buffer()[0],
                   static_cast<uint32>(data_buffer().size()));
 
   std::vector<MojoHandle> handle_buffer;
   TakeHandleBuffer(&handle_buffer);
-#if defined(OS_POSIX) && !defined(OS_NACL)
   MojoResult write_result =
       ChannelMojo::WriteToMessageAttachmentSet(handle_buffer, &message);
   if (write_result != MOJO_RESULT_OK) {
     CloseWithError(write_result);
     return;
   }
-#else
-  DCHECK(handle_buffer.empty());
-#endif
 
   message.TraceMessageEnd();
   delegate_->OnMessageReceived(message);
 }
 
 void MessagePipeReader::OnPipeClosed() {
   if (!delegate_)
     return;
   delegate_->OnPipeClosed(this);
   delegate_ = nullptr;
@@ skipping 102 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