| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_candidate.rs | 4 use ice::candidate::candidate_base::CandidateBaseConfig;
5 use ice::candidate::candidate_host::CandidateHostConfig;
6 use ice::candidate::candidate_peer_reflexive::CandidatePeerReflexiveConfig;
7 use ice::candidate::candidate_relay::CandidateRelayConfig;
8 use ice::candidate::candidate_server_reflexive::CandidateServerReflexiveConfig;
9 use ice::candidate::Candidate;
147 let candidate = self.to_ice()?; in to_json() localVariable
150 candidate: format!("candidate:{}", candidate.marshal()), in to_json()
172 pub candidate: String, field
188 candidate: "candidate:abc123".to_string(), in test_ice_candidate_serialization()
[all …]
|
| H A D | ice_gatherer.rs | 14 use ice::candidate::{Candidate, CandidateType};
95 candidate_types.push(ice::candidate::CandidateType::Host); in create_agent()
97 candidate_types.push(ice::candidate::CandidateType::Relay); in create_agent()
164 move |candidate: Option<Arc<dyn Candidate + Send + Sync>>| { in gather()
172 if let Some(cand) = candidate { in gather()
|
| H A D | ice_candidate_type.rs | 1 use ice::candidate::CandidateType;
|
| /webrtc/examples/examples/data-channels-flow-control/ |
| H A D | data-channels-flow-control.rs | 171 responder.on_ice_candidate(Box::new(move |candidate: Option<RTCIceCandidate>| { in main()
175 if let Some(candidate) = candidate { in main()
176 if let Ok(candidate) = candidate.to_json() { in main()
178 if let Err(err) = requester.add_ice_candidate(candidate).await { in main()
188 requester.on_ice_candidate(Box::new(move |candidate: Option<RTCIceCandidate>| { in main()
192 if let Some(candidate) = candidate { in main()
193 if let Ok(candidate) = candidate.to_json() { in main()
195 if let Err(err) = responder.add_ice_candidate(candidate).await { in main()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_test.rs | 102 for (candidate, want) in tests { in test_candidate_priority()
103 let got = candidate.priority(); in test_candidate_priority()
115 let candidate = CandidateBase::default(); in test_candidate_last_sent() localVariable
120 candidate.set_last_sent(d); in test_candidate_last_sent()
121 assert_eq!(candidate.last_sent(), now); in test_candidate_last_sent()
128 let candidate = CandidateBase::default(); in test_candidate_last_received() localVariable
133 candidate.set_last_received(d); in test_candidate_last_received()
134 assert_eq!(candidate.last_received(), now); in test_candidate_last_received()
391 for (candidate, marshaled) in tests { in test_candidate_marshal()
393 if let Some(candidate) = candidate { in test_candidate_marshal()
[all …]
|
| H A D | candidate_pair_test.rs | 3 use crate::candidate::candidate_host::CandidateHostConfig;
4 use crate::candidate::candidate_peer_reflexive::CandidatePeerReflexiveConfig;
5 use crate::candidate::candidate_relay::CandidateRelayConfig;
6 use crate::candidate::candidate_server_reflexive::CandidateServerReflexiveConfig;
|
| H A D | candidate_base.rs | 2 use crate::candidate::candidate_host::CandidateHostConfig;
3 use crate::candidate::candidate_peer_reflexive::CandidatePeerReflexiveConfig;
4 use crate::candidate::candidate_relay::CandidateRelayConfig;
5 use crate::candidate::candidate_server_reflexive::CandidateServerReflexiveConfig;
|
| /webrtc/ice/src/agent/ |
| H A D | agent_gather.rs | 10 use crate::candidate::candidate_base::CandidateBaseConfig;
11 use crate::candidate::candidate_host::CandidateHostConfig;
12 use crate::candidate::candidate_relay::CandidateRelayConfig;
14 use crate::candidate::*;
322 Ok(candidate) => { in gather_candidates_local()
336 Arc::new(candidate) in gather_candidates_local()
444 let candidate: Arc<dyn Candidate + Send + Sync> = in gather_candidates_local_udp_mux() localVariable
447 agent_internal.add_candidate(&candidate).await?; in gather_candidates_local_udp_mux()
541 Ok(candidate) => Arc::new(candidate), in gather_candidates_srflx_mapped()
677 Ok(candidate) => Arc::new(candidate), in gather_candidates_srflx()
[all …]
|
| H A D | mod.rs | 17 use crate::candidate::*;
286 if let Ok(candidate) = in add_remote_candidate()
289 ai.add_remote_candidate(&candidate).await; in add_remote_candidate()
295 let candidate = Arc::clone(c); in add_remote_candidate() localVariable
297 ai.add_remote_candidate(&candidate).await; in add_remote_candidate()
311 for candidate in candidates { in get_local_candidates()
312 res.push(Arc::clone(candidate)); in get_local_candidates()
|
| H A D | agent_internal.rs | 3 use crate::candidate::candidate_base::CandidateBaseConfig;
4 use crate::candidate::candidate_peer_reflexive::CandidatePeerReflexiveConfig;
1027 candidate: &Arc<dyn Candidate + Send + Sync>, in start_candidate()
1032 let closed_ch = candidate.get_closed_ch(); in start_candidate()
1037 let cand = Arc::clone(candidate); in start_candidate()
1038 if let Some(conn) = candidate.get_conn() { in start_candidate()
1040 let addr = candidate.addr(); in start_candidate()
1116 candidate: Arc<dyn Candidate + Send + Sync>, in recv_loop()
1146 self.handle_inbound_candidate_msg(&candidate, &buffer[..n], src_addr, addr) in recv_loop()
|
| H A D | agent_gather_test.rs | 297 for candidate in candidates { in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
298 match candidate.candidate_type() { in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
300 candi_host = Some(candidate); in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
303 candi_srflx = Some(candidate); in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
|
| H A D | agent_test.rs | 3 use crate::candidate::candidate_base::*;
4 use crate::candidate::candidate_host::*;
5 use crate::candidate::candidate_peer_reflexive::*;
6 use crate::candidate::candidate_relay::*;
7 use crate::candidate::candidate_server_reflexive::*;
1260 let candidate = if stats.id == host_local.id() { in test_local_candidate_stats() localVariable
1272 candidate.candidate_type(), in test_local_candidate_stats()
1277 candidate.priority(), in test_local_candidate_stats()
1391 let candidate = if stats.id == relay_remote.id() { in test_remote_candidate_stats() localVariable
1409 candidate.candidate_type(), in test_remote_candidate_stats()
[all …]
|
| /webrtc/constraints/src/algorithms/select_settings/ |
| H A D | apply_advanced.rs | 40 for (candidate, fitness_distance) in candidates.iter() { in apply_advanced_constraints()
41 if advanced_constraint_set.fitness_distance(candidate).is_ok() { in apply_advanced_constraints()
42 selected_candidates.push((*candidate, *fitness_distance)); in apply_advanced_constraints()
|
| H A D | apply_mandatory.rs | 36 for candidate in candidates { in apply_mandatory_constraints()
37 match mandatory_constraints.fitness_distance(candidate) { in apply_mandatory_constraints()
41 feasible_candidates.push((candidate, fitness_distance)); in apply_mandatory_constraints()
|
| H A D | select_optimal.rs | 10 for (candidate, fitness_distance) in candidates { in select_optimal_candidates()
38 optimal_candidates.push(candidate); in select_optimal_candidates()
|
| /webrtc/stun/src/ |
| H A D | attributes.rs | 19 for candidate in &self.0 { in get()
20 if candidate.typ == t { in get()
21 return (candidate.clone(), true); in get()
|
| /webrtc/ice/src/ |
| H A D | lib.rs | 5 pub mod candidate; module
|
| /webrtc/ice/src/stats/ |
| H A D | mod.rs | 1 use crate::candidate::*;
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | mod.rs | 23 use ice::candidate::candidate_base::unmarshal_candidate;
24 use ice::candidate::Candidate;
272 let candidate = c.to_ice()?; in add_candidates_to_media_descriptions() localVariable
274 candidate.set_component(1); in add_candidates_to_media_descriptions()
275 m = append_candidate_if_new(&candidate, m); in add_candidates_to_media_descriptions()
277 candidate.set_component(2); in add_candidates_to_media_descriptions()
278 m = append_candidate_if_new(&candidate, m); in add_candidates_to_media_descriptions()
807 let candidate = RTCIceCandidate::from(&c); in extract_ice_details() localVariable
808 candidates.push(candidate); in extract_ice_details()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | dtls_transport_test.rs | 51 pc_offer.on_ice_candidate(Box::new(move |candidate: Option<RTCIceCandidate>| { in test_invalid_fingerprint_causes_failed()
54 if candidate.is_none() { in test_invalid_fingerprint_causes_failed()
|
| /webrtc/examples/examples/offer-answer/ |
| H A D | offer.rs | 39 let payload = c.to_json()?.candidate; in signal_candidate()
82 let candidate = in remote_handler() localVariable
90 candidate, in remote_handler()
|
| H A D | answer.rs | 40 let payload = c.to_json()?.candidate; in signal_candidate()
83 let candidate = in remote_handler() localVariable
91 candidate, in remote_handler()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | mod.rs | 70 use ::ice::candidate::candidate_base::unmarshal_candidate;
71 use ::ice::candidate::Candidate;
1487 for candidate in candidates { in set_remote_description()
1490 .add_remote_candidate(Some(candidate)) in set_remote_description()
1607 pub async fn add_ice_candidate(&self, candidate: RTCIceCandidateInit) -> Result<()> { in add_ice_candidate()
1612 let candidate_value = match candidate.candidate.strip_prefix("candidate:") { in add_ice_candidate()
1614 None => candidate.candidate.as_str(), in add_ice_candidate()
1618 let candidate: Arc<dyn Candidate + Send + Sync> = in add_ice_candidate() localVariable
1621 Some(RTCIceCandidate::from(&candidate)) in add_ice_candidate()
|
| /webrtc/dtls/src/ |
| H A D | handshaker.rs | 181 let candidate = labels.join("."); in get_certificate() localVariable
182 if let Some(cert) = self.name_to_certificate.get(&candidate) { in get_certificate()
|
| /webrtc/ice/src/external_ip_mapper/ |
| H A D | mod.rs | 4 use crate::candidate::*;
|