| /webrtc/util/src/replay_detector/ |
| H A D | mod.rs | 10 fn check(&mut self, seq: u64) -> bool; in check()
16 seq: u64, field
31 seq: 0, in new()
44 if seq > self.max_seq { in check()
49 if seq <= self.latest_seq { in check()
60 self.seq = seq; in check()
81 seq: u64, field
95 seq: 0, in new()
109 if seq > self.max_seq { in check()
114 if seq != 0 { in check()
[all …]
|
| H A D | replay_detector_test.rs | 267 for (i, seq) in input.iter().enumerate() { in test_replay_detector()
268 let ok = det.check(*seq); in test_replay_detector()
270 out.push(*seq); in test_replay_detector()
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_stream.rs | 27 let seq = packet.header.sequence_number; in add() localVariable
30 self.last_added = seq; in add()
35 let diff = seq.wrapping_sub(self.last_added); in add()
40 while i != seq { in add()
47 self.last_added = seq; in add()
51 let diff = self.last_added.wrapping_sub(seq); in get()
84 internal.get(seq).cloned() in get()
114 let seq = start.wrapping_add(*n); in test_responder_stream() localVariable
117 sequence_number: seq, in test_responder_stream()
127 let seq = start.wrapping_add(*n); in test_responder_stream() localVariable
[all …]
|
| H A D | mod.rs | 76 move |seq: u16| -> Pin<Box<dyn Future<Output = bool> + Send + 'static>> { in resend_packets()
79 if let Some(p) = stream3.get(seq).await { in resend_packets()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_stream.rs | 27 fn add(&mut self, seq: u16) { in add()
29 self.set_received(seq); in add()
30 self.end = seq; in add()
43 while i != seq { in add()
48 self.end = seq; in add()
64 self.set_received(seq); in add()
67 fn get(&self, seq: u16) -> bool { in get()
77 self.get_received(seq) in get()
147 internal.add(seq); in add()
201 rl.add(seq); in test_generator_stream()
[all …]
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_nack/ |
| H A D | mod.rs | 58 pub fn new(seq: u16) -> Self { in new()
60 packet_id: seq, in new()
254 for &seq in seq_nos.iter().skip(1) { in nack_pairs_from_sequence_numbers()
255 if seq == nack_pair.packet_id { in nack_pairs_from_sequence_numbers()
258 if seq <= nack_pair.packet_id || seq > nack_pair.packet_id.saturating_add(16) { in nack_pairs_from_sequence_numbers()
260 nack_pair = NackPair::new(seq); in nack_pairs_from_sequence_numbers()
265 nack_pair.lost_packets |= 1 << (seq - nack_pair.packet_id - 1); in nack_pairs_from_sequence_numbers()
|
| H A D | transport_layer_nack_test.rs | 344 let seq: Vec<_> = (0u16..=17u16).collect(); in test_lost_packets_is_reset_when_crossing_16_bit_boundary() localVariable
346 nack_pairs_from_sequence_numbers(&seq), in test_lost_packets_is_reset_when_crossing_16_bit_boundary()
|
| /webrtc/rtp/src/packetizer/ |
| H A D | packetizer_test.rs | 12 let seq = Box::new(new_random_sequencer()); in test_packetizer() localVariable
15 let mut packetizer = new_packetizer(100, 98, 0x1234ABCD, g722, seq, 90000); in test_packetizer()
96 let seq = Box::new(new_random_sequencer()); in test_packetizer_timestamp_rollover_does_not_panic() localVariable
99 let mut packetizer = new_packetizer(100, 98, 0x1234ABCD, g722, seq, 90000); in test_packetizer_timestamp_rollover_does_not_panic()
|
| /webrtc/dtls/src/flight/ |
| H A D | flight2.rs | 35 let (seq, msgs) = match cache in parse()
48 Ok((seq, msgs)) => (seq, msgs), in parse()
55 state.handshake_recv_sequence = seq; in parse()
|
| H A D | flight1.rs | 46 let (seq, msgs) = match cache in parse()
67 Ok((seq, msgs)) => (seq, msgs), in parse()
105 state.handshake_recv_sequence = seq; in parse()
|
| H A D | flight0.rs | 34 let (seq, msgs) = match cache in parse()
46 Ok((seq, msgs)) => (seq, msgs), in parse()
50 state.handshake_recv_sequence = seq; in parse()
|
| H A D | flight3.rs | 51 if let Ok((seq, msgs)) = cache in parse()
92 state.handshake_recv_sequence = seq; in parse()
163 let (seq, msgs) = match result { in parse()
164 Ok((seq, msgs)) => (seq, msgs), in parse()
168 state.handshake_recv_sequence = seq; in parse()
|
| H A D | flight4.rs | 52 let (seq, msgs) = match cache in parse()
78 Ok((seq, msgs)) => (seq, msgs), in parse()
410 let (seq, msgs) = match cache in parse()
412 seq, in parse()
422 Ok((seq, msgs)) => (seq, msgs), in parse()
427 state.handshake_recv_sequence = seq; in parse()
|
| H A D | flight6.rs | 46 Ok((seq, msgs)) => (seq, msgs), in parse()
|
| H A D | flight5.rs | 58 Ok((seq, msgs)) => (seq, msgs), in parse()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_stream.rs | 28 fn set_received(&mut self, seq: u16) { in set_received()
29 let pos = (seq as usize) % self.packets.len(); in set_received()
33 fn del_received(&mut self, seq: u16) { in del_received()
34 let pos = (seq as usize) % self.packets.len(); in del_received()
38 fn get_received(&self, seq: u16) -> bool { in get_received()
39 let pos = (seq as usize) % self.packets.len(); in get_received()
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_cache.rs | 132 let mut seq = start_seq; in full_pull_map() localVariable
138 if seq as u16 != raw_handshake.handshake_header.message_sequence { in full_pull_map()
144 seq += 1; in full_pull_map()
149 Ok((seq, out)) in full_pull_map()
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtp_test.rs | 273 let seq = payload_srtp(&read_stream, RTP_HEADER_SIZE, &test_payload) in test_session_srtp_replay_protection() localVariable
277 r.push(seq); in test_session_srtp_replay_protection()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 597 let seq = { in process_packet() localVariable
608 if seq > MAX_SEQUENCE_NUMBER { in process_packet()
614 p.record.record_layer_header.sequence_number = seq; in process_packet()
651 let seq = { in process_handshake_packet() localVariable
656 if seq > MAX_SEQUENCE_NUMBER { in process_handshake_packet()
665 sequence_number: seq, in process_handshake_packet()
|