[mojo-edk] Prevent closed port from accepting new messages

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 12 matching lines @@
   CHECK(false) << "Oops: " << message;
   return error_code;
 }
 
 #define OOPS(x) DebugError(#x, x)
 
 bool CanAcceptMoreMessages(const Port* port) {
   // Have we already doled out the last message (i.e., do we expect to NOT
   // receive further messages)?
   uint64_t next_sequence_num = port->message_queue.next_sequence_num();
+  if (port->state == Port::kClosed)
+    return false;
   if (port->peer_closed || port->remove_proxy_on_last_message) {
     if (port->last_sequence_num_to_receive == next_sequence_num - 1)
       return false;
   }
   return true;
 }
 
 }  // namespace
 
 Node::Node(const NodeName& name, NodeDelegate* delegate)
@@ skipping 771 matching lines @@
                           const scoped_refptr<Port>& port) {
   base::AutoLock lock(ports_lock_);
 
   if (!ports_.insert(std::make_pair(port_name, port)).second)
     return OOPS(ERROR_PORT_EXISTS);  // Suggests a bad UUID generator.
 
   DVLOG(2) << "Created port " << port_name << "@" << name_;
   return OK;
 }
 
-void Node::ErasePort(const PortName& port_name) {
-  base::AutoLock lock(ports_lock_);
-  return ErasePort_Locked(port_name);
-}
-
 void Node::ErasePort_Locked(const PortName& port_name) {
   ports_lock_.AssertAcquired();
   ports_.erase(port_name);
   DVLOG(2) << "Deleted port " << port_name << "@" << name_;
 }
 
 scoped_refptr<Port> Node::GetPort(const PortName& port_name) {
   base::AutoLock lock(ports_lock_);
   return GetPort_Locked(port_name);
 }
@@ skipping 401 matching lines @@
 
   if (num_data_bytes)
     memcpy(header + 1, data, num_data_bytes);
 
   return message;
 }
 
 }  // namespace ports
 }  // namespace edk
 }  // namespace mojo