Searched refs:rtcp_interceptor (Results 1 – 5 of 5) sorted by relevance
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 32 pub(crate) rtcp_interceptor: Mutex<Option<Arc<dyn RTCPReader + Send + Sync>>>, field
42 let rtcp_interceptor = { in read() localVariable
43 let rtcp_interceptor = self.rtcp_interceptor.lock().await; in read() localVariable
44 rtcp_interceptor.clone() in read()
46 if let Some(rtcp_interceptor) = rtcp_interceptor{ in read()
52 result = rtcp_interceptor.read(b, &a) => { in read()
154 rtcp_interceptor: Mutex::new(None), in new()
169 let rtcp_interceptor = interceptor.bind_rtcp_reader(srtp_rtcp_reader).await; in new() localVariable
171 let mut internal_rtcp_interceptor = internal.rtcp_interceptor.lock().await; in new()
172 *internal_rtcp_interceptor = Some(rtcp_interceptor); in new()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 172 if let Some(rtcp_interceptor) = &t.stream.rtcp_interceptor { in read()
179 result = rtcp_interceptor.read(b, &a) => { in read()
203 if let Some(rtcp_interceptor) = &t.stream.rtcp_interceptor { in read_simulcast()
211 result = rtcp_interceptor.read(b, &a) => { in read_simulcast()
526 … let (stream_info, rtp_read_stream, rtp_interceptor, rtcp_read_stream, rtcp_interceptor) = in receive()
535 let (rtp_read_stream, rtp_interceptor, rtcp_read_stream, rtcp_interceptor) = in receive()
545 Some(rtcp_interceptor), in receive()
566 rtcp_interceptor, in receive()
574 rtcp_interceptor: None, in receive()
592 let (rtp_read_stream, rtp_interceptor, rtcp_read_stream, rtcp_interceptor) = self in receive()
[all …]
|
| /webrtc/webrtc/src/track/ |
| H A D | mod.rs | 19 pub(crate) rtcp_interceptor: Option<Arc<dyn RTCPReader + Send + Sync>>, field
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 978 let (rtp_read_stream, rtp_interceptor, rtcp_read_stream, rtcp_interceptor) = self in handle_incoming_ssrc()
1019 rtcp_interceptor: Some(rtcp_interceptor), in handle_incoming_ssrc()
1034 rtcp_interceptor: Some(rtcp_interceptor), in handle_incoming_ssrc()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 608 let rtcp_interceptor = interceptor.bind_rtcp_reader(rtcp_stream_reader).await; in streams_for_ssrc() localVariable
614 rtcp_interceptor, in streams_for_ssrc()
|