| /webrtc/util/src/fixed_big_int/ |
| H A D | mod.rs | 16 for i in (0..self.bits.len()).rev() { in fmt()
52 if i - n_chunk >= 0 { in lsh()
58 if i - n_chunk > 0 { in lsh()
66 self.bits[i as usize] = if n >= 64 { in lsh()
79 if i >= self.n { in bit()
82 let chunk = i / 64; in bit()
83 let pos = i % 64; in bit()
88 pub(crate) fn set_bit(&mut self, i: usize) { in set_bit()
89 if i >= self.n { in set_bit()
92 let chunk = i / 64; in set_bit()
[all …]
|
| /webrtc/stun/src/integrity/ |
| H A D | integrity_test.rs | 9 let i = MessageIntegrity::new_long_term_integrity( in test_message_integrity_add_to_simple() localVariable
18 assert_eq!(i.0, expected, "{}", Error::ErrIntegrityMismatch); in test_message_integrity_add_to_simple()
24 i.add_to(&mut m)?; in test_message_integrity_add_to_simple()
35 i.check(&mut d_m)?; in test_message_integrity_add_to_simple()
39 let result = i.check(&mut d_m); in test_message_integrity_add_to_simple()
59 let result = i.check(&mut m); in test_message_integrity_with_fingerprint()
62 i.add_to(&mut m)?; in test_message_integrity_with_fingerprint()
64 i.check(&mut m)?; in test_message_integrity_with_fingerprint()
67 let result = i.check(&mut m); in test_message_integrity_with_fingerprint()
78 i.add_to(&mut m)?; in test_message_integrity()
[all …]
|
| /webrtc/turn/src/client/binding/ |
| H A D | binding_test.rs | 10 for i in 0..10 { in test_binding_manager_number_assignment()
12 assert_eq!(MIN_CHANNEL_NUMBER + i, n, "should match"); in test_binding_manager_number_assignment()
16 for i in 0..16 { in test_binding_manager_number_assignment()
18 assert_eq!(0x7ff0 + i, n, "should match"); in test_binding_manager_number_assignment()
32 for i in 0..count { in test_binding_manager_method()
33 let addr = SocketAddr::V4(SocketAddrV4::new(lo, 10000 + i)); in test_binding_manager_method()
50 for i in 0..count { in test_binding_manager_method()
51 let addr = SocketAddr::V4(SocketAddrV4::new(lo, 10000 + i)); in test_binding_manager_method()
52 if i % 2 == 0 { in test_binding_manager_method()
56 m.delete_by_number(MIN_CHANNEL_NUMBER + i), in test_binding_manager_method()
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | mod.rs | 88 let mut i = location.head; in too_old() localVariable
89 while i != location.tail { in too_old()
94 i = i.wrapping_add(1); in too_old()
102 while i != location.head { in too_old()
107 i = i.wrapping_sub(1); in too_old()
240 let mut i = self.active.head; in build_sample() localVariable
269 consume.tail = i; in build_sample()
272 i = i.wrapping_add(1); in build_sample()
329 let mut i = consume.head; in build_sample() localVariable
330 while i != consume.tail { in build_sample()
[all …]
|
| H A D | sample_sequence_location.rs | 14 i: u16, field
21 if self.sample.compare(self.i) == Comparison::Inside { in next()
22 let old_i = self.i as usize; in next()
23 self.i = self.i.wrapping_add(1); in next()
78 i: self.head, in range()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_stream.rs | 43 while i != seq { in add()
45 self.del_received(i); in add()
46 i = i.wrapping_add(1); in add()
91 while i != util_plus1 { in missing_seq_numbers()
92 if !self.get_received(i) { in missing_seq_numbers()
95 i = i.wrapping_add(1); in missing_seq_numbers()
118 while i != self.end.wrapping_add(1) && self.get_received(i) { in fix_last_consecutive()
120 i = i.wrapping_add(1); in fix_last_consecutive()
181 let mut i = min; in test_generator_stream() localVariable
184 result.push(i); in test_generator_stream()
[all …]
|
| /webrtc/stun/src/uattrs/ |
| H A D | uattrs_test.rs | 24 for i in 0..a.0.len() { in test_unknown_attributes()
25 assert_eq!(a.0[i], attrs.0[i], "expected {} != {}", a.0[i], attrs.0[i]); in test_unknown_attributes()
|
| /webrtc/mdns/src/message/ |
| H A D | name.rs | 61 for i in 0..data.len() { in pack()
63 if data[i] == b'.' { in pack()
67 if i - begin >= (1 << 6) { in pack()
72 if i - begin == 0 { in pack()
76 msg.push((i - begin) as u8); in pack()
77 msg.extend_from_slice(&data[begin..i]); in pack()
79 begin = i + 1; in pack()
86 if i == 0 || data[i - 1] == b'.' { in pack()
88 let key: String = self.data.chars().skip(i).collect(); in pack()
|
| /webrtc/sdp/src/direction/ |
| H A D | direction_test.rs | 15 for (i, u) in passingtests.iter().enumerate() { in test_new_direction()
17 assert!(u.1 == dir, "{}: {}", i, u.0); in test_new_direction()
35 for (i, u) in tests.iter().enumerate() { in test_direction_string()
36 assert!(u.1 == u.0.to_string(), "{}: {}", i, u.1); in test_direction_string()
|
| /webrtc/stun/src/xoraddr/ |
| H A D | xoraddr_test.rs | 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()
29 for i in 0..dst.len() { in test_xor_safe_bsmaller()
30 assert_eq!(b[i], dst[i], "{} != {}", b[i], dst[i]); in test_xor_safe_bsmaller()
|
| /webrtc/media/benches/ |
| H A D | audio_buffer.rs | 13 let samples = (0..(channels * frames)).map(|i| i as i32).collect(); in benchmark_from()
17 let samples = (0..(channels * frames)).map(|i| i as i32).collect(); in benchmark_from()
|
| /webrtc/ice/src/rand/ |
| H A D | rand_test.rs | 63 for i in 0..N { in test_random_generator_collision()
64 for j in i + 1..N { in test_random_generator_collision()
66 rs[i], rs[j], in test_random_generator_collision()
68 name, rs[i], rs[j], in test_random_generator_collision()
|
| /webrtc/rtp/src/codecs/vp8/ |
| H A D | vp8_test.rs | 32 assert_eq!(pck.i, 0, "I must be 0"); in test_vp8_unmarshal()
42 assert_eq!(pck.i, 1, "I must be 1"); in test_vp8_unmarshal()
52 assert_eq!(pck.i, 0, "I must be 0"); in test_vp8_unmarshal()
62 assert_eq!(pck.i, 0, "I must be 0"); in test_vp8_unmarshal()
72 assert_eq!(pck.i, 0, "I must be 0"); in test_vp8_unmarshal()
84 assert_eq!(pck.i, 1, "I must be 1"); in test_vp8_unmarshal()
96 assert_eq!(pck.i, 1, "I must be 1"); in test_vp8_unmarshal()
168 for (i, payload) in payloads.iter().enumerate() { in test_vp8_payload()
170 assert_eq!(expected[i], actual, "{name}: Generated packet[{i}] differs"); in test_vp8_payload()
|
| /webrtc/util/src/vnet/ |
| H A D | interface.rs | 35 for i in 0..8 { in convert()
36 prefix += (*octet >> (7 - i)) & 0x1; in convert()
45 for i in 0..8 { in convert()
46 prefix += (*octet >> (7 - i)) & 0x1; in convert()
|
| /webrtc/srtp/src/ |
| H A D | key_derivation.rs | 49 for (i, n) in (0..out_len).step_by(n_master_key).enumerate() { in aes_cm_key_derivation()
51 prf_in[n_master_key - 2] = ((i >> 8) & 0xFF) as u8; in aes_cm_key_derivation()
52 prf_in[n_master_key - 1] = (i & 0xFF) as u8; in aes_cm_key_derivation()
88 for i in 0..session_salt.len() { in generate_counter()
89 counter[i] ^= session_salt[i]; in generate_counter()
|
| /webrtc/sctp/src/association/ |
| H A D | association_test.rs | 315 sbuf[i] = (i & 0xff) as u8; in test_assoc_reliable_ordered_reordered()
319 sbufl[i] = (i & 0xff) as u8; in test_assoc_reliable_ordered_reordered()
410 sbuf[i] = (i & 0xff) as u8; in test_assoc_reliable_ordered_fragmented_then_defragmented()
414 sbufl[i] = (i & 0xff) as u8; in test_assoc_reliable_ordered_fragmented_then_defragmented()
477 sbuf[i] = (i & 0xff) as u8; in test_assoc_reliable_unordered_fragmented_then_defragmented()
481 sbufl[i] = (i & 0xff) as u8; in test_assoc_reliable_unordered_fragmented_then_defragmented()
544 sbuf[i] = (i & 0xff) as u8; in test_assoc_reliable_unordered_ordered()
548 sbufl[i] = (i & 0xff) as u8; in test_assoc_reliable_unordered_ordered()
789 sbuf[i] = (i & 0xff) as u8; in test_assoc_unreliable_rexmit_ordered_no_fragment()
874 sbuf[i] = (i & 0xff) as u8; in test_assoc_unreliable_rexmit_ordered_fragment()
[all …]
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_nack/ |
| H A D | mod.rs | 40 let mut i = 0; in next() localVariable
43 if (self.bitfield & (1 << i)) != 0 { in next()
44 self.bitfield &= !(1 << i); in next()
46 return Some(self.packet_id.wrapping_add(i + 1)); in next()
49 i += 1; in next()
186 for i in 0..self.nacks.len() { in marshal_to()
187 buf.put_u16(self.nacks[i].packet_id); in marshal_to()
188 buf.put_u16(self.nacks[i].lost_packets); in marshal_to()
|
| /webrtc/util/src/conn/ |
| H A D | conn_udp_listener_test.rs | 75 for i in 0..BACKLOG as u8 { in test_listener_close_unaccepted()
78 conn.send(&[i]).await?; in test_listener_close_unaccepted()
169 for i in 0..BACKLOG as u8 + 1 { in test_listener_concurrent()
172 conn.send(&[i]).await?; in test_listener_concurrent()
180 for i in 0..BACKLOG as u8 { in test_listener_concurrent()
185 &[i], in test_listener_concurrent()
187 i, in test_listener_concurrent()
188 i, in test_listener_concurrent()
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtp_test.rs | 239 let mut i = 0xFFF0u16; in test_session_srtp_replay_protection() localVariable
240 while i != 0x10 { in test_session_srtp_replay_protection()
241 expected_sequence_number.push(i); in test_session_srtp_replay_protection()
246 sequence_number: i, in test_session_srtp_replay_protection()
256 if i == 0xFFFF { in test_session_srtp_replay_protection()
257 i = 0; in test_session_srtp_replay_protection()
259 i += 1; in test_session_srtp_replay_protection()
271 let mut i = 0; in test_session_srtp_replay_protection() localVariable
272 while i < count { in test_session_srtp_replay_protection()
279 i += 1; in test_session_srtp_replay_protection()
|
| /webrtc/dtls/src/handshake/handshake_cache/ |
| H A D | handshake_cache_test.rs | 324 for i in inputs { in test_handshake_cache_single_push()
325 h.push(i.data, i.epoch, i.message_sequence, i.typ, i.is_client) in test_handshake_cache_single_push()
644 for i in inputs { in test_handshake_cache_session_hash()
645 h.push(i.data, i.epoch, i.message_sequence, i.typ, i.is_client) in test_handshake_cache_session_hash()
|
| /webrtc/sctp/src/queue/ |
| H A D | reassembly_queue.rs | 87 for (i, c) in self.chunks.iter().enumerate() { in is_complete()
88 if i > 0 { in is_complete()
190 for (i, c) in self.unordered_chunks.iter().enumerate() { in find_complete_unordered_chunk_set()
193 start_idx = i as isize; in find_complete_unordered_chunk_set()
329 for (i, c) in self.unordered_chunks.iter().enumerate() { in forward_tsn_for_unordered()
333 last_idx = i as isize; in forward_tsn_for_unordered()
336 for i in 0..(last_idx + 1) as usize { in forward_tsn_for_unordered()
337 self.subtract_num_bytes(self.unordered_chunks[i].user_data.len()); in forward_tsn_for_unordered()
|
| /webrtc/rtp/src/codecs/vp9/ |
| H A D | vp9_test.rs | 24 i: true, in test_vp9_packet_unmarshal()
35 i: true, in test_vp9_packet_unmarshal()
60 i: true, in test_vp9_packet_unmarshal()
77 i: true, in test_vp9_packet_unmarshal()
106 i: true, in test_vp9_packet_unmarshal()
127 i: true, in test_vp9_packet_unmarshal()
316 for i in 0..0x8000 { in test_vp9_payloader_payload()
321 if i > 0 { in test_vp9_payloader_payload()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_stream.rs | 62 for i in self.last_seq_num + 1..pkt.header.sequence_number as i32 { in process_rtp()
63 self.del_received(i as u16); in process_rtp()
96 let mut i = (self.last_report_seq_num + 1) as u16; in generate_report() localVariable
97 while i != self.last_seq_num as u16 { in generate_report()
98 if !self.get_received(i) { in generate_report()
101 i = i.wrapping_add(1); in generate_report()
|
| /webrtc/util/src/vnet/router/ |
| H A D | router_test.rs | 141 for i in 1..255 { in test_router_standalone_assign_ip_address()
201 for i in 0..2 { in test_router_standalone_routing()
207 if i == 1 { in test_router_standalone_routing()
285 for i in 0..2 { in test_router_standalone_add_chunk_filter()
340 for i in 0..3u8 { in test_router_standalone_add_chunk_filter()
381 for i in 0..2 { in delay_sub_test()
387 if i == 1 { in delay_sub_test()
525 for i in 0..2 { in test_router_one_child()
527 cidr: if i == 0 { in test_router_one_child()
540 if i == 1 { in test_router_one_child()
[all …]
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_stream.rs | 39 let mut i = self.last_added.wrapping_add(1); in add() localVariable
40 while i != seq { in add()
41 self.packets[(i % self.size) as usize] = None; in add()
42 i = i.wrapping_add(1); in add()
|