Index: mojo/edk/system/ports/node.cc |
diff --git a/mojo/edk/system/ports/node.cc b/mojo/edk/system/ports/node.cc |
index 5a5d83454197d0118c13a7d46ef138e709fde9fb..75e9857731d02f163b670e8ccc6e3541f57ef60d 100644 |
--- a/mojo/edk/system/ports/node.cc |
+++ b/mojo/edk/system/ports/node.cc |
@@ -30,6 +30,8 @@ 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; |
@@ -821,11 +823,6 @@ int Node::AddPortWithName(const PortName& port_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); |