Lines Matching refs:remote
397 let remote = p.remote.clone(); in ping_all_candidates() localVariable
398 pairs.push((local, remote)); in ping_all_candidates()
403 for (local, remote) in pairs { in ping_all_candidates()
404 self.ping_candidate(&local, &remote).await; in ping_all_candidates()
411 remote: Arc<dyn Candidate + Send + Sync>, in add_pair()
415 remote, in add_pair()
425 remote: &Arc<dyn Candidate + Send + Sync>, in find_pair()
429 if p.local.equal(&**local) && p.remote.equal(&**remote) { in find_pair()
445 .duration_since(selected_pair.remote.last_received()) in validate_selected_pair()
481 let (local, remote) = { in check_keepalive()
488 Some(selected_pair.remote.clone()), in check_keepalive()
493 if let (Some(local), Some(remote)) = (local, remote) { in check_keepalive()
499 .duration_since(remote.last_received()) in check_keepalive()
508 self.ping_candidate(&local, &remote).await; in check_keepalive()
711 remote: &Arc<dyn Candidate + Send + Sync>, in send_binding_request()
717 remote in send_binding_request()
727 destination: remote.addr(), in send_binding_request()
732 self.send_stun(m, local, remote).await; in send_binding_request()
739 remote: &Arc<dyn Candidate + Send + Sync>, in send_binding_success()
741 let addr = remote.addr(); in send_binding_success()
765 remote, in send_binding_success()
769 self.send_stun(&out, local, remote).await; in send_binding_success()
827 remote: SocketAddr, in handle_inbound()
837 remote, in handle_inbound()
868 .find_remote_candidate(local.network_type(), remote) in handle_inbound()
879 remote, in handle_inbound()
887 self.handle_success_response(m, local, rc, remote).await; in handle_inbound()
892 remote in handle_inbound()
905 remote, in handle_inbound()
915 remote, in handle_inbound()
923 let (ip, port, network_type) = (remote.ip(), remote.port(), NetworkType::Udp4); in handle_inbound()
952 remote in handle_inbound()
962 remote, in handle_inbound()
981 remote: SocketAddr, in validate_non_stun_traffic()
983 self.find_remote_candidate(local.network_type(), remote) in validate_non_stun_traffic()
1013 remote: &Arc<dyn Candidate + Send + Sync>, in send_stun()
1015 if let Err(err) = local.write_to(&msg.raw, &**remote).await { in send_stun()
1068 f(&p.local, &p.remote).await; in start_on_connection_state_change_routine()