| /webrtc/srtp/src/context/ |
| H A D | srtp_test.rs | 8 sequence_number: u16, field
16 sequence_number: 5000,
23 sequence_number: 5001,
30 sequence_number: 5002,
37 sequence_number: 5003,
44 sequence_number: 5004,
100 sequence_number: test_case.sequence_number, in test_rtp_invalid_auth()
113 test_case.sequence_number in test_rtp_invalid_auth()
129 sequence_number: test_case.sequence_number, in test_rtp_lifecyle()
139 sequence_number: test_case.sequence_number, in test_rtp_lifecyle()
[all …]
|
| H A D | srtp.rs | 17 if !replay_detector.check(header.sequence_number as u64) { in decrypt_rtp_with_header()
20 header.sequence_number, in decrypt_rtp_with_header()
25 roc = state.next_rollover_count(header.sequence_number); in decrypt_rtp_with_header()
37 state.update_rollover_count(header.sequence_number); in decrypt_rtp_with_header()
59 roc = state.next_rollover_count(header.sequence_number); in encrypt_rtp_with_header()
71 state.update_rollover_count(header.sequence_number); in encrypt_rtp_with_header()
|
| H A D | mod.rs | 41 pub fn next_rollover_count(&self, sequence_number: u16) -> u32 { in next_rollover_count()
45 } else if sequence_number == 0 { in next_rollover_count()
54 && sequence_number > (MAX_SEQUENCE_NUMBER - MAX_ROC_DISORDER) in next_rollover_count()
59 } else if sequence_number < MAX_ROC_DISORDER in next_rollover_count()
71 pub fn update_rollover_count(&mut self, sequence_number: u16) { in update_rollover_count()
74 } else if sequence_number == 0 { in update_rollover_count()
83 && sequence_number > (MAX_SEQUENCE_NUMBER - MAX_ROC_DISORDER) in update_rollover_count()
88 } else if sequence_number < MAX_ROC_DISORDER in update_rollover_count()
95 self.last_sequence_number = sequence_number; in update_rollover_count()
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | sample_builder_test.rs | 76 sequence_number: 5000, in test_sample_builder()
93 sequence_number: 5000, in test_sample_builder()
113 sequence_number: 5000, in test_sample_builder()
1235 sequence_number: 0, in test_sample_builder_max_late()
1243 sequence_number: 1, in test_sample_builder_max_late()
1251 sequence_number: 2, in test_sample_builder_max_late()
1270 sequence_number: 5000, in test_sample_builder_max_late()
1278 sequence_number: 5001, in test_sample_builder_max_late()
1286 sequence_number: 5002, in test_sample_builder_max_late()
1307 sequence_number: 6000, in test_sample_builder_max_late()
[all …]
|
| H A D | mod.rs | 201 let sequence_number = p.header.sequence_number; in push() localVariable
202 self.buffer[sequence_number as usize] = Some(p); in push()
203 match self.filled.compare(sequence_number) { in push()
205 self.filled.head = sequence_number; in push()
206 self.filled.tail = sequence_number.wrapping_add(1); in push()
209 self.filled.head = sequence_number; in push()
212 self.filled.tail = sequence_number.wrapping_add(1); in push()
|
| /webrtc/rtp/src/ |
| H A D | sequence.rs | 22 sequence_number: Arc::new(AtomicU16::new(rand::random::<u16>())), in new_random_sequencer()
31 let sequence_number = if s == 0 { u16::MAX } else { s - 1 }; in new_fixed_sequencer() localVariable
34 sequence_number: Arc::new(AtomicU16::new(sequence_number)), in new_fixed_sequencer()
46 sequence_number: Arc<AtomicU16>, field
54 if self.0.sequence_number.load(Ordering::SeqCst) == u16::MAX { in next_sequence_number()
56 self.0.sequence_number.store(0, Ordering::SeqCst); in next_sequence_number()
59 self.0.sequence_number.fetch_add(1, Ordering::SeqCst) + 1 in next_sequence_number()
|
| H A D | header.rs | 44 pub sequence_number: u16, field
92 let sequence_number = raw_packet.get_u16(); in unmarshal() localVariable
191 sequence_number, in unmarshal()
254 buf.put_u16(self.sequence_number); in marshal_to()
|
| /webrtc/interceptor/src/twcc/ |
| H A D | mod.rs | 15 sequence_number: u32, field
45 pub fn record(&mut self, media_ssrc: u32, sequence_number: u16, arrival_time: i64) { in record()
47 if sequence_number < 0x0fff && self.last_sequence_number > 0xf000 { in record()
51 sequence_number: self.cycles | sequence_number as u32, in record()
54 self.last_sequence_number = sequence_number; in record()
67 a.sequence_number.cmp(&b.sequence_number) in build_feedback_packet()
70 (self.received_packets[0].sequence_number & 0xffff) as u16, in build_feedback_packet()
120 fn set_base(&mut self, sequence_number: u16, time_us: i64) { in set_base()
121 self.base_sequence_number = sequence_number; in set_base()
140 fn add_received(&mut self, sequence_number: u16, timestamp_us: i64) -> bool { in add_received()
[all …]
|
| /webrtc/dtls/src/record_layer/ |
| H A D | record_layer_header.rs | 42 pub sequence_number: u64, // uint48 in spec field
48 if self.sequence_number > MAX_SEQUENCE_NUMBER { in marshal()
57 let be: [u8; 8] = self.sequence_number.to_be_bytes(); in marshal()
74 let sequence_number = u64::from_be_bytes(be); in unmarshal() localVariable
86 sequence_number, in unmarshal()
|
| /webrtc/rtcp/src/payload_feedbacks/full_intra_request/ |
| H A D | full_intra_request_test.rs | 21 sequence_number: 0x42, in test_full_intra_request_unmarshal()
43 sequence_number: 0x42, in test_full_intra_request_unmarshal()
47 sequence_number: 0x57, in test_full_intra_request_unmarshal()
129 sequence_number: 42, in test_full_intra_request_round_trip()
141 sequence_number: 57, in test_full_intra_request_round_trip()
|
| H A D | mod.rs | 17 pub sequence_number: u8, field
36 out += format!(" ({} {})", e.ssrc, e.sequence_number).as_str(); in fmt()
105 buf.put_u8(fir.sequence_number); in marshal_to()
148 sequence_number: raw_packet.get_u8(), in unmarshal()
|
| /webrtc/rtp/src/packet/ |
| H A D | packet_test.rs | 28 sequence_number: 27023, in test_basic()
193 sequence_number: 27023, in test_rfc_8285_one_byte_extension()
259 sequence_number: 27023, in test_rfc_8285_one_byte_two_extension_of_two_bytes()
394 sequence_number: 27023, in test_rfc_8285_one_byte_multiple_extension()
436 sequence_number: 27023, in test_rfc_8285_two_byte_extension()
547 sequence_number: 27023, in test_rfc8285_two_byte_multiple_extension_with_large_extension()
576 sequence_number: 27023, in test_rfc8285_get_extension_returns_nil_when_extension_disabled()
610 sequence_number: 27023, in test_rfc8285_del_extension()
656 sequence_number: 27023, in test_rfc8285_get_extension_ids()
691 sequence_number: 27023, in test_rfc8285_get_extension_ids_return_empty_when_extension_disabled()
[all …]
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_stream.rs | 47 self.set_received(pkt.header.sequence_number); in process_rtp()
48 self.last_seq_num = pkt.header.sequence_number as i32; in process_rtp()
49 self.last_report_seq_num = pkt.header.sequence_number as i32 - 1; in process_rtp()
52 self.set_received(pkt.header.sequence_number); in process_rtp()
54 let diff = pkt.header.sequence_number as i32 - self.last_seq_num; in process_rtp()
62 for i in self.last_seq_num + 1..pkt.header.sequence_number as i32 { in process_rtp()
66 self.last_seq_num = pkt.header.sequence_number as i32; in process_rtp()
|
| H A D | receiver_test.rs | 87 sequence_number: i, in test_receiver_interceptor_after_rtp_packets()
152 sequence_number: i, in test_receiver_interceptor_after_rtp_and_rtcp_packets()
245 sequence_number: 0, in test_receiver_interceptor_overflow()
339 sequence_number: 0, in test_receiver_interceptor_overflow_five_pkts()
349 sequence_number: 1, in test_receiver_interceptor_overflow_five_pkts()
411 sequence_number: 0x01, in test_receiver_interceptor_packet_loss()
421 sequence_number: 0x03, in test_receiver_interceptor_packet_loss()
532 sequence_number: 0x01, in test_receiver_interceptor_overflow_and_packet_loss()
593 sequence_number, in test_receiver_interceptor_reordered_packets()
655 sequence_number: 0x01, in test_receiver_interceptor_jitter()
[all …]
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_test.rs | 31 sequence_number: seq_num, in test_responder_interceptor()
41 assert_eq!(p.header.sequence_number, seq_num); in test_responder_interceptor()
61 assert_eq!(p.header.sequence_number, seq_num); in test_responder_interceptor()
|
| H A D | responder_stream.rs | 27 let seq = packet.header.sequence_number; in add()
117 sequence_number: seq, in test_responder_stream()
130 packet.header.sequence_number, seq, in test_responder_stream()
132 seq, packet.header.sequence_number in test_responder_stream()
146 seq, packet.header.sequence_number in test_responder_stream()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | sender_stream.rs | 28 let sequence_number = self.next_sequence_nr.fetch_add(1, Ordering::SeqCst); in write() localVariable
31 transport_sequence: sequence_number as u16, in write()
|
| H A D | sender_test.rs | 44 sequence_number: seq_num, in test_twcc_sender_interceptor()
58 assert_eq!(p.header.sequence_number, seq_num); in test_twcc_sender_interceptor()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_test.rs | 87 sequence_number: i, in test_sender_interceptor_after_rtp_packets()
150 sequence_number: 0xfffd, in test_sender_interceptor_after_rtp_packets_overflow()
160 sequence_number: 0xfffe, in test_sender_interceptor_after_rtp_packets_overflow()
170 sequence_number: 0xffff, in test_sender_interceptor_after_rtp_packets_overflow()
180 sequence_number: 0, in test_sender_interceptor_after_rtp_packets_overflow()
190 sequence_number: 1, in test_sender_interceptor_after_rtp_packets_overflow()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_test.rs | 34 sequence_number: seq_num, in test_generator_interceptor()
45 assert_eq!(r.header.sequence_number, seq_num); in test_generator_interceptor()
|
| /webrtc/media/src/io/ivf_writer/ |
| H A D | ivf_writer_test.rs | 21 sequence_number: 27023, in test_ivf_writer_add_packet_and_close()
48 sequence_number: 27023, in test_ivf_writer_add_packet_and_close()
75 sequence_number: 27023, in test_ivf_writer_add_packet_and_close()
|
| /webrtc/dtls/src/ |
| H A D | state.rs | 60 sequence_number: u64, field
134 let sequence_number = { in serialize() localVariable
153 sequence_number, in serialize()
172 lsn[serialized.local_epoch as usize] = serialized.sequence_number; in deserialize()
|
| /webrtc/dtls/src/crypto/ |
| H A D | crypto_cbc.rs | 65 h.sequence_number, in encrypt()
113 h.sequence_number, in decrypt()
|
| /webrtc/srtp/src/ |
| H A D | key_derivation.rs | 73 sequence_number: u16, in generate_counter()
85 writer.write_u32::<BigEndian>((sequence_number as u32) << 16)?; in generate_counter()
|
| /webrtc/media/src/io/ogg_writer/ |
| H A D | ogg_writer_test.rs | 20 sequence_number: 27023, in test_ogg_writer_add_packet_and_close()
|