| /webrtc/srtp/src/context/ |
| H A D | mod.rs | 25 ssrc: u32, field
36 ssrc: u32, field
163 ssrc, in get_srtp_ssrc_state()
168 self.srtp_ssrc_states.entry(ssrc).or_insert(s); in get_srtp_ssrc_state()
169 self.srtp_ssrc_states.get_mut(&ssrc) in get_srtp_ssrc_state()
174 ssrc, in get_srtcp_ssrc_state()
179 self.srtcp_ssrc_states.get_mut(&ssrc) in get_srtcp_ssrc_state()
183 fn get_roc(&self, ssrc: u32) -> Option<u32> { in get_roc()
188 fn set_roc(&mut self, ssrc: u32, roc: u32) { in set_roc()
195 fn get_index(&self, ssrc: u32) -> Option<usize> { in get_index()
[all …]
|
| H A D | srtcp.rs | 14 let ssrc = u32::from_be_bytes([encrypted[4], encrypted[5], encrypted[6], encrypted[7]]); in decrypt_rtcp() localVariable
17 if let Some(state) = self.get_srtcp_ssrc_state(ssrc) { in decrypt_rtcp()
20 return Err(Error::SrtcpSsrcDuplicated(ssrc, index)); in decrypt_rtcp()
24 return Err(Error::SsrcMissingFromSrtcp(ssrc)); in decrypt_rtcp()
28 let dst = self.cipher.decrypt_rtcp(encrypted, index, ssrc)?; in decrypt_rtcp()
31 if let Some(state) = self.get_srtcp_ssrc_state(ssrc) { in decrypt_rtcp()
47 let ssrc = u32::from_be_bytes([decrypted[4], decrypted[5], decrypted[6], decrypted[7]]); in encrypt_rtcp() localVariable
51 if let Some(state) = self.get_srtcp_ssrc_state(ssrc) { in encrypt_rtcp()
58 return Err(Error::SsrcMissingFromSrtcp(ssrc)); in encrypt_rtcp()
62 self.cipher.encrypt_rtcp(decrypted, index, ssrc) in encrypt_rtcp()
|
| H A D | srtp.rs | 15 if let Some(state) = self.get_srtp_ssrc_state(header.ssrc) { in decrypt_rtp_with_header()
19 header.ssrc, in decrypt_rtp_with_header()
27 return Err(Error::SsrcMissingFromSrtp(header.ssrc)); in decrypt_rtp_with_header()
33 if let Some(state) = self.get_srtp_ssrc_state(header.ssrc) { in decrypt_rtp_with_header()
58 if let Some(state) = self.get_srtp_ssrc_state(header.ssrc) { in encrypt_rtp_with_header()
61 return Err(Error::SsrcMissingFromSrtp(header.ssrc)); in encrypt_rtp_with_header()
70 if let Some(state) = self.get_srtp_ssrc_state(header.ssrc) { in encrypt_rtp_with_header()
|
| H A D | srtcp_test.rs | 8 ssrc: u32, field
26 ssrc: 0x66ef91ff,
43 ssrc: 0x11111111,
60 ssrc: 0x11111111,
77 ssrc: 0x11111111,
120 encrypt_context.set_index(test_case.ssrc, test_case.index); in test_rtcp_lifecycle()
|
| /webrtc/rtcp/src/sender_report/ |
| H A D | sender_report_test.rs | 29 ssrc: 0x902f9e2e, in test_sender_report_unmarshal()
35 ssrc: 0xbc5e9a40, in test_sender_report_unmarshal()
99 ssrc: 0x2b7ec0c5, in test_sender_report_unmarshal()
145 ssrc: 2, in test_sender_report_roundtrip()
159 ssrc: 1, in test_sender_report_roundtrip()
166 ssrc: 2, in test_sender_report_roundtrip()
183 ssrc: 2, in test_sender_report_roundtrip()
185 ssrc: 999, in test_sender_report_roundtrip()
200 ssrc: 2, in test_sender_report_roundtrip()
202 ssrc: 999, in test_sender_report_roundtrip()
[all …]
|
| H A D | mod.rs | 30 pub ssrc: u32, field
64 let mut out = format!("SenderReport from {}\n", self.ssrc); in fmt()
73 rep.ssrc, rep.fraction_lost, rep.total_lost, rep.last_sequence_number in fmt()
96 let mut out: Vec<u32> = self.reports.iter().map(|x| x.ssrc).collect(); in destination_ssrc()
97 out.push(self.ssrc); in destination_ssrc()
186 buf.put_u32(self.ssrc); in marshal_to()
261 let ssrc = raw_packet.get_u32(); in unmarshal() localVariable
285 ssrc, in unmarshal()
|
| /webrtc/rtcp/src/receiver_report/ |
| H A D | receiver_report_test.rs | 19 ssrc: 0x902f9e2e, in test_receiver_report_unmarshal()
21 ssrc: 0xbc5e9a40, in test_receiver_report_unmarshal()
48 ssrc: 0x902f9e2e, in test_receiver_report_unmarshal()
50 ssrc: 0xbc5e9a40, in test_receiver_report_unmarshal()
145 ssrc: 2, in test_receiver_report_roundtrip()
159 ssrc: 1, in test_receiver_report_roundtrip()
162 ssrc: 2, in test_receiver_report_roundtrip()
179 ssrc: 2, in test_receiver_report_roundtrip()
181 ssrc: 999, in test_receiver_report_roundtrip()
196 ssrc: 1, in test_receiver_report_roundtrip()
[all …]
|
| H A D | mod.rs | 20 pub ssrc: u32, field
33 let mut out = format!("ReceiverReport from {}\n", self.ssrc); in fmt()
38 rep.ssrc, rep.fraction_lost, rep.total_lost, rep.last_sequence_number in fmt()
61 self.reports.iter().map(|x| x.ssrc).collect() in destination_ssrc()
139 buf.put_u32(self.ssrc); in marshal_to()
200 let ssrc = raw_packet.get_u32(); in unmarshal() localVariable
220 ssrc, in unmarshal()
|
| /webrtc/rtcp/src/extended_report/ |
| H A D | extended_report_test.rs | 11 ssrc: 0x12345689, in decoded_packet()
20 ssrc: 0x12345689, in decoded_packet()
28 ssrc: 0x98765432, in decoded_packet()
39 ssrc: 0x88888888, in decoded_packet()
44 ssrc: 0x09090909, in decoded_packet()
49 ssrc: 0x11223344, in decoded_packet()
61 ssrc: 0xFEDCBA98, in decoded_packet()
76 ssrc: 0x89ABCDEF, in decoded_packet()
|
| H A D | dlrr.rs | 8 pub ssrc: u32, field
65 let mut ssrc = Vec::with_capacity(self.reports.len()); in destination_ssrc() localVariable
67 ssrc.push(r.ssrc); in destination_ssrc()
69 ssrc in destination_ssrc()
108 buf.put_u32(rep.ssrc); in marshal_to()
138 let ssrc = raw_packet.get_u32(); in unmarshal() localVariable
142 ssrc, in unmarshal()
|
| H A D | prt.rs | 31 pub ssrc: u32, field
60 vec![self.ssrc] in destination_ssrc()
98 buf.put_u32(self.ssrc); in marshal_to()
131 let ssrc = raw_packet.get_u32(); in unmarshal() localVariable
144 ssrc, in unmarshal()
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 126 streams.remove(&ssrc); in close_stream()
151 vec![rtp::header::Header::unmarshal(&mut buf)?.ssrc] in incoming()
157 for ssrc in ssrcs { in incoming()
165 ssrc in incoming()
188 ssrc: u32, in get_or_create_stream()
192 if let Some(stream) = streams.get(&ssrc) { in get_or_create_stream()
196 streams.insert(ssrc, Arc::clone(&stream)); in get_or_create_stream()
203 pub async fn open(&self, ssrc: u32) -> Arc<Stream> { in open()
208 ssrc, in open()
269 for ssrc in p.destination_ssrc() { in destination_ssrc()
[all …]
|
| H A D | session_rtp_test.rs | 89 ssrc: TEST_SSRC, in test_session_srtp_accept()
97 let ssrc = read_stream.get_ssrc(); in test_session_srtp_accept() localVariable
99 ssrc, TEST_SSRC, in test_session_srtp_accept()
128 ssrc: TEST_SSRC, in test_session_srtp_listen()
163 for ssrc in &ssrcs { in test_session_srtp_multi_ssrc()
164 let read_stream = sb.open(*ssrc).await; in test_session_srtp_multi_ssrc()
165 read_streams.insert(*ssrc, read_stream); in test_session_srtp_multi_ssrc()
168 for ssrc in &ssrcs { in test_session_srtp_multi_ssrc()
171 ssrc: *ssrc, in test_session_srtp_multi_ssrc()
189 panic!("ssrc {} not found", *ssrc); in test_session_srtp_multi_ssrc()
[all …]
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 28 ssrc: u32,
312 .entry(info.ssrc) in bind_remote_stream()
335 .entry(info.ssrc) in bind_local_stream()
538 ssrc, in read()
555 ssrc, in read()
566 ssrc, in read()
590 ssrc, in read()
669 ssrc, in write()
681 ssrc, in write()
734 ssrc: packet.header.ssrc, in read()
[all …]
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | receiver_stream.rs | 6 ssrc: u32, field
16 ssrc: u32, in new()
23 ssrc, in new()
49 ssrc: self.ssrc, in read()
|
| /webrtc/srtp/src/ |
| H A D | stream.rs | 15 ssrc: u32, field
23 pub fn new(ssrc: u32, tx: mpsc::Sender<u32>, is_rtp: bool) -> Self { in new()
25 ssrc, in new()
42 self.ssrc in get_ssrc()
84 let _ = self.tx.send(self.ssrc).await; in close()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_test.rs | 23 ssrc: 123456, in test_receiver_interceptor_before_any_packet()
42 ssrc: 123456, in test_receiver_interceptor_before_any_packet()
75 ssrc: 123456, in test_receiver_interceptor_after_rtp_packets()
140 ssrc: 123456, in test_receiver_interceptor_after_rtp_and_rtcp_packets()
169 ssrc: 123456, in test_receiver_interceptor_after_rtp_and_rtcp_packets()
224 ssrc: 123456, in test_receiver_interceptor_overflow()
298 ssrc: 123456, in test_receiver_interceptor_overflow_five_pkts()
400 ssrc: 123456, in test_receiver_interceptor_packet_loss()
460 ssrc: 123456, in test_receiver_interceptor_packet_loss()
511 ssrc: 123456, in test_receiver_interceptor_overflow_and_packet_loss()
[all …]
|
| /webrtc/rtcp/src/payload_feedbacks/full_intra_request/ |
| H A D | full_intra_request_test.rs | 20 ssrc: 0x12345678, in test_full_intra_request_unmarshal()
42 ssrc: 0x12345678, in test_full_intra_request_unmarshal()
46 ssrc: 0x98765432, in test_full_intra_request_unmarshal()
128 ssrc: 3, in test_full_intra_request_round_trip()
140 ssrc: 3, in test_full_intra_request_round_trip()
|
| /webrtc/webrtc/src/peer_connection/policy/ |
| H A D | sdp_semantics.rs | 99 if let Some(ssrc) = fields.first() { in extract_ssrc_list()
100 ssrcs.insert(*ssrc); in extract_ssrc_list()
107 .map(|ssrc| ssrc.to_owned()) in extract_ssrc_list()
|
| /webrtc/rtp/src/packet/ |
| H A D | packet_test.rs | 30 ssrc: 476325762, in test_basic()
195 ssrc: 476325762, in test_rfc_8285_one_byte_extension()
261 ssrc: 476325762, in test_rfc_8285_one_byte_two_extension_of_two_bytes()
396 ssrc: 476325762, in test_rfc_8285_one_byte_multiple_extension()
438 ssrc: 476325762, in test_rfc_8285_two_byte_extension()
549 ssrc: 476325762, in test_rfc8285_two_byte_multiple_extension_with_large_extension()
578 ssrc: 476325762, in test_rfc8285_get_extension_returns_nil_when_extension_disabled()
612 ssrc: 476325762, in test_rfc8285_del_extension()
658 ssrc: 476325762, in test_rfc8285_get_extension_ids()
693 ssrc: 476325762, in test_rfc8285_get_extension_ids_return_empty_when_extension_disabled()
[all …]
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_stream.rs | 12 ssrc: u32, field
33 ssrc: self.ssrc, in generate_report()
57 ssrc: u32, in new()
67 ssrc, in new()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 343 if *ssrc == track.ssrc() { in start_rtp_receivers()
840 ssrc: SSRC, in handle_undeclared_ssrc()
904 ssrc: SSRC, in handle_incoming_ssrc()
973 ssrc, in handle_incoming_ssrc()
1202 ssrc: SSRC, in collect_inbound_stats() field
1223 ssrc: track.ssrc(), in collect_inbound_stats()
1240 let ssrc = info.ssrc; in collect_inbound_stats() localVariable
1276 ssrc, in collect_inbound_stats()
1327 ssrc: SSRC, in collect_outbound_stats() field
1355 ssrc: sender.ssrc, in collect_outbound_stats()
[all …]
|
| /webrtc/srtp/src/cipher/ |
| H A D | cipher_aead_aes_gcm.rs | 86 fn encrypt_rtcp(&mut self, decrypted: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes> { in encrypt_rtcp()
87 let iv = self.rtcp_initialization_vector(srtcp_index, ssrc); in encrypt_rtcp()
106 fn decrypt_rtcp(&mut self, encrypted: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes> { in decrypt_rtcp()
111 let nonce = self.rtcp_initialization_vector(srtcp_index, ssrc); in decrypt_rtcp()
200 BigEndian::write_u32(&mut iv[2..], header.ssrc); in rtp_initialization_vector()
218 pub(crate) fn rtcp_initialization_vector(&self, srtcp_index: usize, ssrc: u32) -> Vec<u8> { in rtcp_initialization_vector()
221 BigEndian::write_u32(&mut iv[2..], ssrc); in rtcp_initialization_vector()
|
| /webrtc/rtp/src/packetizer/ |
| H A D | mod.rs | 62 pub(crate) ssrc: u32, field
76 .field("ssrc", &self.ssrc) in fmt()
87 ssrc: u32, in new_packetizer()
95 ssrc, in new_packetizer()
124 ssrc: self.ssrc, in packetize()
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 50 ssrc: AtomicU32, //SSRC, field
71 .field("ssrc", &self.ssrc) in fmt()
83 ssrc: SSRC, in new()
96 ssrc: AtomicU32::new(ssrc), in new()
163 pub fn ssrc(&self) -> SSRC { in ssrc() method
164 self.ssrc.load(Ordering::SeqCst) in ssrc()
167 pub fn set_ssrc(&self, ssrc: SSRC) { in set_ssrc()
168 self.ssrc.store(ssrc, Ordering::SeqCst); in set_ssrc()
|