Chromium Code Reviews| 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 b331399039706f1ef2fbb78acd9f9339a74d64e5..fddd0fd8cf84c2559ce8d54015e897ad69c8ae8b 100644 |
| --- a/mojo/edk/system/message_pipe_dispatcher.h |
| +++ b/mojo/edk/system/message_pipe_dispatcher.h |
| @@ -14,6 +14,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 +53,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; |
|
Sam McNally
2016/04/26 08:20:43
This should be named the same as in Dispatcher.
Ken Rockot(use gerrit already)
2016/04/26 15:28:23
Done
|
| HandleSignalsState GetHandleSignalsState() const override; |
| MojoResult AddAwakable(Awakable* awakable, |
| MojoHandleSignals signals, |