| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_test.rs | 32 assert_eq!(pkts.len(), 1); in test_receiver_interceptor_before_any_packet()
34 if let Some(rr) = pkts[0] in test_receiver_interceptor_before_any_packet()
96 assert_eq!(pkts.len(), 1); in test_receiver_interceptor_after_rtp_packets()
97 if let Some(rr) = pkts[0] in test_receiver_interceptor_after_rtp_packets()
179 assert_eq!(pkts.len(), 1); in test_receiver_interceptor_after_rtp_and_rtcp_packets()
180 if let Some(rr) = pkts[0] in test_receiver_interceptor_after_rtp_and_rtcp_packets()
253 assert_eq!(pkts.len(), 1); in test_receiver_interceptor_overflow()
254 if let Some(rr) = pkts[0] in test_receiver_interceptor_overflow()
358 if let Some(rr) = pkts[0] in test_receiver_interceptor_overflow_five_pkts()
430 if let Some(rr) = pkts[0] in test_receiver_interceptor_packet_loss()
[all …]
|
| H A D | mod.rs | 33 let pkts = rtcp::packet::unmarshal(&mut b)?; in read() localVariable
41 for p in &pkts { in read()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | receiver_test.rs | 33 pkts = stream.written_rtcp() => { in test_twcc_receiver_interceptor_before_any_packets()
80 let pkts = stream.written_rtcp().await.unwrap(); in test_twcc_receiver_interceptor_after_rtp_packets() localVariable
81 assert_eq!(pkts.len(), 1); in test_twcc_receiver_interceptor_after_rtp_packets()
82 if let Some(cc) = pkts[0].as_any().downcast_ref::<TransportLayerCc>() { in test_twcc_receiver_interceptor_after_rtp_packets()
147 let pkts = stream.written_rtcp().await.unwrap(); in test_twcc_receiver_interceptor_different_delays_between_rtp_packets() localVariable
149 assert_eq!(pkts.len(), 1); in test_twcc_receiver_interceptor_different_delays_between_rtp_packets()
150 if let Some(cc) = pkts[0].as_any().downcast_ref::<TransportLayerCc>() { in test_twcc_receiver_interceptor_different_delays_between_rtp_packets()
226 let pkts = stream.written_rtcp().await.unwrap(); in test_twcc_receiver_interceptor_packet_loss() localVariable
228 assert_eq!(pkts.len(), 1); in test_twcc_receiver_interceptor_packet_loss()
315 let pkts = stream.written_rtcp().await.unwrap(); in test_twcc_receiver_interceptor_overflow() localVariable
[all …]
|
| H A D | mod.rs | 131 let pkts = { in run() localVariable
136 if pkts.is_empty() { in run()
140 if let Err(err) = rtcp_writer.write(&pkts, &a).await{ in run()
|
| /webrtc/dtls/src/ |
| H A D | listener.rs | 24 let pkts = match unpack_datagram(packet) { in listen() localVariable
25 Ok(pkts) => { in listen()
26 if pkts.is_empty() { in listen()
29 pkts in listen()
34 let mut reader = BufReader::new(pkts[0].as_slice()); in listen()
|
| H A D | handshaker.rs | 251 Ok(pkts) => { in prepare()
265 self.flights = Some(pkts) in prepare()
271 if let Some(pkts) = &mut self.flights { in prepare()
272 for p in pkts { in prepare()
296 if let Some(pkts) = self.flights.clone() { in send()
297 self.write_packets(pkts).await?; in send()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_test.rs | 34 let pkts = stream.written_rtcp().await.unwrap(); in test_sender_interceptor_before_any_packet() localVariable
35 assert_eq!(pkts.len(), 1); in test_sender_interceptor_before_any_packet()
36 if let Some(sr) = pkts[0] in test_sender_interceptor_before_any_packet()
98 let pkts = stream.written_rtcp().await.unwrap(); in test_sender_interceptor_after_rtp_packets() localVariable
99 assert_eq!(pkts.len(), 1); in test_sender_interceptor_after_rtp_packets()
100 if let Some(sr) = pkts[0] in test_sender_interceptor_after_rtp_packets()
200 let pkts = stream.written_rtcp().await.unwrap(); in test_sender_interceptor_after_rtp_packets_overflow() localVariable
201 assert_eq!(pkts.len(), 1); in test_sender_interceptor_after_rtp_packets_overflow()
202 if let Some(sr) = pkts[0] in test_sender_interceptor_after_rtp_packets_overflow()
|
| /webrtc/dtls/src/record_layer/ |
| H A D | record_layer_test.rs | 62 } else if let Ok(pkts) = dtls_pkts { in test_udp_decode()
64 wanted, pkts, in test_udp_decode()
|
| /webrtc/dtls/src/flight/ |
| H A D | flight6.rs | 76 let mut pkts = vec![Packet { in generate() localVariable
173 pkts.push(Packet { in generate()
187 Ok(pkts) in generate()
|
| H A D | flight5.rs | 199 let mut pkts = vec![]; in generate() localVariable
202 pkts.push(Packet { in generate()
233 pkts.push(Packet { in generate()
304 for p in &mut pkts { in generate()
482 pkts.push(p); in generate()
485 pkts.push(Packet { in generate()
584 pkts.push(Packet { in generate()
598 Ok(pkts) in generate()
|
| H A D | flight4.rs | 532 let mut pkts = vec![Packet { in generate() localVariable
571 pkts.push(Packet { in generate()
639 pkts.push(Packet { in generate()
663 pkts.push(Packet { in generate()
687 pkts.push(Packet { in generate()
710 pkts.push(Packet { in generate()
722 Ok(pkts) in generate()
|
| /webrtc/interceptor/src/twcc/ |
| H A D | mod.rs | 74 let mut pkts = vec![]; in build_feedback_packet() localVariable
80 pkts.push(p); in build_feedback_packet()
88 pkts.push(p); in build_feedback_packet()
89 pkts in build_feedback_packet()
|
| H A D | twcc_test.rs | 396 fn marshal_all(pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>]) -> Result<()> { in marshal_all()
397 for pkt in pkts { in marshal_all()
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 176 pub async fn receive_rtcp(&self, pkts: Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>) { in receive_rtcp()
179 let _ = tx.send(pkts).await; in receive_rtcp()
251 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
254 let _ = self.rtcp_out_modified_tx.send(pkts.to_vec()).await; in write()
263 let pkts = { in read() localVariable
268 let marshaled = rtcp::packet::marshal(&pkts)?; in read()
|
| /webrtc/interceptor/src/ |
| H A D | lib.rs | 134 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
155 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
158 self.0(pkts, attributes).await in write()
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 153 let pkts = rtcp::packet::unmarshal(&mut buf)?; in incoming() localVariable
154 destination_ssrc(&pkts) in incoming()
266 fn destination_ssrc(pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>]) -> Vec<u32> { in destination_ssrc()
268 for p in pkts { in destination_ssrc()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 437 let pkts = vec![Packet { in write() localVariable
452 result = self.write_packets(pkts) => { in write()
458 self.write_packets(pkts).await?; in write()
511 pub(crate) async fn write_packets(&self, pkts: Vec<Packet>) -> Result<()> { in write_packets()
514 self.packet_tx.send((pkts, Some(tx))).await?; in write_packets()
525 mut pkts: Vec<Packet>, in handle_outgoing_packets()
533 for p in &mut pkts { in handle_outgoing_packets()
755 let pkts = unpack_datagram(&buf[..n])?; in read_and_buffer() localVariable
757 for pkt in pkts { in read_and_buffer()
836 pkts: Vec<Vec<u8>>, in handle_queued_packets()
[all …]
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | mod.rs | 109 let pkts = rtcp::packet::unmarshal(&mut b)?; in read() localVariable
110 for p in &pkts { in read()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 234 let pkts = rtcp::packet::unmarshal(&mut buf)?; in read_rtcp() localVariable
236 Ok((pkts, attributes)) in read_rtcp()
249 let pkts = rtcp::packet::unmarshal(&mut buf)?; in read_simulcast_rtcp() localVariable
251 Ok((pkts, attributes)) in read_simulcast_rtcp()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 399 let pkts = rtcp::packet::unmarshal(&mut b)?; in read() localVariable
446 let updates = pkts in read()
622 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
632 let updates = pkts in write()
701 self.rtcp_writer.write(pkts, attributes).await in write()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 75 let pkts = rtcp::packet::unmarshal(&mut buf)?; in read_rtcp() localVariable
77 Ok((pkts, attributes)) in read_rtcp()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 144 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write_rtcp()
148 let raw = rtcp::packet::marshal(pkts)?; in write_rtcp()
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | sample_builder_test.rs | 1450 let pkts = vec![Packet { in test_sample_builder_push_max_zero() localVariable
1464 s.push(pkts[0].clone()); in test_sample_builder_push_max_zero()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 1468 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
1471 Ok(self.dtls_transport.write_rtcp(pkts).await?) in write()
|
| H A D | mod.rs | 1874 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write_rtcp()
1877 Ok(self.interceptor_rtcp_writer.write(pkts, &a).await?) in write_rtcp()
|