| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 14 use crate::track::track_local::{
175 let stream_ids = track in new()
177 .map(|track| vec![track.stream_id().to_string()]) in new()
180 track: Mutex::new(track), in new()
244 let track = self.track.lock().await; in get_parameters() localVariable
284 let track = self.track.lock().await; in track() localVariable
285 track.clone() in track()
323 *t = track; in replace_track()
353 let track = self.track.lock().await; in replace_track() localVariable
369 *t = track; in replace_track()
[all …]
|
| H A D | rtp_sender_test.rs | 12 use crate::track::track_local::track_local_static_sample::TrackLocalStaticSample;
61 receiver.on_track(Box::new(move |track, _, _| { in test_rtp_sender_replace_track()
66 let pkt = match track.read_rtp().await { in test_rtp_sender_replace_track()
77 assert_eq!(track.codec().capability.mime_type, MIME_TYPE_VP8); in test_rtp_sender_replace_track()
80 assert_eq!(track.codec().capability.mime_type, MIME_TYPE_H264); in test_rtp_sender_replace_track()
150 let track = Arc::new(TrackLocalStaticSample::new( in test_rtp_sender_set_read_deadline() localVariable
160 .add_track(Arc::clone(&track) as Arc<dyn TrackLocal + Send + Sync>) in test_rtp_sender_set_read_deadline()
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | track_local_static_sample.rs | 5 use crate::track::RTP_OUTBOUND_MTU;
250 pub struct SampleWriter<'track> {
251 track: &'track TrackLocalStaticSample, field
255 impl<'track> SampleWriter<'track> {
256 pub(super) fn new(track: &'track TrackLocalStaticSample) -> Self { in new()
258 track, in new()
291 self.track in write_sample()
|
| H A D | track_local_static_test.rs | 15 let track: Arc<dyn TrackLocal + Send + Sync> = Arc::new(TrackLocalStaticSample::new( in test_track_local_static_no_codec_intersection() localVariable
37 pc.add_track(Arc::clone(&track)).await?; in test_track_local_static_no_codec_intersection()
77 pc.add_track(Arc::clone(&track)).await?; in test_track_local_static_no_codec_intersection()
240 let track = Arc::new(TrackLocalStaticSample::new( in test_track_local_static_payload_type() localVariable
253 .add_track(Arc::clone(&track) as Arc<dyn TrackLocal + Send + Sync>) in test_track_local_static_payload_type()
258 offerer.on_track(Box::new(move |track, _, _| { in test_track_local_static_payload_type()
261 assert_eq!(track.payload_type(), 100); in test_track_local_static_payload_type()
262 assert_eq!(track.codec().capability.mime_type, MIME_TYPE_VP8); in test_track_local_static_payload_type()
275 vec![track], in test_track_local_static_payload_type()
|
| /webrtc/examples/examples/reflect/ |
| H A D | reflect.rs | 19 use webrtc::track::track_local::track_local_static_rtp::TrackLocalStaticRTP;
20 use webrtc::track::track_local::{TrackLocal, TrackLocalWriter};
199 peer_connection.on_track(Box::new(move |track, _, _| { in main()
202 let media_ssrc = track.ssrc(); in main()
204 if track.kind() == RTPCodecType::Video { in main()
228 let kind = if track.kind() == RTPCodecType::Audio { in main()
244 track.payload_type(), in main()
245 track.codec().capability.mime_type in main()
248 while let Ok((rtp, _)) = track.read_rtp().await { in main()
257 track.payload_type(), in main()
[all …]
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | rtp_receiver_test.rs | 10 use crate::track::track_local::track_local_static_sample::TrackLocalStaticSample;
11 use crate::track::track_local::TrackLocal;
94 if let Some(t) = receiver.track().await { in test_set_rtp_parameters()
167 let track: Arc<dyn TrackLocal + Send + Sync> = Arc::new(TrackLocalStaticSample::new( in test_rtp_receiver_set_read_deadline() localVariable
176 sender.add_track(Arc::clone(&track)).await?; in test_rtp_receiver_set_read_deadline()
180 receiver.on_track(Box::new(move |track, receiver, _| { in test_rtp_receiver_set_read_deadline()
184 let result = tokio::time::timeout(Duration::from_secs(1), track.read_rtp()).await; in test_rtp_receiver_set_read_deadline()
190 let result = tokio::time::timeout(Duration::from_secs(1), track.read_rtp()).await; in test_rtp_receiver_set_read_deadline()
211 if let Some(v) = track.as_any().downcast_ref::<TrackLocalStaticSample>() { in test_rtp_receiver_set_read_deadline()
|
| H A D | mod.rs | 16 use crate::track::track_remote::TrackRemote;
17 use crate::track::{TrackStream, TrackStreams};
202 if t.track.rid() == rid { in read_simulcast()
266 if t.track.tid() == tid { in read_rtp()
478 let current_track = &t.track; in set_rtp_parameters()
751 if t.track.rid() == rid { in receive_for_rid()
752 t.track.set_kind(self.kind); in receive_for_rid()
757 t.track in receive_for_rid()
783 let track = t.clone(); in receive_for_rtx() localVariable
821 stream.track.fire_onmute().await; in pause()
[all …]
|
| /webrtc/constraints/src/ |
| H A D | settings.rs | 2 mod track; module
4 pub use self::track::MediaTrackSettings;
|
| H A D | capabilities.rs | 2 mod track; module
4 pub use self::track::MediaTrackCapabilities;
|
| H A D | constraints.rs | 5 mod track; module
20 track::{
|
| /webrtc/examples/examples/simulcast/ |
| H A D | simulcast.rs | 19 use webrtc::track::track_local::track_local_static_rtp::TrackLocalStaticRTP;
20 use webrtc::track::track_local::{TrackLocal, TrackLocalWriter};
155 peer_connection.on_track(Box::new(move |track, _, _| { in main()
158 let rid = track.rid().to_owned(); in main()
167 let media_ssrc = track.ssrc(); in main()
194 println!("enter track loop {}", track.rid()); in main()
195 while let Ok((rtp, _)) = track.read_rtp().await { in main()
205 println!("exit track loop {}", track.rid()); in main()
|
| H A D | README.md | 3 demonstrates of how to handle incoming track with multiple simulcast rtp streams and show all them …
40 Your browser should send a simulcast track to WebRTC.rs, and then all 3 incoming streams will be re…
|
| /webrtc/examples/examples/swap-tracks/ |
| H A D | swap-tracks.rs | 17 use webrtc::track::track_local::track_local_static_rtp::TrackLocalStaticRTP;
18 use webrtc::track::track_local::{TrackLocal, TrackLocalWriter};
146 peer_connection.on_track(Box::new(move |track, _, _| { in main()
155 track.payload_type(), in main()
156 track.codec().capability.mime_type in main()
161 while let Ok((mut rtp, _)) = track.read_rtp().await { in main()
180 media_ssrc: track.ssrc(), in main()
198 track.payload_type(), in main()
199 track.codec().capability.mime_type in main()
|
| /webrtc/examples/examples/save-to-disk-h264/ |
| H A D | save-to-disk-h264.rs | 22 use webrtc::track::track_remote::TrackRemote;
26 track: Arc<TrackRemote>, in save_to_disk()
31 result = track.read_rtp() => { in save_to_disk()
207 peer_connection.on_track(Box::new(move |track, _, _| { in main()
209 let media_ssrc = track.ssrc(); in main()
236 let codec = track.codec(); in main()
241 let _ = save_to_disk(ogg_writer2, track, notify_rx2).await; in main()
246 let _ = save_to_disk(h264_writer2, track, notify_rx2).await; in main()
|
| /webrtc/examples/examples/save-to-disk-vpx/ |
| H A D | save-to-disk-vpx.rs | 23 use webrtc::track::track_remote::TrackRemote;
27 track: Arc<TrackRemote>, in save_to_disk()
32 result = track.read_rtp() => { in save_to_disk()
232 peer_connection.on_track(Box::new(move |track, _, _| { in main()
234 let media_ssrc = track.ssrc(); in main()
261 let codec = track.codec(); in main()
266 let _ = save_to_disk(ogg_writer2, track, notify_rx2).await; in main()
276 let _ = save_to_disk(ivf_writer2, track, notify_rx2).await; in main()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 11 use crate::track::TrackStream;
503 track.kind(), in new_transceiver_from_track()
512 Some(Arc::clone(&track)), in new_transceiver_from_track()
525 track.kind(), in new_transceiver_from_track()
1025 let track = receiver in handle_incoming_ssrc() localVariable
1042 track, in handle_incoming_ssrc()
1075 if let Some(track) = receiver.track().await { in start_receiver()
1092 track.ssrc(), in start_receiver()
1214 for track in tracks { in collect_inbound_stats()
1341 let track = match sender.track().await { in collect_outbound_stats() localVariable
[all …]
|
| H A D | peer_connection_test.rs | 8 use crate::track::track_local::track_local_static_sample::TrackLocalStaticSample;
230 for track in &tracks { in send_video_until_done()
232 let result = track.write_sample(&Sample{ in send_video_until_done()
293 let track = Arc::new(TrackLocalStaticSample::new( in test_get_stats() localVariable
302 .add_track(track.clone()) in test_get_stats()
307 pc_answer.on_track(Box::new(move |track, _, _| { in test_get_stats()
310 while let Ok((pkt, _)) = track.read_rtp().await { in test_get_stats()
329 vec![track], in test_get_stats()
|
| /webrtc/examples/examples/broadcast/ |
| H A D | broadcast.rs | 16 use webrtc::track::track_local::track_local_static_rtp::TrackLocalStaticRTP;
17 use webrtc::track::track_local::{TrackLocal, TrackLocalWriter};
128 peer_connection.on_track(Box::new(move |track, _, _| { in main()
131 let media_ssrc = track.ssrc(); in main()
158 track.codec().capability, in main()
165 while let Ok((rtp, _)) = track.read_rtp().await { in main()
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | sdp_test.rs | 10 use crate::track::track_local::TrackLocal;
387 assert_eq!(track.kind, RTPCodecType::Audio); in test_track_details_from_sdp()
388 assert_eq!(track.ssrcs[0], 2000); in test_track_details_from_sdp()
389 assert_eq!(track.stream_id, "audio_trk_label"); in test_track_details_from_sdp()
394 assert_eq!(track.kind, RTPCodecType::Video); in test_track_details_from_sdp()
395 assert_eq!(track.ssrcs[0], 3000); in test_track_details_from_sdp()
396 assert_eq!(track.stream_id, "video_trk_label"); in test_track_details_from_sdp()
404 assert_eq!(track.kind, RTPCodecType::Video); in test_track_details_from_sdp()
405 assert_eq!(track.ssrcs[0], 5000); in test_track_details_from_sdp()
406 assert_eq!(track.id, "video_trk_id"); in test_track_details_from_sdp()
[all …]
|
| /webrtc/constraints/src/constraints/ |
| H A D | stream.rs | 6 use super::track::GenericBoolOrMediaTrackConstraints;
49 track::{BoolOrMediaTrackConstraints, MediaTrackConstraints},
|
| /webrtc/webrtc/src/api/ |
| H A D | mod.rs | 26 use crate::track::track_local::TrackLocal;
157 track: Option<Arc<dyn TrackLocal + Send + Sync>>, in new_rtp_sender()
163 track, in new_rtp_sender()
|
| /webrtc/examples/examples/rtp-forwarder/ |
| H A D | rtp-forwarder.rs | 177 peer_connection.on_track(Box::new(move |track, _, _| { in main()
179 let c = if let Some(c) = udp_conns.get(&track.kind().to_string()) { in main()
186 let media_ssrc = track.ssrc(); in main()
211 while let Ok((n, _)) = track.read(&mut b).await { in main()
|
| /webrtc/webrtc/src/ |
| H A D | lib.rs | 30 pub mod track; module
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | mod.rs | 10 use crate::track::track_local::TrackLocal;
260 track: Option<Arc<dyn TrackLocal + Send + Sync>>, in set_sender_track()
263 self.set_sending_track(track).await in set_sender_track()
442 track: Option<Arc<dyn TrackLocal + Send + Sync>>, in set_sending_track()
444 let track_is_none = track.is_none(); in set_sending_track()
447 sender.replace_track(track).await?; in set_sending_track()
|
| /webrtc/webrtc/src/track/ |
| H A D | mod.rs | 26 pub(crate) track: Arc<TrackRemote>, field
|