Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(631)

Unified Diff: third_party/mojo/src/mojo/edk/system/local_message_pipe_endpoint.h

Issue 929433005: WIP: A couple of more ChannelMojo speedup ideas (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Build and test fix Created 5 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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);
};

Powered by Google App Engine
This is Rietveld 408576698