| /webrtc/sctp/src/chunk/ |
| H A D | chunk_heartbeat_ack.rs | 37 pub(crate) params: Vec<Box<dyn Param + Send + Sync>>, field
72 let params = vec![p]; in unmarshal() localVariable
74 Ok(ChunkHeartbeatAck { params }) in unmarshal()
78 if self.params.len() != 1 { in marshal_to()
81 if self.params[0].header().typ != ParamType::HeartbeatInfo { in marshal_to()
86 for (idx, p) in self.params.iter().enumerate() { in marshal_to()
98 if idx != self.params.len() - 1 { in marshal_to()
112 for (idx, p) in self.params.iter().enumerate() { in value_length()
115 if idx != self.params.len() - 1 { in value_length()
|
| H A D | chunk_init.rs | 74 pub(crate) params: Vec<Box<dyn Param + Send + Sync>>, field
86 params: self.params.to_vec(), in clone()
112 for (i, param) in self.params.iter().enumerate() { in fmt()
169 let mut params = vec![]; in unmarshal() localVariable
176 params.push(p); in unmarshal()
188 params, in unmarshal()
200 for (idx, p) in self.params.iter().enumerate() { in marshal_to()
212 if idx != self.params.len() - 1 { in marshal_to()
275 for (idx, p) in self.params.iter().enumerate() { in value_length()
278 if idx != self.params.len() - 1 { in value_length()
[all …]
|
| H A D | chunk_heartbeat.rs | 35 pub(crate) params: Vec<Box<dyn Param + Send + Sync>>, field
70 let params = vec![p]; in unmarshal() localVariable
72 Ok(ChunkHeartbeat { params }) in unmarshal()
77 for p in &self.params { in marshal_to()
88 self.params.iter().fold(0, |length, p| { in value_length()
|
| H A D | chunk_test.rs | 598 params: vec![], in test_init_marshal_unmarshal()
602 init_ack.params.push(cookie); in test_init_marshal_unmarshal()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_gather.rs | 81 ¶ms.chan_candidate_tx, in gather_candidates_internal()
82 ¶ms.gathering_state, in gather_candidates_internal()
89 for t in ¶ms.candidate_types { in gather_candidates_internal()
95 mdns_mode: params.mdns_mode, in gather_candidates_internal()
119 urls: params.urls.clone(), in gather_candidates_internal()
170 ¶ms.chan_candidate_tx, in gather_candidates_internal()
171 ¶ms.gathering_state, in gather_candidates_internal()
205 } = params; in gather_candidates_local()
382 } = params; in gather_candidates_local_udp_mux()
460 } = params; in gather_candidates_srflx_mapped()
[all …]
|
| H A D | mod.rs | 447 let params = GatherCandidatesInternalParams { in gather_candidates() localVariable
463 Self::gather_candidates_internal(params).await; in gather_candidates()
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 52 pub(crate) params: SyncMutex<RTCRtpParameters>, field
73 .field("params", &self.params) in fmt()
98 params: Default::default(), in new()
187 pub fn params(&self) -> RTCRtpParameters { in params() method
188 let p = self.params.lock(); in params()
192 pub fn set_params(&self, params: RTCRtpParameters) { in set_params()
193 let mut p = self.params.lock(); in set_params()
194 *p = params; in set_params()
272 let mut params = self.params.lock(); in check_and_update_track() localVariable
273 *params = p; in check_and_update_track()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | certificate.rs | 40 pub fn from_params(params: CertificateParams) -> Result<Self> { in from_params()
41 let not_after = params.not_after; in from_params()
42 let x509_cert = rcgen::Certificate::from_params(params)?; in from_params()
98 let mut params = CertificateParams::new(vec![math_rand_alpha(16)]); in from_key_pair() localVariable
101 params.alg = &rcgen::PKCS_ED25519; in from_key_pair()
103 params.alg = &rcgen::PKCS_ECDSA_P256_SHA256; in from_key_pair()
105 params.alg = &rcgen::PKCS_RSA_SHA256; in from_key_pair()
109 params.key_pair = Some(key_pair); in from_key_pair()
111 RTCCertificate::from_params(params) in from_key_pair()
|
| H A D | mod.rs | 323 let state: NegotiationNeededState = params in do_negotiation_needed_inner()
328 params in do_negotiation_needed_inner()
335 params in do_negotiation_needed_inner()
348 let params2 = params.clone(); in do_negotiation_needed()
349 let _ = params in do_negotiation_needed()
364 params in after_negotiation_needed_op()
388 if !params.ops.is_empty().await { in negotiation_needed_op()
1809 params.ordered = ordered; in create_data_channel()
1824 params.protocol = protocol; in create_data_channel()
1828 if params.protocol.len() > 65535 { in create_data_channel()
[all …]
|
| H A D | peer_connection_internal.rs | 572 let params = params.clone(); in make_negotiation_needed_trigger() localVariable
574 let params = params.clone(); in make_negotiation_needed_trigger() localVariable
696 let params = PopulateSdpParams { in generate_unmatched_sdp() localVariable
709 params, in generate_unmatched_sdp()
812 let params = PopulateSdpParams { in generate_matched_sdp() localVariable
825 params, in generate_matched_sdp()
961 let params = self in handle_incoming_ssrc() localVariable
974 params.codecs[0].payload_type, in handle_incoming_ssrc()
975 params.codecs[0].capability.clone(), in handle_incoming_ssrc()
976 ¶ms.header_extensions, in handle_incoming_ssrc()
[all …]
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | mod.rs | 333 params.dtls_role.to_string(), in add_data_media_section()
340 params.ice_params.password, in add_data_media_section()
347 if params.should_add_candidates { in add_data_media_section()
411 params: AddTransceiverSdpParams, in add_transceiver_sdp()
417 params.should_add_candidates, in add_transceiver_sdp()
418 params.mid_value, in add_transceiver_sdp()
419 params.dtls_role, in add_transceiver_sdp()
420 params.ice_gathering_state, in add_transceiver_sdp()
653 params: PopulateSdpParams, in populate_sdp()
702 params, in populate_sdp()
[all …]
|
| H A D | sdp_test.rs | 534 let params = PopulateSdpParams { in fingerprint_test() localVariable
548 params, in fingerprint_test()
714 let params = PopulateSdpParams { in test_populate_sdp() localVariable
727 params, in test_populate_sdp()
808 let params = PopulateSdpParams { in test_populate_sdp() localVariable
821 params, in test_populate_sdp()
934 let params = PopulateSdpParams { in test_populate_sdp_reject() localVariable
947 params, in test_populate_sdp_reject()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 48 pub fn new(params: UDPMuxConnParams) -> Self { in new()
54 params, in new()
64 &self.inner.params.key in key()
122 if let Some(mux) = self.inner.params.udp_mux.upgrade() { in add_address()
139 params: UDPMuxConnParams, field
195 if let Some(mux) = self.params.udp_mux.upgrade() { in send_to()
233 self.params.local_addr in local_addr()
283 let normalized_target = normalize_socket_addr(&target, &self.inner.params.local_addr); in send_to()
|
| H A D | mod.rs | 69 params: UDPMuxParams, field
85 pub fn new(params: UDPMuxParams) -> Arc<Self> { in new()
89 params, in new()
108 let local_addr = self.params.conn.local_addr()?; in create_muxed_conn()
110 let params = UDPMuxConnParams { in create_muxed_conn() localVariable
116 Ok(UDPMuxConn::new(params)) in create_muxed_conn()
169 let conn = &loop_self.params.conn; in start_conn_worker()
332 self.params in send_to()
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | mod.rs | 35 pub(crate) params: RTCRtpParameters, field
45 &self.params.codecs in codec_parameters()
51 &self.params.header_extensions in header_extensions()
107 params: RTCRtpParameters, field
|
| H A D | track_local_static_rtp.rs | 104 .params in write_rtp_with_extensions()
155 params: t.params.clone(), in bind()
|
| /webrtc/webrtc/src/api/media_engine/ |
| H A D | media_engine_test.rs | 535 let params = in test_media_engine_header_extension_direction() localVariable
538 assert_eq!(params.header_extensions.len(), 1); in test_media_engine_header_extension_direction()
553 let params = in test_media_engine_header_extension_direction() localVariable
556 assert_eq!(params.header_extensions.len(), 1); in test_media_engine_header_extension_direction()
571 let params = in test_media_engine_header_extension_direction() localVariable
574 assert_eq!(params.header_extensions.len(), 0); in test_media_engine_header_extension_direction()
589 let params = in test_media_engine_header_extension_direction() localVariable
592 assert_eq!(params.header_extensions.len(), 1); in test_media_engine_header_extension_direction()
764 let params = in test_extension_id_collision() localVariable
766 dbg!(¶ms); in test_extension_id_collision()
[all …]
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | mod.rs | 94 pub(crate) fn new(params: DataChannelParameters, setting_engine: Arc<SettingEngine>) -> Self { in new()
97 let id = params.negotiated.unwrap_or(0); in new()
105 label: params.label, in new()
106 protocol: params.protocol, in new()
107 negotiated: params.negotiated.is_some(), in new()
109 ordered: params.ordered, in new()
110 max_packet_lifetime: params.max_packet_life_time, in new()
111 max_retransmits: params.max_retransmits, in new()
|
| /webrtc/webrtc/src/api/ |
| H A D | mod.rs | 125 params: DataChannelParameters, in new_data_channel()
128 if params.label.len() > 65535 { in new_data_channel()
132 let d = RTCDataChannel::new(params, Arc::clone(&self.setting_engine)); in new_data_channel()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | mod.rs | 100 pub async fn start(&self, params: &RTCIceParameters, role: Option<RTCIceRole>) -> Result<()> { in start()
163 params.username_fragment.clone(), in start()
164 params.password.clone(), in start()
173 params.username_fragment.clone(), in start()
174 params.password.clone(), in start()
|
| H A D | ice_gatherer.rs | 360 let params = gatherer.get_local_parameters().await?; in test_new_ice_gatherer_success() localVariable
363 !params.username_fragment.is_empty() && !params.password.is_empty(), in test_new_ice_gatherer_success()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 462 pub async fn set_rtp_parameters(&self, params: RTCRtpParameters) { in set_rtp_parameters()
464 for h in ¶ms.header_extensions { in set_rtp_parameters()
472 for (idx, codec) in params.codecs.iter().enumerate() { in set_rtp_parameters()
480 current_track.set_params(params.clone()); in set_rtp_parameters()
746 params: RTCRtpParameters, in receive_for_rid()
753 if let Some(codec) = params.codecs.first() { in receive_for_rid()
756 t.track.set_params(params.clone()); in receive_for_rid()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 337 params: self in replace_track()
364 context.params.codecs = vec![codec]; in replace_track()
388 params: self.media_engine.get_rtp_parameters_by_kind( in send()
410 context.params.codecs = vec![codec]; in send()
|
| /webrtc/dtls/src/crypto/ |
| H A D | mod.rs | 51 let mut params = rcgen::CertificateParams::new(subject_alt_names); in generate_self_signed_with_alg() localVariable
52 params.alg = alg; in generate_self_signed_with_alg()
53 let cert = rcgen::Certificate::from_params(params)?; in generate_self_signed_with_alg()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 645 for param in &i.params { in handle_init()
669 .params in handle_init()
694 params: unrecognized_params_from_init, in handle_init()
702 init_ack.params = vec![Box::new(my_cookie.clone())]; in handle_init()
762 for param in &i.params { in handle_init_ack()
799 if let Some(p) = c.params.first() { in handle_heartbeat()
806 params: vec![Box::new(ParamHeartbeatInfo { in handle_heartbeat()
|