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) { |