Lines Matching refs:port1
379 Port* port1 = port1_ref.port();
385 base::AutoLock port1_lock(port1->lock);
390 if (port0->state != Port::kReceiving || port1->state != Port::kReceiving)
864 Port* port1 = port1_ref.port();
868 port1->lock.AssertAcquired();
871 CHECK(port1->state == Port::kReceiving);
878 if (port1->peer_node_name == name_ &&
879 port1->peer_port_name == port0_ref.name())
884 port1->next_sequence_num_to_send == kInitialSequenceNum) {
888 std::swap(port0->peer_node_name, port1->peer_node_name);
889 std::swap(port0->peer_port_name, port1->peer_port_name);
895 port1->state = Port::kBuffering;
896 if (port1->peer_closed)
897 port1->remove_proxy_on_last_message = true;
900 int rv2 = BeginProxying_Locked(LockedPort(port1), port1_ref.name());
905 if (port1->peer_closed) {
916 data.last_sequence_num = port1->last_sequence_num_to_receive;
918 port1->peer_node_name,
919 NewInternalMessage(port1->peer_port_name,
929 std::swap(port0->peer_node_name, port1->peer_node_name);
930 std::swap(port0->peer_port_name, port1->peer_port_name);
932 port1->remove_proxy_on_last_message = false;
934 port1->state = Port::kReceiving;
