Searched refs:tr (Results 1 – 6 of 6) sorted by relevance
| /webrtc/turn/src/client/ |
| H A D | transaction.rs | 25 Some(tr) => (tr.raw.clone(), tr.to.clone()), in on_rtx_timeout()
31 if let Some(tr) = tm.delete(tr_key) { in on_rtx_timeout()
32 if !tr in on_rtx_timeout()
62 if let Some(tr) = tm.delete(tr_key) { in on_rtx_timeout()
63 if !tr in on_rtx_timeout()
248 pub fn insert(&mut self, key: String, tr: Transaction) -> bool { in insert()
249 self.tr_map.insert(key, tr); in insert()
269 for tr in self.tr_map.values_mut() { in close_and_delete_all()
270 tr.close(); in close_and_delete_all()
|
| H A D | mod.rs | 108 let mut tr = Transaction::new(TransactionConfig { in perform_transaction() localVariable
115 let result_ch_rx = tr.get_result_channel(); in perform_transaction()
117 log::trace!("start {} transaction {} to {}", msg.typ, tr_key, tr.to); in perform_transaction()
120 tm.insert(tr_key.clone(), tr); in perform_transaction()
131 if let Some(tr) = tm.get(&tr_key) { in perform_transaction()
132 tr.start_rtx_timer(conn2, tr_map2).await; in perform_transaction()
144 Some(tr) => Ok(tr), in perform_transaction()
353 if let Some(mut tr) = tm.delete(&tr_key) { in handle_stun_message()
355 tr.stop_rtx_timer(); in handle_stun_message()
357 if !tr in handle_stun_message()
[all …]
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | rtp_transceiver_test.rs | 35 let tr = RTCRtpTransceiver::new( in test_rtp_transceiver_set_codec_preferences() localVariable
46 assert_eq!(&tr.get_codecs().await, &media_video_codecs); in test_rtp_transceiver_set_codec_preferences()
87 if let Err(err) = tr.set_codec_preferences(test_case).await { in test_rtp_transceiver_set_codec_preferences()
133 tr.set_codec_preferences(test_case).await?; in test_rtp_transceiver_set_codec_preferences()
136 tr.set_codec_preferences(vec![]).await?; in test_rtp_transceiver_set_codec_preferences()
137 assert_ne!(0, tr.get_codecs().await.len()); in test_rtp_transceiver_set_codec_preferences()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 226 let mut tr = self.rtp_transceiver.lock(); in set_rtp_transceiver() localVariable
227 *tr = rtp_transceiver; in set_rtp_transceiver()
266 let tr = self.rtp_transceiver.lock().clone(); in get_parameters() localVariable
267 if let Some(t) = &tr { in get_parameters()
296 let tr = self.rtp_transceiver.lock(); in replace_track() localVariable
297 if let Some(r) = &*tr { in replace_track()
|
| H A D | rtp_sender_test.rs | 285 let tr = rtp_sender.rtp_transceiver.lock(); in test_rtp_sender_replace_track_invalid_codec_change() localVariable
286 if let Some(t) = &*tr { in test_rtp_sender_replace_track_invalid_codec_change()
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | sdp_test.rs | 691 let tr = RTCRtpTransceiver::new( in test_populate_sdp() localVariable
706 transceivers: vec![tr], in test_populate_sdp()
775 let tr = RTCRtpTransceiver::new( in test_populate_sdp() localVariable
785 tr.set_codec_preferences(vec![RTCRtpCodecParameters { in test_populate_sdp()
800 transceivers: vec![tr], in test_populate_sdp()
|