| /webrtc/interceptor/src/ |
| H A D | chain.rs | 20 self.interceptors.push(icpr); in add()
32 for icpr in &self.interceptors { in bind_rtcp_reader()
44 for icpr in &self.interceptors { in bind_rtcp_writer()
57 for icpr in &self.interceptors { in bind_local_stream()
65 for icpr in &self.interceptors { in unbind_local_stream()
66 icpr.unbind_local_stream(info).await; in unbind_local_stream()
77 for icpr in &self.interceptors { in bind_remote_stream()
85 for icpr in &self.interceptors { in unbind_remote_stream()
86 icpr.unbind_remote_stream(info).await; in unbind_remote_stream()
93 for icpr in &self.interceptors { in close()
[all …]
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_test.rs | 16 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_before_any_packet() localVariable
27 icpr, in test_receiver_interceptor_before_any_packet()
79 icpr, in test_receiver_interceptor_after_rtp_packets()
144 icpr, in test_receiver_interceptor_after_rtp_and_rtcp_packets()
228 icpr, in test_receiver_interceptor_overflow()
302 icpr, in test_receiver_interceptor_overflow_five_pkts()
404 icpr, in test_receiver_interceptor_packet_loss()
515 icpr, in test_receiver_interceptor_overflow_and_packet_loss()
585 icpr, in test_receiver_interceptor_reordered_packets()
647 icpr, in test_receiver_interceptor_jitter()
[all …]
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | receiver_test.rs | 16 let icpr = builder.build("")?; in test_twcc_receiver_interceptor_before_any_packets() localVariable
28 icpr, in test_twcc_receiver_interceptor_before_any_packets()
49 let icpr = builder.build("")?; in test_twcc_receiver_interceptor_after_rtp_packets() localVariable
61 icpr, in test_twcc_receiver_interceptor_after_rtp_packets()
105 let icpr = builder.build("")?; in test_twcc_receiver_interceptor_different_delays_between_rtp_packets() localVariable
117 icpr, in test_twcc_receiver_interceptor_different_delays_between_rtp_packets()
177 let icpr = builder.build("")?; in test_twcc_receiver_interceptor_packet_loss() localVariable
189 icpr, in test_twcc_receiver_interceptor_packet_loss()
284 let icpr = builder.build("")?; in test_twcc_receiver_interceptor_overflow() localVariable
296 icpr, in test_twcc_receiver_interceptor_overflow()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_test.rs | 16 let icpr: Arc<dyn Interceptor + Send + Sync> = SenderReport::builder() in test_sender_interceptor_before_any_packet() localVariable
27 icpr, in test_sender_interceptor_before_any_packet()
68 let icpr: Arc<dyn Interceptor + Send + Sync> = SenderReport::builder() in test_sender_interceptor_after_rtp_packets() localVariable
79 icpr, in test_sender_interceptor_after_rtp_packets()
132 let icpr: Arc<dyn Interceptor + Send + Sync> = SenderReport::builder() in test_sender_interceptor_after_rtp_packets_overflow() localVariable
143 icpr, in test_sender_interceptor_after_rtp_packets_overflow()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_test.rs | 11 let icpr: Arc<dyn Interceptor + Send + Sync> = Generator::builder() in test_generator_interceptor() localVariable
26 icpr, in test_generator_interceptor()
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_test.rs | 11 let icpr: Arc<dyn Interceptor + Send + Sync> = in test_responder_interceptor() localVariable
23 icpr, in test_responder_interceptor()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | sender_test.rs | 14 let icpr = builder.build("")?; in test_twcc_sender_interceptor() localVariable
23 let icpr2 = Arc::clone(&icpr); in test_twcc_sender_interceptor()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 858 let icpr: Arc<_> = Arc::new(StatsInterceptor::new("Hello".to_owned())); in test_stats_interceptor_rtp() localVariable
865 icpr.clone(), in test_stats_interceptor_rtp()
874 icpr.clone(), in test_stats_interceptor_rtp()
913 let snapshots = icpr.fetch_inbound_stats(vec![123456]).await; in test_stats_interceptor_rtp()
921 let snapshots = icpr.fetch_outbound_stats(vec![234567]).await; in test_stats_interceptor_rtp()
944 icpr.clone(), in test_stats_interceptor_rtcp()
953 icpr.clone(), in test_stats_interceptor_rtcp()
1041 let snapshots = icpr.fetch_outbound_stats(vec![234567]).await; in test_stats_interceptor_rtcp()
1139 let snapshots = icpr.fetch_inbound_stats(vec![123456]).await; in test_stats_interceptor_rtcp()
1151 let snapshots = icpr.fetch_outbound_stats(vec![234567]).await; in test_stats_interceptor_rtcp()
[all …]
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 966 let icpr = match self.interceptor.upgrade() { in handle_incoming_ssrc() localVariable
980 .streams_for_ssrc(ssrc, &stream_info, &icpr) in handle_incoming_ssrc()
1052 icpr.unbind_remote_stream(&stream_info).await; in handle_incoming_ssrc()
|