[mojo-edk] Fix uninitialized reads in EDK dispatchers

mojo/edk/system/data_pipe_consumer_dispatcher.cc

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..6d1b618fd7fc2595b4f3076007021f4a4042f6b6 100644
--- a/mojo/edk/system/data_pipe_consumer_dispatcher.cc
+++ b/mojo/edk/system/data_pipe_consumer_dispatcher.cc
@@ -518,16 +518,12 @@ void DataPipeConsumerDispatcher::UpdateSignalsStateNoLock() {
   size_t previous_bytes_available = bytes_available_;
 
   ports::PortStatus port_status;
-  if (node_controller_->node()->GetStatus(control_port_, &port_status) !=
-          ports::OK ||
-      !port_status.receiving_messages) {
+  int rv = node_controller_->node()->GetStatus(control_port_, &port_status);
+  if (rv != ports::OK || !port_status.receiving_messages) {
     DVLOG(1) << "Data pipe consumer " << pipe_id_ << " is aware of peer closure"
              << " [control_port=" << control_port_.name() << "]";
-
     peer_closed_ = true;
-  }
-
-  if (port_status.has_messages && !in_transit_) {
+  } else if (rv == ports::OK && port_status.has_messages && !in_transit_) {
     ports::ScopedMessage message;
     do {
       int rv = node_controller_->node()->GetMessageIf(control_port_, nullptr,