Home
last modified time | relevance | path

Searched refs:r (Results 1 – 25 of 60) sorted by relevance

123

/webrtc/turn/src/proto/reqtrans/
H A Dreqtrans_test.rs5 let mut r = RequestedTransport { in test_requested_transport_string() localVariable
9 r.to_string(), in test_requested_transport_string()
12 r, in test_requested_transport_string()
15 r.protocol = Protocol(254); in test_requested_transport_string()
16 if r.to_string() != "protocol: 254" { in test_requested_transport_string()
18 r.to_string(), in test_requested_transport_string()
21 r, in test_requested_transport_string()
32 let r = RequestedTransport { in test_requested_transport_add_to() localVariable
35 r.add_to(&mut m)?; in test_requested_transport_add_to()
46 assert_eq!(req, r, "Decoded {req}, expected {r}"); in test_requested_transport_add_to()
/webrtc/dtls/src/crypto/
H A Dcrypto_gcm.rs74 r.extend_from_slice(raw); in encrypt()
75 r.extend_from_slice(&nonce[4..]); in encrypt()
76 r.extend_from_slice(&buffer); in encrypt()
79 let r_len = (r.len() - RECORD_LAYER_HEADER_SIZE) as u16; in encrypt()
83 Ok(r) in encrypt()
86 pub fn decrypt(&self, r: &[u8]) -> Result<Vec<u8>> { in decrypt()
87 let mut reader = Cursor::new(r); in decrypt()
91 return Ok(r.to_vec()); in decrypt()
94 if r.len() <= (RECORD_LAYER_HEADER_SIZE + 8) { in decrypt()
103 let out = &r[RECORD_LAYER_HEADER_SIZE + 8..]; in decrypt()
[all …]
H A Dcrypto_cbc.rs80 let mut r = vec![]; in encrypt() localVariable
81 r.extend_from_slice(raw); in encrypt()
82 r.extend_from_slice(&iv); in encrypt()
83 r.extend_from_slice(&encrypted); in encrypt()
85 let r_len = (r.len() - RECORD_LAYER_HEADER_SIZE) as u16; in encrypt()
89 Ok(r) in encrypt()
92 pub fn decrypt(&self, r: &[u8]) -> Result<Vec<u8>> { in decrypt()
93 let mut reader = Cursor::new(r); in decrypt()
97 return Ok(r.to_vec()); in decrypt()
100 let body = &r[RECORD_LAYER_HEADER_SIZE..]; in decrypt()
[all …]
H A Dpadding.rs81 let r = DtlsPadding::pad_block(&mut block, original_length); in full_block_is_padding_error() localVariable
82 assert!(r.is_err()); in full_block_is_padding_error()
91 let r = DtlsPadding::pad_block(&mut block, original_length); in padding_length_bigger_than_255_is_a_pad_error() localVariable
93 assert!(r.is_err()); in padding_length_bigger_than_255_is_a_pad_error()
99 let r = DtlsPadding::unpad(&[]); in empty_block_is_unpadding_error() localVariable
100 assert!(r.is_err()); in empty_block_is_unpadding_error()
105 let r = DtlsPadding::unpad(&[1]); in padding_too_big_for_block_is_unpadding_error() localVariable
106 assert!(r.is_err()); in padding_too_big_for_block_is_unpadding_error()
118 let r = DtlsPadding::unpad(&block); in one_of_the_padding_bytes_with_value_different_than_padding_length_is_unpadding_error() localVariable
119 assert!(r.is_err()); in one_of_the_padding_bytes_with_value_different_than_padding_length_is_unpadding_error()
H A Dcrypto_ccm.rs134 r.extend_from_slice(raw); in encrypt()
135 r.extend_from_slice(&nonce[4..]); in encrypt()
136 r.extend_from_slice(&buffer); in encrypt()
139 let r_len = (r.len() - RECORD_LAYER_HEADER_SIZE) as u16; in encrypt()
143 Ok(r) in encrypt()
146 pub fn decrypt(&self, r: &[u8]) -> Result<Vec<u8>> { in decrypt()
147 let mut reader = Cursor::new(r); in decrypt()
151 return Ok(r.to_vec()); in decrypt()
154 if r.len() <= (RECORD_LAYER_HEADER_SIZE + 8) { in decrypt()
163 let out = &r[RECORD_LAYER_HEADER_SIZE + 8..]; in decrypt()
[all …]
/webrtc/dtls/src/handshake/
H A Dhandshake_message_certificate.rs24 for r in &self.certificate { in size()
25 len += HANDSHAKE_MESSAGE_CERTIFICATE_LENGTH_FIELD_SIZE + r.len(); in size()
33 for r in &self.certificate { in marshal()
34 payload_size += HANDSHAKE_MESSAGE_CERTIFICATE_LENGTH_FIELD_SIZE + r.len(); in marshal()
40 for r in &self.certificate { in marshal()
42 writer.write_u24::<BigEndian>(r.len() as u32)?; in marshal()
45 writer.write_all(r)?; in marshal()
H A Dhandshake_cache.rs77 for r in rules { in pull()
80 if c.typ == r.typ && c.is_client == r.is_client && c.epoch == r.epoch { in pull()
108 for r in rules { in full_pull_map()
111 if c.typ == r.typ && c.is_client == r.is_client && c.epoch == r.epoch { in full_pull_map()
121 if !r.optional && item.is_none() { in full_pull_map()
127 ci.insert(r.typ, c); in full_pull_map()
133 for r in rules { in full_pull_map()
134 let t = r.typ; in full_pull_map()
/webrtc/media/src/io/ivf_reader/
H A Divf_reader_test.rs35 let r = BufReader::new(&ivf[..]); in test_ivf_reader_parse_valid_file_header() localVariable
36 let (_, header) = IVFReader::new(r)?; in test_ivf_reader_parse_valid_file_header()
76 let r = BufReader::new(&ivf[..]); in test_ivf_reader_parse_valid_frames() localVariable
77 let (mut reader, _) = IVFReader::new(r)?; in test_ivf_reader_parse_valid_frames()
123 let r = BufReader::new(&ivf[..]); in test_ivf_reader_parse_incomplete_frame_header() localVariable
124 let (mut reader, _) = IVFReader::new(r)?; in test_ivf_reader_parse_incomplete_frame_header()
142 let r = BufReader::new(&ivf[..]); in test_ivf_reader_parse_incomplete_frame_payload() localVariable
143 let (mut reader, _) = IVFReader::new(r)?; in test_ivf_reader_parse_incomplete_frame_payload()
155 let r = BufReader::new(&ivf[..]); in test_ivf_reader_eof_when_no_frames_left() localVariable
156 let (mut reader, _) = IVFReader::new(r)?; in test_ivf_reader_eof_when_no_frames_left()
H A Dmod.rs49 let mut r = IVFReader { in new() localVariable
54 let header = r.parse_file_header()?; in new()
56 Ok((r, header)) in new()
/webrtc/turn/src/server/request/
H A Drequest_test.rs75 let mut r = Request::new(l, socket, allocation_manager, Arc::new(TestAuthHandler {})); in test_allocation_lifetime_deletion_zero_lifetime() localVariable
78 let mut nonces = r.nonces.lock().await; in test_allocation_lifetime_deletion_zero_lifetime()
83 src_addr: r.src_addr, in test_allocation_lifetime_deletion_zero_lifetime()
84 dst_addr: r.conn.local_addr()?, in test_allocation_lifetime_deletion_zero_lifetime()
88 r.allocation_manager in test_allocation_lifetime_deletion_zero_lifetime()
91 Arc::clone(&r.conn), in test_allocation_lifetime_deletion_zero_lifetime()
97 assert!(r in test_allocation_lifetime_deletion_zero_lifetime()
110 r.handle_refresh_request(&m).await?; in test_allocation_lifetime_deletion_zero_lifetime()
111 assert!(r in test_allocation_lifetime_deletion_zero_lifetime()
/webrtc/webrtc/src/peer_connection/operation/
H A Doperation_test.rs12 let r = Arc::clone(&results); in test_operations_enqueue() localVariable
15 let r2 = Arc::clone(&r); in test_operations_enqueue()
32 let r = results.lock().await; in test_operations_enqueue() localVariable
33 assert_eq!(r.len(), expected.len()); in test_operations_enqueue()
34 assert_eq!(&*r, &expected); in test_operations_enqueue()
/webrtc/util/src/vnet/router/
H A Drouter_test.rs44 net.set_router(r).await in set_router()
240 r.start().await?; in test_router_standalone_routing()
241 r.push(c).await; in test_router_standalone_routing()
248 r.stop().await?; in test_router_standalone_routing()
337 r.start().await?; in test_router_standalone_add_chunk_filter()
351 r.stop().await?; in test_router_standalone_add_chunk_filter()
421 r.start().await?; in delay_sub_test()
425 r.push(c).await; in delay_sub_test()
434 r.stop().await?; in delay_sub_test()
565 rs.push(r); in test_router_one_child()
[all …]
/webrtc/media/src/io/ogg_reader/
H A Dmod.rs59 let mut r = OggReader { in new() localVariable
66 let header = r.read_headers()?; in new()
68 Ok((r, header)) in new()
192 let mut r = (i as u32) << 24; localVariable
194 if (r & 0x80000000) != 0 {
195 r = (r << 1) ^ POLY;
197 r <<= 1;
200 *t = r;
H A Dogg_reader_test.rs19 let r = Cursor::new(&ogg); in test_ogg_reader_parse_valid_header() localVariable
20 let (_reader, header) = OggReader::new(r, true)?; in test_ogg_reader_parse_valid_header()
35 let r = Cursor::new(&ogg); in test_ogg_reader_parse_next_page() localVariable
36 let (mut reader, _header) = OggReader::new(r, true)?; in test_ogg_reader_parse_next_page()
/webrtc/sdp/src/util/
H A Dutil_test.rs157 let r = new_session_id(); in test_new_session_id() localVariable
159 if r > (1 << 63) - 1 { in test_new_session_id()
162 if r < min { in test_new_session_id()
163 min = r in test_new_session_id()
165 if r > max { in test_new_session_id()
166 max = r in test_new_session_id()
/webrtc/interceptor/src/nack/generator/
H A Dgenerator_test.rs41 let r = timeout_or_fail(Duration::from_millis(10), stream.read_rtp()) in test_generator_interceptor() localVariable
45 assert_eq!(r.header.sequence_number, seq_num); in test_generator_interceptor()
53 let r = timeout_or_fail(Duration::from_millis(10), stream.written_rtcp()) in test_generator_interceptor() localVariable
56 if let Some(p) = r[0].as_any().downcast_ref::<TransportLayerNack>() { in test_generator_interceptor()
/webrtc/util/src/vnet/resolver/
H A Dresolver_test.rs7 let mut r = Resolver::new(); in test_resolver_standalone() localVariable
14 if let Some(resolved) = r.lookup(name.to_owned()).await { in test_resolver_standalone()
25 r.add_host(name.to_owned(), ip_addr.to_owned())?; in test_resolver_standalone()
27 if let Some(resolved) = r.lookup(name.to_owned()).await { in test_resolver_standalone()
/webrtc/mdns/src/message/
H A Dbuilder.rs172 pub fn add_resource(&mut self, r: &mut Resource) -> Result<()> { in add_resource()
175 if let Some(body) = &r.body { in add_resource()
176 r.header.typ = body.real_type(); in add_resource()
182 let (mut msg, len_off) = r.header.pack(msg, &mut self.compression, self.start)?; in add_resource()
184 if let Some(body) = &r.body { in add_resource()
186 r.header.fix_len(&mut msg, len_off, pre_len)?; in add_resource()
H A Dparser.rs197 Ok(r) => a.push(r), in all_answers()
251 Ok(r) => a.push(r), in all_authorities()
305 Ok(r) => a.push(r), in all_additionals()
/webrtc/turn/src/proto/reqfamily/
H A Dreqfamily_test.rs33 let r = REQUESTED_FAMILY_IPV4; in test_requested_address_family_add_to() localVariable
34 r.add_to(&mut m)?; in test_requested_address_family_add_to()
43 assert_eq!(req, r, "Decoded {req}, expected {r}"); in test_requested_address_family_add_to()
/webrtc/rtp/src/extension/video_orientation_extension/
H A Dmod.rs81 let r = b & 0b0011; in unmarshal() localVariable
86 rotation: r.try_into()?, in unmarshal()
95 let r = self.rotation as u8; in marshal_to() localVariable
97 buf.put_u8(c | f | r); in marshal_to()
/webrtc/dtls/src/record_layer/
H A Drecord_layer_test.rs99 let r = RecordLayer::unmarshal(&mut reader)?; in test_record_layer_round_trip() localVariable
102 want, r, in test_record_layer_round_trip()
109 r.marshal(&mut writer)?; in test_record_layer_round_trip()
/webrtc/util/src/vnet/
H A Dresolver.rs22 let mut r = Resolver { in new() localVariable
27 if let Err(err) = r.add_host("localhost".to_owned(), "127.0.0.1".to_owned()) { in new()
30 r in new()
/webrtc/turn/src/proto/chandata/
H A Dchandata_test.rs87 for (name, a, b, r) in tests { in test_channel_data_equal()
89 assert_eq!(v, r, "unexpected: ({name}) {r} != {r}"); in test_channel_data_equal()
155 for (name, buf, r) in tests { in test_is_channel_data()
157 assert_eq!(v, r, "unexpected: ({name}) {r} != {v}"); in test_is_channel_data()
/webrtc/ice/src/rand/
H A Drand_test.rs54 let mut r = rs.lock().await; in test_random_generator_collision() localVariable
55 r.push(s); in test_random_generator_collision()

123