[mojo-edk] Add explicit message object APIs

mojo/edk/system/dispatcher.h

 // 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.
 
 #ifndef MOJO_EDK_SYSTEM_DISPATCHER_H_
 #define MOJO_EDK_SYSTEM_DISPATCHER_H_
 
 #include <stddef.h>
 #include <stdint.h>
 
@@ skipping 13 matching lines @@
 #include "mojo/public/c/system/buffer.h"
 #include "mojo/public/c/system/data_pipe.h"
 #include "mojo/public/c/system/message_pipe.h"
 #include "mojo/public/c/system/types.h"
 
 namespace mojo {
 namespace edk {
 
 class Awakable;
 class Dispatcher;
+class MessageForTransit;
 
 using DispatcherVector = std::vector<scoped_refptr<Dispatcher>>;
 
 // A |Dispatcher| implements Mojo EDK calls that are associated with a
 // particular MojoHandle, with the exception of MojoWait and MojoWaitMany (
 // which are implemented directly in Core.).
 class MOJO_SYSTEM_IMPL_EXPORT Dispatcher
     : public base::RefCountedThreadSafe<Dispatcher> {
  public:
   struct DispatcherInTransit {
@@ skipping 25 matching lines @@
   ///////////// Watch API ////////////////////
 
   virtual MojoResult Watch(MojoHandleSignals signals,
                            const Watcher::WatchCallback& callback,
                            uintptr_t context);
 
   virtual MojoResult CancelWatch(uintptr_t context);
 
   ///////////// Message pipe API /////////////
 
-  virtual MojoResult WriteMessage(const void* bytes,
-                                  uint32_t num_bytes,
-                                  const DispatcherInTransit* dispatchers,
-                                  uint32_t num_dispatchers,
+  virtual MojoResult WriteMessage(std::unique_ptr<MessageForTransit> message,
                                   MojoWriteMessageFlags flags);
 
-  virtual MojoResult ReadMessage(void* bytes,
+  virtual MojoResult ReadMessage(std::unique_ptr<MessageForTransit>* message,
                                  uint32_t* num_bytes,
                                  MojoHandle* handles,
                                  uint32_t* num_handles,
-                                 MojoReadMessageFlags flags);
+                                 MojoReadMessageFlags flags,
+                                 bool read_any_size);
 
   ///////////// Shared buffer API /////////////
 
   // |options| may be null. |new_dispatcher| must not be null, but
   // |*new_dispatcher| should be null (and will contain the dispatcher for the
   // new handle on success).
   virtual MojoResult DuplicateBufferHandle(
       const MojoDuplicateBufferHandleOptions* options,
       scoped_refptr<Dispatcher>* new_dispatcher);
 
@@ skipping 150 matching lines @@
 // So logging macros and |DCHECK_EQ()|, etc. work.
 MOJO_SYSTEM_IMPL_EXPORT inline std::ostream& operator<<(std::ostream& out,
                                                         Dispatcher::Type type) {
   return out << static_cast<int>(type);
 }
 
 }  // namespace edk
 }  // namespace mojo
 
 #endif  // MOJO_EDK_SYSTEM_DISPATCHER_H_