| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_test.rs | 167 stream in test_receiver_interceptor_after_rtp_and_rtcp_packets()
232 stream in test_receiver_interceptor_overflow()
242 stream in test_receiver_interceptor_overflow()
306 stream in test_receiver_interceptor_overflow_five_pkts()
316 stream in test_receiver_interceptor_overflow_five_pkts()
326 stream in test_receiver_interceptor_overflow_five_pkts()
336 stream in test_receiver_interceptor_overflow_five_pkts()
346 stream in test_receiver_interceptor_overflow_five_pkts()
408 stream in test_receiver_interceptor_packet_loss()
418 stream in test_receiver_interceptor_packet_loss()
[all …]
|
| H A D | mod.rs | 46 let stream = { in read() localVariable
50 if let Some(stream) = stream { in read()
51 stream.process_sender_report(now, sr); in read()
110 for stream in streams { in run()
111 let pkt = stream.generate_report(now); in run()
187 let stream = Arc::new(ReceiverStream::new( in bind_remote_stream() localVariable
195 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_remote_stream()
198 stream in bind_remote_stream()
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_test.rs | 14 let stream = MockStream::new( in test_responder_interceptor() localVariable
28 stream in test_responder_interceptor()
38 let p = timeout_or_fail(Duration::from_millis(10), stream.written_rtp()) in test_responder_interceptor()
44 stream in test_responder_interceptor()
59 if let Ok(r) = tokio::time::timeout(Duration::from_millis(50), stream.written_rtp()).await { in test_responder_interceptor()
70 let result = tokio::time::timeout(Duration::from_millis(10), stream.written_rtp()).await; in test_responder_interceptor()
73 stream.close().await?; in test_responder_interceptor()
|
| H A D | mod.rs | 62 let stream = { in resend_packets() localVariable
64 if let Some(stream) = m.get(&nack.media_ssrc) { in resend_packets()
65 stream.clone() in resend_packets()
74 let stream2 = Arc::clone(&stream); in resend_packets()
170 let stream = Arc::new(ResponderStream::new(self.internal.log2_size, writer)); in bind_local_stream() localVariable
173 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream()
176 stream in bind_local_stream()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | srtp_writer_future.rs | 7 use srtp::stream::Stream;
151 *stream = Some(rtcp_read_stream); in init()
169 let stream = { in close() localVariable
171 stream.take() in close()
173 if let Some(rtcp_read_stream) = stream { in close()
182 let stream = { in read() localVariable
184 stream.clone() in read()
186 if let Some(rtcp_read_stream) = stream { in read()
194 let stream = { in read() localVariable
196 stream.clone() in read()
[all …]
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_test.rs | 21 let stream = MockStream::new( in test_sender_interceptor_before_any_packet() localVariable
55 stream.close().await?; in test_sender_interceptor_before_any_packet()
73 let stream = MockStream::new( in test_sender_interceptor_after_rtp_packets() localVariable
84 stream in test_sender_interceptor_after_rtp_packets()
119 stream.close().await?; in test_sender_interceptor_after_rtp_packets()
147 stream in test_sender_interceptor_after_rtp_packets_overflow()
157 stream in test_sender_interceptor_after_rtp_packets_overflow()
167 stream in test_sender_interceptor_after_rtp_packets_overflow()
177 stream in test_sender_interceptor_after_rtp_packets_overflow()
187 stream in test_sender_interceptor_after_rtp_packets_overflow()
[all …]
|
| H A D | mod.rs | 71 for stream in streams { in run()
72 let pkt = stream.generate_report(now).await; in run()
132 let stream = Arc::new(SenderStream::new( in bind_local_stream() localVariable
140 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream()
143 stream in bind_local_stream()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_test.rs | 17 let stream = MockStream::new( in test_generator_interceptor() localVariable
31 stream in test_generator_interceptor()
41 let r = timeout_or_fail(Duration::from_millis(10), stream.read_rtp()) in test_generator_interceptor()
51 let _ = stream.written_rtcp().await; in test_generator_interceptor()
53 let r = timeout_or_fail(Duration::from_millis(10), stream.written_rtcp()) in test_generator_interceptor()
63 stream.close().await?; in test_generator_interceptor()
|
| H A D | mod.rs | 134 for (ssrc, stream) in streams.iter() { in run()
135 let missing = stream.missing_seq_numbers(internal.skip_last_n); in run()
225 let stream = Arc::new(GeneratorStream::new( in bind_remote_stream() localVariable
231 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_remote_stream()
234 stream in bind_remote_stream()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | receiver_test.rs | 18 let stream = MockStream::new( in test_twcc_receiver_interceptor_before_any_packets() localVariable
41 stream.close().await?; in test_twcc_receiver_interceptor_before_any_packets()
51 let stream = MockStream::new( in test_twcc_receiver_interceptor_after_rtp_packets() localVariable
72 stream in test_twcc_receiver_interceptor_after_rtp_packets()
97 stream.close().await?; in test_twcc_receiver_interceptor_after_rtp_packets()
132 stream in test_twcc_receiver_interceptor_different_delays_between_rtp_packets()
169 stream.close().await?; in test_twcc_receiver_interceptor_different_delays_between_rtp_packets()
211 stream in test_twcc_receiver_interceptor_packet_loss()
276 stream.close().await?; in test_twcc_receiver_interceptor_packet_loss()
307 stream in test_twcc_receiver_interceptor_overflow()
[all …]
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 43 stream: Arc<Stream>, field
56 stream, in new()
67 let stream = association in dial() localVariable
71 Self::client(stream, config).await in dial()
83 let stream = association in accept() localVariable
91 ch.stream in accept()
114 stream in client()
283 .stream in write_data_channel()
300 .stream in write_data_channel_ack()
324 self.stream.buffered_amount() in buffered_amount()
[all …]
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 11 stream::*,
158 let (stream, is_new) = in incoming()
170 match stream.buffer.write(&decrypted).await { in incoming()
192 if let Some(stream) = streams.get(&ssrc) { in get_or_create_stream()
193 (Arc::clone(stream), false) in get_or_create_stream()
196 streams.insert(ssrc, Arc::clone(&stream)); in get_or_create_stream()
197 (stream, true) in get_or_create_stream()
204 let (stream, _) = Session::get_or_create_stream( in open()
212 stream in open()
219 if let Some(stream) = result { in accept()
[all …]
|
| /webrtc/sctp/examples/ |
| H A D | ping.rs | 3 use webrtc_sctp::stream::*;
74 let stream = a.open_stream(0, PayloadProtocolIdentifier::String).await?; in main() localVariable
78 stream.set_reliability_params(true, ReliabilityType::Timed, 10); in main()
80 let stream_tx = Arc::clone(&stream); in main()
96 let stream_rx = Arc::clone(&stream); in main()
112 stream.shutdown(Shutdown::Both).await?; in main()
|
| H A D | pong.rs | 2 use webrtc_sctp::stream::*;
73 let stream = a.accept_stream().await.unwrap(); in main() localVariable
77 stream.set_reliability_params(true, ReliabilityType::Timed, 10); in main()
80 let stream2 = Arc::clone(&stream); in main()
103 stream.shutdown(Shutdown::Both).await?; in main()
|
| H A D | throughput.rs | 8 use webrtc_sctp::stream::*;
73 let stream = a.accept_stream().await.unwrap(); in main() localVariable
77 stream.set_reliability_params(true, ReliabilityType::Rexmit, 0); in main()
84 while let Ok(n) = stream.read(&mut buff).await { in main()
119 let stream = a in main() localVariable
132 while stream.write(&bytes).await.is_ok() { in main()
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 585 stream: Arc<Stream>, field
608 stream, in new()
619 self.stream in into_inner()
625 self.stream.clone() in clone_inner()
630 self.stream.stream_identifier in stream_identifier()
672 let stream = self.stream.clone(); in poll_read() localVariable
743 let stream = self.stream.clone(); in poll_write() localVariable
753 let stream = self.stream.clone(); in poll_write() localVariable
760 let stream = self.stream.clone(); in poll_write() localVariable
814 let stream = self.stream.clone(); in poll_shutdown() localVariable
[all …]
|
| /webrtc/webrtc/src/track/ |
| H A D | mod.rs | 16 pub(crate) rtp_read_stream: Option<Arc<srtp::stream::Stream>>,
18 pub(crate) rtcp_read_stream: Option<Arc<srtp::stream::Stream>>,
27 pub(crate) stream: TrackStream, field
|
| /webrtc/constraints/src/ |
| H A D | settings.rs | 1 mod stream; module
6 pub(crate) use self::stream::MediaStreamSettings;
|
| H A D | capabilities.rs | 1 mod stream; module
6 pub(crate) use self::stream::MediaStreamCapabilities;
|
| H A D | constraints.rs | 4 mod stream; module
19 stream::MediaStreamConstraints,
|
| /webrtc/srtp/src/cipher/ |
| H A D | cipher_aes_cm_hmac_sha1.rs | 192 let mut stream = Aes128Ctr::new(key, nonce); in encrypt_rtp() localVariable
194 stream.apply_keystream(&mut writer[payload_offset..]); in encrypt_rtp()
241 let mut stream = Aes128Ctr::new(key, nonce); in decrypt_rtp() localVariable
243 stream.seek(0); in decrypt_rtp()
244 stream.apply_keystream(&mut writer[payload_offset..]); in decrypt_rtp()
266 let mut stream = Aes128Ctr::new(key, nonce); in encrypt_rtcp() localVariable
268 stream.apply_keystream( in encrypt_rtcp()
323 let mut stream = Aes128Ctr::new(key, nonce); in decrypt_rtcp() localVariable
325 stream.seek(0); in decrypt_rtcp()
326 stream.apply_keystream( in decrypt_rtcp()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | sender_test.rs | 26 let stream = MockStream::new( in test_twcc_sender_interceptor() localVariable
41 stream in test_twcc_sender_interceptor()
56 p = stream.written_rtp() =>{ in test_twcc_sender_interceptor()
70 let _ = stream.close().await; in test_twcc_sender_interceptor()
|
| H A D | mod.rs | 94 let stream = Arc::new(SenderStream::new( in bind_local_stream() localVariable
102 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream()
105 stream in bind_local_stream()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 172 if let Some(rtcp_interceptor) = &t.stream.rtcp_interceptor { in read()
267 rtp_interceptor = t.stream.rtp_interceptor.clone(); in read_rtp()
474 if let Some(stream_info) = &mut t.stream.stream_info { in set_rtp_parameters()
561 stream: TrackStream { in receive()
717 if let Some(stream_info) = &t.stream.stream_info { in stop()
747 stream: TrackStream, in receive_for_rid()
759 t.stream = stream; in receive_for_rid()
818 for stream in streams.iter() { in pause()
821 stream.track.fire_onmute().await; in pause()
836 for stream in streams.iter() { in resume()
[all …]
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 46 let stream = Arc::new(MockStream { in new() localVariable
67 .bind_rtcp_writer(Arc::clone(&stream) as Arc<dyn RTCPWriter + Send + Sync>) in new()
70 let mut rw = stream.rtcp_writer.lock().await; in new()
76 Arc::clone(&stream) as Arc<dyn RTPWriter + Send + Sync>, in new()
80 let mut rw = stream.rtp_writer.lock().await; in new()
85 .bind_rtcp_reader(Arc::clone(&stream) as Arc<dyn RTCPReader + Send + Sync>) in new()
117 Arc::clone(&stream) as Arc<dyn RTPReader + Send + Sync>, in new()
147 stream in new()
|