| 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);
|
| };
|
|
|