[mojo-edk] Process proxy disruptions locally.

mojo/edk/system/ports/node.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "mojo/edk/system/ports/node.h"
 
 #include <string.h>
 
 #include <utility>
 
@@ skipping 1337 matching lines @@
 
   for (const auto& proxy_name : dead_proxies_to_broadcast) {
     // Broadcast an event signifying that this proxy is no longer functioning.
     ObserveProxyEventData event;
     event.proxy_node_name = name_;
     event.proxy_port_name = proxy_name;
     event.proxy_to_node_name = kInvalidNodeName;
     event.proxy_to_port_name = kInvalidPortName;
     delegate_->BroadcastMessage(NewInternalMessage(
         kInvalidPortName, EventType::kObserveProxy, event));
+
+    // Also process death locally since the port that points this closed one
+    // could be on the current node.
+    // Note: Although this is recursive, only a single port is involved which
+    // limits the expected branching to 1.
+    DestroyAllPortsWithPeer(name_, proxy_name);
   }
 
   // Close any ports referenced by the closed proxies.
   for (const auto& name : referenced_port_names) {
     PortRef ref;
     if (GetPort(name, &ref) == OK)
       ClosePort(ref);
   }
 }
 
@@ skipping 11 matching lines @@
 
   if (num_data_bytes)
     memcpy(header + 1, data, num_data_bytes);
 
   return message;
 }
 
 }  // namespace ports
 }  // namespace edk
 }  // namespace mojo