| /webrtc/examples/examples/insertable-streams/ |
| H A D | README.md | 1 # insertable-streams
3 insertable-streams demonstrates how to use insertable streams with WebRTC.rs.
7 insertable-streams allows the browser to process encoded video. You could implement
18 ### Build insertable-streams
21 cargo build --example insertable-streams
24 ### Open insertable-streams example page
29 ### Run insertable-streams with your browsers SessionDescription as stdin
35 Run `echo $BROWSER_SDP | ./target/debug/examples/insertable-streams`
40 1. Run `./target/debug/examples/insertable-streams < my_file`
42 ### Input insertable-streams's SessionDescription into your browser
[all …]
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | mod.rs | 46 streams: Arc::new(Mutex::new(HashMap::new())), in build()
54 streams: Arc<Mutex<HashMap<u32, Arc<ResponderStream>>>>, field
59 streams: Arc<Mutex<HashMap<u32, Arc<ResponderStream>>>>, in resend_packets()
63 let m = streams.lock().await; in resend_packets()
113 let streams = Arc::clone(&self.internal.streams); in read() localVariable
115 ResponderInternal::resend_packets(streams, nack).await; in read()
172 let mut streams = self.internal.streams.lock().await; in bind_local_stream() localVariable
173 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream()
181 let mut streams = self.internal.streams.lock().await; in unbind_local_stream() localVariable
182 streams.remove(&info.ssrc); in unbind_local_stream()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | mod.rs | 37 streams: Mutex::new(HashMap::new()), in build()
45 streams: Mutex<HashMap<u32, Arc<SenderStream>>>, field
101 let mut streams = self.streams.lock().await; in bind_local_stream() localVariable
102 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream()
110 let mut streams = self.streams.lock().await; in unbind_local_stream() localVariable
111 streams.remove(&info.ssrc); in unbind_local_stream()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 18 pub(crate) streams: Mutex<HashMap<u32, Arc<SenderStream>>>, field
67 let streams:Vec<Arc<SenderStream>> = { in run() localVariable
68 let m = internal.streams.lock().await; in run()
71 for stream in streams { in run()
139 let mut streams = self.internal.streams.lock().await; in bind_local_stream() localVariable
140 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream()
148 let mut streams = self.internal.streams.lock().await; in unbind_local_stream() localVariable
149 streams.remove(&info.ssrc); in unbind_local_stream()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 18 pub(crate) streams: Mutex<HashMap<u32, Arc<ReceiverStream>>>, field
47 let m = self.internal.streams.lock().await; in read()
106 let streams:Vec<Arc<ReceiverStream>> = { in run() localVariable
107 let m = internal.streams.lock().await; in run()
110 for stream in streams { in run()
194 let mut streams = self.internal.streams.lock().await; in bind_remote_stream() localVariable
195 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_remote_stream()
203 let mut streams = self.internal.streams.lock().await; in unbind_remote_stream() localVariable
204 streams.remove(&info.ssrc); in unbind_remote_stream()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_forward_tsn.rs | 31 pub(crate) streams: Vec<ChunkForwardTsnStream>, field
42 for s in &self.streams { in fmt()
74 let mut streams = vec![]; in unmarshal() localVariable
82 streams.push(s); in unmarshal()
87 streams, in unmarshal()
96 for s in &self.streams { in marshal_to()
108 NEW_CUMULATIVE_TSN_LENGTH + FORWARD_TSN_STREAM_LENGTH * self.streams.len() in value_length()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 75 streams: Mutex::new(HashMap::new()), in build()
90 streams: Mutex<HashMap<u32, Arc<GeneratorStream>>>, field
133 let streams = internal.streams.lock().await; in run() localVariable
134 for (ssrc, stream) in streams.iter() { in run()
230 let mut streams = self.internal.streams.lock().await; in bind_remote_stream() localVariable
231 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_remote_stream()
239 let mut receive_logs = self.internal.streams.lock().await; in unbind_remote_stream()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 44 streams: Mutex::new(HashMap::new()), in build()
66 streams: Mutex<HashMap<u32, Arc<ReceiverStream>>>, field
232 let mut streams = self.internal.streams.lock().await; in bind_remote_stream() localVariable
233 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_remote_stream()
241 let mut streams = self.internal.streams.lock().await; in unbind_remote_stream() localVariable
242 streams.remove(&info.ssrc); in unbind_remote_stream()
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 87 assert_eq!(fwdtsn.streams.len(), 1, "there should be one stream"); in test_create_forward_tsn_forward_one_abandoned()
88 assert_eq!(fwdtsn.streams[0].identifier, 1, "si should be 1"); in test_create_forward_tsn_forward_one_abandoned()
89 assert_eq!(fwdtsn.streams[0].sequence, 2, "ssn should be 2"); in test_create_forward_tsn_forward_one_abandoned()
139 assert_eq!(fwdtsn.streams.len(), 2, "there should be two stream"); in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
143 for s in &fwdtsn.streams { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
173 streams: vec![ChunkForwardTsnStream { in test_handle_forward_tsn_forward_3unreceived_chunks()
223 streams: vec![ChunkForwardTsnStream { in test_handle_forward_tsn_forward_1for1_missing()
273 streams: vec![ChunkForwardTsnStream { in test_handle_forward_tsn_forward_1for2_missing()
307 streams: vec![ChunkForwardTsnStream { in test_handle_forward_tsn_dup_forward_tsn_chunk_should_generate_sack()
333 let result = a.streams.get(&s.stream_identifier); in test_assoc_create_new_stream()
[all …]
|
| /webrtc/examples/examples/simulcast/ |
| H A D | README.md | 3 demonstrates of how to handle incoming track with multiple simulcast rtp streams and show all them …
5 The browser will not send higher quality streams unless it has the available bandwidth. You can loo…
40 Your browser should send a simulcast track to WebRTC.rs, and then all 3 incoming streams will be re…
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 125 let mut streams = streams_map.lock().await; in close_stream() localVariable
126 streams.remove(&ssrc); in close_stream()
190 let mut streams = streams_map.lock().await; in get_or_create_stream() localVariable
192 if let Some(stream) = streams.get(&ssrc) { in get_or_create_stream()
196 streams.insert(ssrc, Arc::clone(&stream)); in get_or_create_stream()
|
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 48 streams: Mutex::new(HashMap::new()), in build_rr()
67 streams: Mutex::new(HashMap::new()), in build_sr()
|
| /webrtc/examples/examples/ |
| H A D | README.md | 12 …able-streams): The insertable-streams example demonstrates how webrtc-rs can be used to send E2E e…
16 …rwarder): The rtp-forwarder example demonstrates how to forward your audio/video streams using RTP.
18 …e demonstrates how to accept and demux 1 Track that contains 3 Simulcast streams. It then returns …
|
| /webrtc/constraints/ |
| H A D | README.md | 29 …ediacapture-streams/#dfn-selectsettings">SelectSettings</a> algorithm from the WebRTC/W3C <a href=…
|
| /webrtc/examples/ |
| H A D | Cargo.toml | 78 name = "insertable-streams"
79 path = "examples/insertable-streams/insertable-streams.rs"
|
| /webrtc/examples/examples/rtp-forwarder/ |
| H A D | README.md | 44 …probe -i rtp-forwarder.sdp -protocol_whitelist file,udp,rtp` to get more details about your streams
46 Run `ffplay -i rtp-forwarder.sdp -protocol_whitelist file,udp,rtp` to play your streams
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 76 streams: HashMap<u16, Arc<Stream>>, field
140 streams: HashMap::new(), in new()
301 let s = self.streams.remove(&stream_identifier); in unregister_stream()
1006 for s in self.streams.values() { in get_my_receiver_window_credit()
1073 self.streams.get(&stream_identifier).cloned() in get_or_create_stream()
1416 if let Some(s) = self.streams.get_mut(si) { in handle_sack()
1586 streams: vec![], in create_forward_tsn()
1592 fwd_tsn.streams.push(ChunkForwardTsnStream { in create_forward_tsn()
1701 for forwarded in &c.streams { in handle_forward_tsn()
1712 for s in self.streams.values_mut() { in handle_forward_tsn()
[all …]
|
| /webrtc/examples/examples/swap-tracks/ |
| H A D | README.md | 36 Your browser should send streams to webrtc-rs, and then a stream will be relayed back, changing eve…
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 816 let streams = self.internal.tracks.read().await; in pause() localVariable
818 for stream in streams.iter() { in pause()
834 let streams = self.internal.tracks.read().await; in resume() localVariable
836 for stream in streams.iter() { in resume()
|