| Index: mojo/edk/system/message_pipe_dispatcher.h
|
| diff --git a/mojo/edk/system/message_pipe_dispatcher.h b/mojo/edk/system/message_pipe_dispatcher.h
|
| index fd3f665b8e457c3e32a1c7ffbddd34aec7730454..0345a45203e4677fa15f239b345fdaed08472a06 100644
|
| --- a/mojo/edk/system/message_pipe_dispatcher.h
|
| +++ b/mojo/edk/system/message_pipe_dispatcher.h
|
| @@ -7,6 +7,7 @@
|
|
|
| #include <stdint.h>
|
|
|
| +#include <memory>
|
| #include <queue>
|
|
|
| #include "base/macros.h"
|
| @@ -14,6 +15,7 @@
|
| #include "mojo/edk/system/atomic_flag.h"
|
| #include "mojo/edk/system/awakable_list.h"
|
| #include "mojo/edk/system/dispatcher.h"
|
| +#include "mojo/edk/system/message_for_transit.h"
|
| #include "mojo/edk/system/ports/port_ref.h"
|
|
|
| namespace mojo {
|
| @@ -52,16 +54,14 @@ class MessagePipeDispatcher : public Dispatcher {
|
| const Watcher::WatchCallback& callback,
|
| uintptr_t context) override;
|
| MojoResult CancelWatch(uintptr_t context) override;
|
| - MojoResult WriteMessage(const void* bytes,
|
| - uint32_t num_bytes,
|
| - const DispatcherInTransit* dispatchers,
|
| - uint32_t num_dispatchers,
|
| + MojoResult WriteMessage(std::unique_ptr<MessageForTransit> message,
|
| MojoWriteMessageFlags flags) override;
|
| - MojoResult ReadMessage(void* bytes,
|
| + MojoResult ReadMessage(std::unique_ptr<MessageForTransit>* message,
|
| uint32_t* num_bytes,
|
| MojoHandle* handles,
|
| uint32_t* num_handles,
|
| - MojoReadMessageFlags flags) override;
|
| + MojoReadMessageFlags flags,
|
| + bool read_any_size) override;
|
| HandleSignalsState GetHandleSignalsState() const override;
|
| MojoResult AddAwakable(Awakable* awakable,
|
| MojoHandleSignals signals,
|
|
|