Chromium Code Reviews| 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 7bf0b0177acdbd0a2a86891d6f6473cbbfab6752..2ed5917dd6166b59241a1cde9e001bf4e660393b 100644 |
| --- a/mojo/edk/system/data_pipe_consumer_dispatcher.cc |
| +++ b/mojo/edk/system/data_pipe_consumer_dispatcher.cc |
| @@ -525,9 +525,7 @@ void DataPipeConsumerDispatcher::UpdateSignalsStateNoLock() { |
| << " [control_port=" << control_port_.name() << "]"; |
| peer_closed_ = true; |
| - } |
| - |
| - if (port_status.has_messages && !in_transit_) { |
| + } else if (port_status.has_messages && !in_transit_) { |
|
Anand Mistry (off Chromium)
2016/05/03 05:51:54
I think this logic is subtle and unclear. Why not
Ken Rockot(use gerrit already)
2016/05/03 06:16:14
Sorry, are you asking why they aren't using shared
Anand Mistry (off Chromium)
2016/05/03 07:19:10
I mean that these two functions are mostly the sam
Ken Rockot(use gerrit already)
2016/05/03 15:19:07
Oh... oh god. Yikes. I stared at this for like 3 m
|
| ports::ScopedMessage message; |
| do { |
| int rv = node_controller_->node()->GetMessageIf(control_port_, nullptr, |