Lines Matching refs:ports
5 #include "mojo/edk/system/ports/node.h"
14 #include "mojo/edk/system/ports/node_delegate.h"
18 namespace ports {
82 // relatively few ports should be open during shutdown and shutdown doesn't
229 // care to close those ports so as to avoid leaking memory.
292 // Allow referenced ports to trigger PortStatusChanged calls.
295 const PortName& new_port_name = (*message)->ports()[i];
314 // If send failed, close all carried ports. Note that we're careful not to
316 // ports (an invalid but possible condition.)
318 if (message->ports()[i] == port_ref.name())
322 if (GetPort(message->ports()[i], &port) == OK)
389 DVLOG(1) << "Merging local ports " << port0_ref.name() << "@" << name_
426 ports_buf << message->ports()[i];
430 << " [ports=" << ports_buf.str() << "] at "
437 // buffering or proxying messages, we still need these ports to be bound to
438 // this node. When the message is forwarded, these ports will get transferred
440 // newly bound ports will simply be closed.
443 int rv = AcceptPort(message->ports()[i], GetPortDescriptors(event)[i]);
483 // Close all newly accepted ports as they are effectively orphaned.
486 if (GetPort(message->ports()[i], &port_ref) == OK) {
516 // inform ports when their peer (which was itself a proxy) has become
519 // Receiving ports affected by this treat it as equivalent to peer closure.
752 // Both ports are locked. Now all we have to do is swap their peer
826 if (m->ports()[i] == port_ref.name())
834 // WillSendMessage_Locked may need to lock multiple ports out of order.
882 // Ports cannot be merged with their own receiving peer!
891 // Only merge if both ports have never sent a message.
894 // Swap the ports' peer information and switch them both into buffering
1041 ports_buf << message->ports()[i];
1046 // Note: Another thread could be trying to send the same ports, so we need
1049 std::vector<scoped_refptr<Port>> ports;
1050 ports.resize(message->num_ports());
1054 ports[i] = GetPort_Locked(message->ports()[i]);
1055 DCHECK(ports[i]);
1057 ports[i]->lock.Acquire();
1059 if (ports[i]->state != Port::kReceiving)
1061 else if (message->ports()[i] == port->peer_port_name)
1067 ports[i]->lock.Release();
1079 WillSendPort(LockedPort(ports[i].get()),
1086 ports[i]->lock.Release();
1092 << " [ports=" << ports_buf.str() << "]"
1292 // Wipes out all ports whose peer node matches |node_name| and whose peer port
1345 // Wake up any receiving ports who have just observed simulated peer closure.
1366 // Close any ports referenced by the closed proxies.
1392 } // namespace ports
