Searched refs:rtcp_read_stream (Results 1 – 6 of 6) sorted by relevance
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | srtp_writer_future.rs | 150 let mut stream = self.rtcp_read_stream.lock().await; in init()
151 *stream = Some(rtcp_read_stream); in init()
170 let mut stream = self.rtcp_read_stream.lock().await; in close()
173 if let Some(rtcp_read_stream) = stream { in close()
174 Ok(rtcp_read_stream.close().await?) in close()
183 let stream = self.rtcp_read_stream.lock().await; in read()
186 if let Some(rtcp_read_stream) = stream { in read()
187 return Ok(rtcp_read_stream.read(b).await?); in read()
195 let stream = self.rtcp_read_stream.lock().await; in read()
198 if let Some(rtcp_read_stream) = stream { in read()
[all …]
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 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()
544 Some(rtcp_read_stream), in receive()
565 rtcp_read_stream, in receive()
573 rtcp_read_stream: None, in receive()
592 let (rtp_read_stream, rtp_interceptor, rtcp_read_stream, rtcp_interceptor) = self in receive()
604 rtcp_read_stream: Some(rtcp_read_stream), in receive()
693 if let Some(rtcp_read_stream) = &t.stream.rtcp_read_stream { in stop()
694 if let Err(err) = rtcp_read_stream.close().await { in stop()
705 if let Some(repair_rtcp_read_stream) = &t.repair_stream.rtcp_read_stream { in stop()
|
| /webrtc/webrtc/src/track/ |
| H A D | mod.rs | 18 pub(crate) rtcp_read_stream: Option<Arc<srtp::stream::Stream>>, field
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 606 let rtcp_read_stream = srtcp_session.open(ssrc).await; in streams_for_ssrc() localVariable
607 let rtcp_stream_reader = Arc::clone(&rtcp_read_stream) as Arc<dyn RTCPReader + Send + Sync>; in streams_for_ssrc()
613 rtcp_read_stream, in streams_for_ssrc()
|
| /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()
1018 rtcp_read_stream: Some(rtcp_read_stream), in handle_incoming_ssrc()
1033 rtcp_read_stream: Some(rtcp_read_stream), in handle_incoming_ssrc()
1051 let _ = rtcp_read_stream.close().await; in handle_incoming_ssrc()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 163 rtcp_read_stream: Mutex::new(None), in new()
|