| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | rtp_sender_test.rs | 51 let rtp_sender = sender in test_rtp_sender_replace_track()
88 signal_pair(&mut sender, &mut receiver).await?; in test_rtp_sender_replace_track()
118 close_pair_now(&sender, &receiver).await; in test_rtp_sender_replace_track()
136 let sender = rtp_transceiver.sender(); in test_rtp_sender_get_parameters() localVariable
159 let rtp_sender = sender in test_rtp_sender_set_read_deadline()
165 &mut sender, in test_rtp_sender_set_read_deadline()
188 close_pair_now(&sender, &receiver).await; in test_rtp_sender_set_read_deadline()
219 let rtp_sender = sender in test_rtp_sender_replace_track_invalid_track_kind_change()
250 close_pair_now(&sender, &receiver).await; in test_rtp_sender_replace_track_invalid_track_kind_change()
280 let rtp_sender = sender in test_rtp_sender_replace_track_invalid_codec_change()
[all …]
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | mod.rs | 197 sender: Arc<RTCRtpSender>, in new()
209 sender: SyncMutex::new(sender), in new()
252 let sender = self.sender.lock(); in sender() localVariable
253 sender.clone() in sender()
262 self.set_sender(sender); in set_sender_track()
273 let mut sender = self.sender.lock(); in set_sender() localVariable
274 *sender = s; in set_sender()
411 let sender = &*self.sender.lock(); in process_new_current_direction() localVariable
427 let sender = self.sender.lock(); in stop() localVariable
428 sender.stop().await?; in stop()
[all …]
|
| H A D | rtp_transceiver_test.rs | 30 let sender = Arc::new( in test_rtp_transceiver_set_codec_preferences() localVariable
37 sender, in test_rtp_transceiver_set_codec_preferences()
|
| /webrtc/webrtc/src/api/interceptor_registry/ |
| H A D | mod.rs | 11 use interceptor::report::{receiver::ReceiverReport, sender::SenderReport};
12 use interceptor::twcc::{receiver::Receiver, sender::Sender};
33 let sender = Box::new(SenderReport::builder()); in configure_rtcp_reports() localVariable
35 registry.add(sender); in configure_rtcp_reports()
96 let sender = Box::new(Sender::builder()); in configure_twcc() localVariable
98 registry.add(sender); in configure_twcc()
125 let sender = Box::new(Sender::builder()); in configure_twcc_sender_only() localVariable
126 registry.add(sender); in configure_twcc_sender_only()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | rtp_receiver_test.rs | 71 let (mut sender, mut receiver, wan) = create_vnet_pair().await?; in test_set_rtp_parameters()
82 sender.add_track(Arc::clone(&outgoing_track)).await?; in test_set_rtp_parameters()
130 until_connection_state(&mut sender, &wg, RTCPeerConnectionState::Connected).await; in test_set_rtp_parameters()
133 signal_pair(&mut sender, &mut receiver).await?; in test_set_rtp_parameters()
156 close_pair_now(&sender, &receiver).await; in test_set_rtp_parameters()
165 let (mut sender, mut receiver, wan) = create_vnet_pair().await?; in test_rtp_receiver_set_read_deadline()
176 sender.add_track(Arc::clone(&track)).await?; in test_rtp_receiver_set_read_deadline()
204 until_connection_state(&mut sender, &wg, RTCPeerConnectionState::Connected).await; in test_rtp_receiver_set_read_deadline()
207 signal_pair(&mut sender, &mut receiver).await?; in test_rtp_receiver_set_read_deadline()
227 close_pair_now(&sender, &receiver).await; in test_rtp_receiver_set_read_deadline()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | mod.rs | 472 let sender = t.sender(); in check_negotiation_needed() localVariable
1395 sender, in set_remote_description()
1588 let sender = transceiver.sender(); in start_rtp_senders() localVariable
1589 if sender.is_negotiated() && !sender.has_sent() { in start_rtp_senders()
1590 sender.send(&sender.get_parameters().await).await?; in start_rtp_senders()
1646 let sender = transceiver.sender(); in get_senders() localVariable
1647 senders.push(sender); in get_senders()
1681 let sender = t.sender(); in add_track() localVariable
1694 return Ok(sender); in add_track()
1708 Ok(transceiver.sender()) in add_track()
[all …]
|
| H A D | peer_connection_internal.rs | 459 let sender = Arc::new( in add_transceiver_from_kind() localVariable
473 sender, in add_transceiver_from_kind()
669 t.sender().set_negotiated(); in generate_unmatched_sdp()
758 t.sender().set_negotiated(); in generate_matched_sdp()
783 t.sender().set_negotiated(); in generate_matched_sdp()
1334 let sender = transceiver.sender(); in collect_outbound_stats() localVariable
1341 let track = match sender.track().await { in collect_outbound_stats()
1355 ssrc: sender.ssrc, in collect_outbound_stats()
|
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 8 pub mod sender; module
13 use sender::{SenderReport, SenderReportInternal};
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | mod.rs | 464 if t.sender().track().await.is_some() { in add_transceiver_sdp()
531 let sender = mt.sender(); in add_transceiver_sdp() localVariable
532 if let Some(track) = sender.track().await { in add_transceiver_sdp()
534 sender.ssrc, in add_transceiver_sdp()
543 if sender.initial_track_id().is_none() { in add_transceiver_sdp()
544 for stream_id in sender.associated_media_stream_ids() { in add_transceiver_sdp()
549 sender.set_initial_track_id(track.id().to_string())?; in add_transceiver_sdp()
554 if let Some(track_id) = sender.initial_track_id() { in add_transceiver_sdp()
566 for stream_id in sender.associated_media_stream_ids() { in add_transceiver_sdp()
|
| H A D | sdp_test.rs | 686 let sender = Arc::new( in test_populate_sdp() localVariable
693 sender, in test_populate_sdp()
770 let sender = Arc::new( in test_populate_sdp() localVariable
777 sender, in test_populate_sdp()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 5 use crate::twcc::sender::TRANSPORT_CC_URI;
|
| /webrtc/interceptor/src/twcc/ |
| H A D | mod.rs | 5 pub mod sender; module
|
| /webrtc/examples/examples/ |
| H A D | README.md | 18 …contains 3 Simulcast streams. It then returns the media as 3 independent Tracks back to the sender.
|
| /webrtc/webrtc/ |
| H A D | CHANGELOG.md | 20 * Change `RTCRtpTransceiver::sender` signature to `|&self| -> Arc<RTCRtpSender>` [#377](https://git…
22 * Change `RTCRtpTransceiver::set_sender_track` signature to `|self: &Arc<Self>, sender: Arc<RTCRtpS…
41 - `sender`;
|