Index: third_party/mojo/src/mojo/edk/system/local_message_pipe_endpoint.h |
diff --git a/third_party/mojo/src/mojo/edk/system/local_message_pipe_endpoint.h b/third_party/mojo/src/mojo/edk/system/local_message_pipe_endpoint.h |
index f792d90ac0f69fcef93b14d2257f11f3be0e01cf..61b52b3b060e48e65f0324347602693e79b89a3f 100644 |
--- a/third_party/mojo/src/mojo/edk/system/local_message_pipe_endpoint.h |
+++ b/third_party/mojo/src/mojo/edk/system/local_message_pipe_endpoint.h |
@@ -29,6 +29,7 @@ class MOJO_SYSTEM_IMPL_EXPORT LocalMessagePipeEndpoint |
Type GetType() const override; |
bool OnPeerClose() override; |
void EnqueueMessage(scoped_ptr<MessageInTransit> message) override; |
+ void OnReadMessage(MessageInTransit::ReadContext& reading_message) override; |
// There's a dispatcher for |LocalMessagePipeEndpoint|s, so we have to |
// implement/override these: |
@@ -46,6 +47,8 @@ class MOJO_SYSTEM_IMPL_EXPORT LocalMessagePipeEndpoint |
HandleSignalsState* signals_state) override; |
void RemoveAwakable(Awakable* awakable, |
HandleSignalsState* signals_state) override; |
+ MojoResult SetAsyncMessageCallback( |
+ const AsyncMessageCallback& callback) override; |
// This is only to be used by |MessagePipe|: |
MessageInTransitQueue* message_queue() { return &message_queue_; } |
@@ -57,6 +60,7 @@ class MOJO_SYSTEM_IMPL_EXPORT LocalMessagePipeEndpoint |
// Queue of incoming messages. |
MessageInTransitQueue message_queue_; |
AwakableList awakable_list_; |
+ AsyncMessageCallback message_callback_; |
DISALLOW_COPY_AND_ASSIGN(LocalMessagePipeEndpoint); |
}; |