| /webrtc/rtp/src/extension/video_orientation_extension/ |
| H A D | video_orientation_extension_test.rs | 27 dst.resize(a2.marshal_size(), 0); in test_video_orientation_extension_back_facing_camera()
28 a2.marshal_to(&mut dst)?; in test_video_orientation_extension_back_facing_camera()
29 assert_eq!(raw, dst.freeze()); in test_video_orientation_extension_back_facing_camera()
48 a2.marshal_to(&mut dst)?; in test_video_orientation_extension_flip_true()
49 assert_eq!(raw, dst.freeze()); in test_video_orientation_extension_flip_true()
68 a2.marshal_to(&mut dst)?; in test_video_orientation_extension_degree_90()
69 assert_eq!(raw, dst.freeze()); in test_video_orientation_extension_degree_90()
88 a2.marshal_to(&mut dst)?; in test_video_orientation_extension_degree_180()
89 assert_eq!(raw, dst.freeze()); in test_video_orientation_extension_degree_180()
108 a2.marshal_to(&mut dst)?; in test_video_orientation_extension_degree_270()
[all …]
|
| /webrtc/rtp/src/extension/audio_level_extension/ |
| H A D | audio_level_extension_test.rs | 25 let mut dst = BytesMut::with_capacity(a2.marshal_size()); in test_audio_level_extension_voice_true() localVariable
26 dst.resize(a2.marshal_size(), 0); in test_audio_level_extension_voice_true()
27 a2.marshal_to(&mut dst)?; in test_audio_level_extension_voice_true()
28 assert_eq!(raw, dst.freeze()); in test_audio_level_extension_voice_true()
44 let mut dst = BytesMut::with_capacity(a2.marshal_size()); in test_audio_level_extension_voice_false() localVariable
45 dst.resize(a2.marshal_size(), 0); in test_audio_level_extension_voice_false()
46 a2.marshal_to(&mut dst)?; in test_audio_level_extension_voice_false()
47 assert_eq!(raw, dst.freeze()); in test_audio_level_extension_voice_false()
59 let mut dst = BytesMut::with_capacity(a.marshal_size()); in test_audio_level_extension_level_overflow() localVariable
60 dst.resize(a.marshal_size(), 0); in test_audio_level_extension_level_overflow()
[all …]
|
| /webrtc/stun/src/xoraddr/ |
| H A D | xoraddr_test.rs | 8 let mut dst = vec![0; 8]; in test_xor_safe() localVariable
11 safe_xor_bytes(&mut dst, &a, &b); in test_xor_safe()
12 let c = dst.clone(); in test_xor_safe()
13 safe_xor_bytes(&mut dst, &c, &a); in test_xor_safe()
14 for i in 0..dst.len() { in test_xor_safe()
15 assert_eq!(b[i], dst[i], "{} != {}", b[i], dst[i]); in test_xor_safe()
23 let mut dst = vec![0; 5]; in test_xor_safe_bsmaller() localVariable
26 safe_xor_bytes(&mut dst, &a, &b); in test_xor_safe_bsmaller()
27 let c = dst.clone(); in test_xor_safe_bsmaller()
29 for i in 0..dst.len() { in test_xor_safe_bsmaller()
[all …]
|
| /webrtc/util/src/vnet/nat/ |
| H A D | nat_test.rs | 57 let oic = ChunkUdp::new(src, dst); in test_nat_mapping_behavior_full_cone_nat()
67 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_full_cone_nat()
82 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_full_cone_nat()
118 let oic = ChunkUdp::new(src, dst); in test_nat_mapping_behavior_addr_restricted_cone_nat()
137 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_addr_restricted_cone_nat()
152 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_addr_restricted_cone_nat()
197 let oic = ChunkUdp::new(src, dst); in test_nat_mapping_behavior_port_restricted_cone_nat()
216 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_port_restricted_cone_nat()
231 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_port_restricted_cone_nat()
458 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_timeout_outbound_detects_timeout()
[all …]
|
| /webrtc/rtp/src/extension/transport_cc_extension/ |
| H A D | transport_cc_extension_test.rs | 24 let mut dst = BytesMut::with_capacity(t2.marshal_size()); in test_transport_cc_extension() localVariable
25 dst.resize(t2.marshal_size(), 0); in test_transport_cc_extension()
26 t2.marshal_to(&mut dst)?; in test_transport_cc_extension()
27 assert_eq!(raw, dst.freeze()); in test_transport_cc_extension()
|
| /webrtc/util/src/vnet/chunk/ |
| H A D | chunk_test.rs | 26 let dst = SocketAddr::from_str(&(DEMO_IP.to_owned() + ":5678"))?; in test_chunk_udp() localVariable
28 let mut c = ChunkUdp::new(src, dst); in test_chunk_udp()
33 assert!(s.contains(&dst.to_string()), "should include address"); in test_chunk_udp()
35 assert_eq!(c.get_destination_ip(), dst.ip(), "ip should match"); in test_chunk_udp()
57 assert_eq!(cloned.get_destination_ip(), dst.ip(), "ip should match"); in test_chunk_udp()
|
| /webrtc/stun/src/ |
| H A D | xoraddr.rs | 43 fn safe_xor_bytes(dst: &mut [u8], a: &[u8], b: &[u8]) -> usize { in safe_xor_bytes()
48 if dst.len() < n { in safe_xor_bytes()
49 n = dst.len(); in safe_xor_bytes()
52 dst[i] = a[i] ^ b[i]; in safe_xor_bytes()
59 pub fn xor_bytes(dst: &mut [u8], a: &[u8], b: &[u8]) -> usize { in xor_bytes()
63 safe_xor_bytes(dst, a, b) in xor_bytes()
|
| /webrtc/srtp/src/context/ |
| H A D | srtp.rs | 31 let dst = self.cipher.decrypt_rtp(encrypted, header, roc)?; in decrypt_rtp_with_header() localVariable
41 Ok(dst) in decrypt_rtp_with_header()
65 let dst = self in encrypt_rtp_with_header() localVariable
75 Ok(dst) in encrypt_rtp_with_header()
|
| H A D | srtcp.rs | 28 let dst = self.cipher.decrypt_rtcp(encrypted, index, ssrc)?; in decrypt_rtcp() localVariable
38 Ok(dst) in decrypt_rtcp()
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_cc/ |
| H A D | mod.rs | 159 let mut dst = set_nbits_of_uint16(0, 1, 0, 0)?; in marshal_to() localVariable
162 dst = set_nbits_of_uint16(dst, 2, 1, self.packet_status_symbol as u16)?; in marshal_to()
165 dst = set_nbits_of_uint16(dst, 13, 3, self.run_length)?; in marshal_to()
167 buf.put_u16(dst); in marshal_to()
236 let mut dst = set_nbits_of_uint16(0, 1, 0, 1)?; in marshal_to() localVariable
239 dst = set_nbits_of_uint16(dst, 1, 1, self.symbol_size as u16)?; in marshal_to()
245 dst = set_nbits_of_uint16(dst, num_of_bits, index, *s as u16)?; in marshal_to()
248 buf.put_u16(dst); in marshal_to()
|
| /webrtc/dtls/src/crypto/ |
| H A D | padding.rs | 42 fn set(dst: &mut [u8], value: u8) { in set()
47 core::ptr::write_bytes(dst.as_mut_ptr(), value, dst.len()); in set()
|
| /webrtc/turn/src/client/ |
| H A D | transaction.rs | 56 let dst = match SocketAddr::from_str(&tr_to) { in on_rtx_timeout() localVariable
57 Ok(dst) => dst, in on_rtx_timeout()
61 if conn.send_to(&tr_raw, dst).await.is_err() { in on_rtx_timeout()
|
| /webrtc/rtp/src/packet/ |
| H A D | packet_test.rs | 202 let dst = p.marshal()?; in test_rfc_8285_one_byte_extension() localVariable
203 assert_eq!(dst, raw_pkt); in test_rfc_8285_one_byte_extension()
268 let dst = p.marshal()?; in test_rfc_8285_one_byte_two_extension_of_two_bytes() localVariable
269 assert_eq!(dst, raw_pkt); in test_rfc_8285_one_byte_two_extension_of_two_bytes()
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 839 dst: SocketAddr, in build_and_send()
842 let _ = conn.send_to(&msg.raw, dst).await?; in build_and_send()
849 dst: SocketAddr, in build_and_send_err()
853 build_and_send(conn, dst, msg).await?; in build_and_send_err()
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 386 dst: IpAddr, in send_answer()
421 log::trace!("Sent answer to IP {}", dst); in send_answer()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_base.rs | 273 async fn write_to(&self, raw: &[u8], dst: &(dyn Candidate + Send + Sync)) -> Result<usize> { in write_to()
275 let addr = dst.addr(); in write_to()
|
| H A D | mod.rs | 82 async fn write_to(&self, raw: &[u8], dst: &(dyn Candidate + Send + Sync)) -> Result<usize>; in write_to()
|
| /webrtc/stun/benches/ |
| H A D | bench.rs | 603 let mut dst = [0u8; 1024]; in benchmark_xor() localVariable
606 let _ = xor_bytes(&mut dst, &a, &d); in benchmark_xor()
|