| Index: mojo/edk/system/data_pipe_producer_dispatcher.cc
|
| diff --git a/mojo/edk/system/data_pipe_producer_dispatcher.cc b/mojo/edk/system/data_pipe_producer_dispatcher.cc
|
| index d3b2530035889b2a5446edd1f33596d096dc6563..418b739ab840d12a9e2ee71dd57a43704f05ea82 100644
|
| --- a/mojo/edk/system/data_pipe_producer_dispatcher.cc
|
| +++ b/mojo/edk/system/data_pipe_producer_dispatcher.cc
|
| @@ -503,9 +503,7 @@ void DataPipeProducerDispatcher::UpdateSignalsStateNoLock() {
|
| << " [control_port=" << control_port_.name() << "]";
|
|
|
| peer_closed_ = true;
|
| - }
|
| -
|
| - if (port_status.has_messages && !in_transit_) {
|
| + } else {
|
| ports::ScopedMessage message;
|
| do {
|
| int rv = node_controller_->node()->GetMessageIf(control_port_, nullptr,
|
|
|