Index: third_party/mojo/src/mojo/edk/system/message_pipe.h |
diff --git a/third_party/mojo/src/mojo/edk/system/message_pipe.h b/third_party/mojo/src/mojo/edk/system/message_pipe.h |
index df0501484e5715eb743733b2b739cc77803b49b6..3deee2986a92f9b0b07f06a42603117ad6e2ecb2 100644 |
--- a/third_party/mojo/src/mojo/edk/system/message_pipe.h |
+++ b/third_party/mojo/src/mojo/edk/system/message_pipe.h |
@@ -105,6 +105,9 @@ class MOJO_SYSTEM_IMPL_EXPORT MessagePipe : public ChannelEndpointClient { |
void RemoveAwakable(unsigned port, |
Awakable* awakable, |
HandleSignalsState* signals_state); |
+ MojoResult SetAsyncMessageCallback(unsigned port, |
+ const AsyncMessageCallback& callback); |
+ |
void StartSerialize(unsigned port, |
Channel* channel, |
size_t* max_size, |
@@ -116,7 +119,8 @@ class MOJO_SYSTEM_IMPL_EXPORT MessagePipe : public ChannelEndpointClient { |
embedder::PlatformHandleVector* platform_handles); |
// |ChannelEndpointClient| methods: |
- bool OnReadMessage(unsigned port, MessageInTransit* message) override; |
+ bool OnReadMessage(unsigned port, |
+ MessageInTransit::ReadContext& reading_message) override; |
void OnDetachFromChannel(unsigned port) override; |
private: |
@@ -130,6 +134,10 @@ class MOJO_SYSTEM_IMPL_EXPORT MessagePipe : public ChannelEndpointClient { |
scoped_ptr<MessageInTransit> message, |
std::vector<DispatcherTransport>* transports); |
+ MojoResult DispatchOnReadMessageNoLock( |
+ unsigned port, |
+ MessageInTransit::ReadContext& reading_message); |
+ |
// Helper for |EnqueueMessageNoLock()|. Must be called with |lock_| held. |
MojoResult AttachTransportsNoLock( |
unsigned port, |