| Index: mojo/edk/system/data_pipe_consumer_dispatcher.cc
|
| diff --git a/mojo/edk/system/data_pipe_consumer_dispatcher.cc b/mojo/edk/system/data_pipe_consumer_dispatcher.cc
|
| index d5460cb4642c39fdb8dbe292952e1206ae4119a8..ec8d2d855e4bbb6f62940b91f5176b99e2ab1d46 100644
|
| --- a/mojo/edk/system/data_pipe_consumer_dispatcher.cc
|
| +++ b/mojo/edk/system/data_pipe_consumer_dispatcher.cc
|
| @@ -527,8 +527,8 @@ void DataPipeConsumerDispatcher::UpdateSignalsStateNoLock() {
|
| } else if (rv == ports::OK && port_status.has_messages && !in_transit_) {
|
| ports::ScopedMessage message;
|
| do {
|
| - int rv = node_controller_->node()->GetMessageIf(control_port_, nullptr,
|
| - &message);
|
| + int rv = node_controller_->node()->GetMessage(
|
| + control_port_, &message, nullptr);
|
| if (rv != ports::OK)
|
| peer_closed_ = true;
|
| if (message) {
|
|
|