| Index: mojo/system/local_message_pipe_endpoint.cc
|
| diff --git a/mojo/system/local_message_pipe_endpoint.cc b/mojo/system/local_message_pipe_endpoint.cc
|
| index 8f1cdf39123f3ab12ab1e3957f92fa560f85968b..2886a1d66537c6d189f6a54917e2ba346c6613bd 100644
|
| --- a/mojo/system/local_message_pipe_endpoint.cc
|
| +++ b/mojo/system/local_message_pipe_endpoint.cc
|
| @@ -51,10 +51,18 @@ bool LocalMessagePipeEndpoint::OnPeerClose() {
|
| return true;
|
| }
|
|
|
| -MojoResult LocalMessagePipeEndpoint::EnqueueMessage(MessageInTransit* message) {
|
| +MojoResult LocalMessagePipeEndpoint::EnqueueMessage(
|
| + MessageInTransit* message,
|
| + const std::vector<Dispatcher*>* dispatchers) {
|
| DCHECK(is_open_);
|
| DCHECK(is_peer_open_);
|
|
|
| + // TODO(vtl)
|
| + if (dispatchers) {
|
| + message->Destroy();
|
| + return MOJO_RESULT_UNIMPLEMENTED;
|
| + }
|
| +
|
| bool was_empty = message_queue_.empty();
|
| message_queue_.push_back(message);
|
| if (was_empty) {
|
| @@ -70,9 +78,11 @@ void LocalMessagePipeEndpoint::CancelAllWaiters() {
|
| waiter_list_.CancelAllWaiters();
|
| }
|
|
|
| +// TODO(vtl): Support receiving handles.
|
| MojoResult LocalMessagePipeEndpoint::ReadMessage(
|
| void* bytes, uint32_t* num_bytes,
|
| - MojoHandle* handles, uint32_t* num_handles,
|
| + uint32_t max_num_dispatchers,
|
| + std::vector<scoped_refptr<Dispatcher> >* dispatchers,
|
| MojoReadMessageFlags flags) {
|
| DCHECK(is_open_);
|
|
|
| @@ -96,10 +106,6 @@ MojoResult LocalMessagePipeEndpoint::ReadMessage(
|
| else
|
| not_enough_space = true;
|
|
|
| - // TODO(vtl): Support receiving handles.
|
| - if (num_handles)
|
| - *num_handles = 0;
|
| -
|
| if (!not_enough_space || (flags & MOJO_READ_MESSAGE_FLAG_MAY_DISCARD)) {
|
| message_queue_.pop_front();
|
| message->Destroy();
|
|
|