Searched refs:forwarding_port (Results 1 – 1 of 1) sorted by relevance
1068 auto* forwarding_port = locker.GetPort(forwarding_port_ref); in PrepareToForwardUserMessage() local1070 if (forwarding_port->peer_node_name != target_node_name) { in PrepareToForwardUserMessage()1078 target_node_name = forwarding_port->peer_node_name; in PrepareToForwardUserMessage()1082 if (forwarding_port->state != expected_port_state) in PrepareToForwardUserMessage()1084 if (forwarding_port->peer_closed && !ignore_closed_peer) in PrepareToForwardUserMessage()1090 message->set_sequence_num(forwarding_port->next_sequence_num_to_send++); in PrepareToForwardUserMessage()1111 forwarding_port->peer_port_name) { in PrepareToForwardUserMessage()1117 forwarding_port->next_sequence_num_to_send--; in PrepareToForwardUserMessage()1141 << forwarding_port->peer_port_name << "@" << target_node_name; in PrepareToForwardUserMessage()1145 message->set_port_name(forwarding_port->peer_port_name); in PrepareToForwardUserMessage()