| /webrtc/examples/examples/ice-restart/ |
| H A D | ice-restart.rs | 72 let pc = { in do_signaling() localVariable
74 if let Some(pc) = &*peer_connection { in do_signaling()
75 Arc::clone(pc) in do_signaling()
108 let pc = Arc::new(pc); in do_signaling() localVariable
112 pc.on_ice_connection_state_change(Box::new( in do_signaling()
120 pc.on_data_channel(Box::new(|d: Arc<RTCDataChannel>| { in do_signaling()
137 *peer_connection = Some(Arc::clone(&pc)); in do_signaling()
138 pc in do_signaling()
151 if let Err(err) = pc.set_remote_description(offer).await { in do_signaling()
159 let answer = match pc.create_answer(None).await { in do_signaling()
[all …]
|
| /webrtc/examples/examples/play-from-disk-renegotiation/ |
| H A D | play-from-disk-renegotiation.rs | 65 let pc = { in remote_handler() localVariable
91 pc: &Arc<RTCPeerConnection>, in do_signaling()
149 pc: &Arc<RTCPeerConnection>, in create_peer_connection()
155 pc.connection_state() in create_peer_connection()
160 do_signaling(pc, r).await in create_peer_connection()
165 pc: &Arc<RTCPeerConnection>, in add_video()
177 let rtp_sender = match pc in add_video()
206 do_signaling(pc, r).await in add_video()
211 pc: &Arc<RTCPeerConnection>, in remove_video()
214 let senders = pc.get_senders().await; in remove_video()
[all …]
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | track_local_static_test.rs | 30 let mut pc = api.new_peer_connection(RTCConfiguration::default()).await?; 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()
39 if let Err(err) = signal_pair(&mut pc, &mut no_codec_pc).await { in test_track_local_static_no_codec_intersection()
45 close_pair_now(&no_codec_pc, &pc).await; in test_track_local_static_no_codec_intersection()
50 let mut pc = api.new_peer_connection(RTCConfiguration::default()).await?; in test_track_local_static_no_codec_intersection() localVariable
77 pc.add_track(Arc::clone(&track)).await?; in test_track_local_static_no_codec_intersection()
79 if let Err(err) = signal_pair(&mut vp9only_pc, &mut pc).await { in test_track_local_static_no_codec_intersection()
91 close_pair_now(&vp9only_pc, &pc).await; in test_track_local_static_no_codec_intersection()
|
| /webrtc/examples/examples/data-channels-flow-control/ |
| H A D | data-channels-flow-control.rs | 58 let pc = create_peer_connection().await?; in create_requester() localVariable
68 let dc = pc.create_data_channel("data", options).await?; in create_requester()
110 Ok(pc) in create_requester()
115 let pc = create_peer_connection().await?; in create_responder() localVariable
118 pc.on_data_channel(Box::new(move |dc| { in create_responder()
160 Ok(pc) in create_responder()
|
| /webrtc/examples/examples/offer-answer/ |
| H A D | answer.rs | 68 let pc = { in remote_handler() localVariable
89 if let Err(err) = pc in remote_handler()
117 if let Err(err) = pc.set_remote_description(sdp).await { in remote_handler()
122 let answer = match pc.create_answer(None).await { in remote_handler()
158 if let Err(err) = pc.set_local_description(answer).await { in remote_handler()
280 let pc = Arc::downgrade(&peer_connection); in main() localVariable
286 let pc2 = pc.clone(); in main()
291 if let Some(pc) = pc2.upgrade() { in main()
292 let desc = pc.remote_description().await; in main()
|
| H A D | offer.rs | 67 let pc = { in remote_handler() localVariable
88 if let Err(err) = pc in remote_handler()
116 if let Err(err) = pc.set_remote_description(sdp).await { in remote_handler()
238 let pc = Arc::downgrade(&peer_connection); in main() localVariable
244 let pc2 = pc.clone(); in main()
249 if let Some(pc) = pc2.upgrade() { in main()
250 let desc = pc.remote_description().await; in main()
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | session_description.rs | 174 let pc = api.new_peer_connection(RTCConfiguration::default()).await?; in test_session_description_offer() localVariable
175 let offer = pc.create_offer(None).await?; in test_session_description_offer()
216 let pc = api.new_peer_connection(RTCConfiguration::default()).await?; in test_session_description_unmarshal() localVariable
218 let offer = pc.create_offer(None).await?; in test_session_description_unmarshal()
231 pc.close().await?; in test_session_description_unmarshal()
|
| /webrtc/examples/examples/simulcast/ |
| H A D | simulcast.rs | 154 let pc = Arc::downgrade(&peer_connection); in main() localVariable
168 let pc2 = pc.clone(); in main()
179 if let Some(pc) = pc2.upgrade(){ in main()
180 result = pc.write_rtcp(&[Box::new(PictureLossIndication{ in main()
|
| /webrtc/webrtc/src/api/media_engine/ |
| H A D | media_engine_test.rs | 14 let pc = api.new_peer_connection(RTCConfiguration::default()).await?; in test_opus_case() localVariable
15 pc.add_transceiver_from_kind(RTPCodecType::Audio, None) in test_opus_case()
18 let offer = pc.create_offer(None).await?; in test_opus_case()
23 pc.close().await?; in test_opus_case()
34 let pc = api.new_peer_connection(RTCConfiguration::default()).await?; in test_video_case() localVariable
35 pc.add_transceiver_from_kind(RTPCodecType::Video, None) in test_video_case()
38 let offer = pc.create_offer(None).await?; in test_video_case()
47 pc.close().await?; in test_video_case()
|
| /webrtc/examples/examples/reflect/ |
| H A D | reflect.rs | 198 let pc = Arc::downgrade(&peer_connection); in main() localVariable
205 let pc2 = pc.clone(); in main()
214 if let Some(pc) = pc2.upgrade(){ in main()
215 result = pc.write_rtcp(&[Box::new(PictureLossIndication{ in main()
|
| /webrtc/examples/examples/rtp-forwarder/ |
| H A D | rtp-forwarder.rs | 176 let pc = Arc::downgrade(&peer_connection); in main() localVariable
187 let pc2 = pc.clone(); in main()
196 if let Some(pc) = pc2.upgrade(){ in main()
197 result = pc.write_rtcp(&[Box::new(PictureLossIndication{ in main()
|
| /webrtc/examples/examples/broadcast/ |
| H A D | broadcast.rs | 127 let pc = Arc::downgrade(&peer_connection); in main() localVariable
132 let pc2 = pc.clone(); in main()
141 if let Some(pc) = pc2.upgrade(){ in main()
142 result = pc.write_rtcp(&[Box::new(PictureLossIndication{ in main()
|
| /webrtc/examples/examples/swap-tracks/ |
| H A D | swap-tracks.rs | 143 let pc = Arc::downgrade(&peer_connection); in main() localVariable
150 let pc2 = pc.clone(); in main()
176 if let Some(pc) = pc2.upgrade() { in main()
177 if let Err(err) = pc in main()
|
| /webrtc/examples/examples/save-to-disk-h264/ |
| H A D | save-to-disk-h264.rs | 206 let pc = Arc::downgrade(&peer_connection); in main() localVariable
210 let pc2 = pc.clone(); in main()
219 if let Some(pc) = pc2.upgrade(){ in main()
220 result = pc.write_rtcp(&[Box::new(PictureLossIndication{ in main()
|
| /webrtc/examples/examples/save-to-disk-vpx/ |
| H A D | save-to-disk-vpx.rs | 231 let pc = Arc::downgrade(&peer_connection); in main() localVariable
235 let pc2 = pc.clone(); in main()
244 if let Some(pc) = pc2.upgrade(){ in main()
245 result = pc.write_rtcp(&[Box::new(PictureLossIndication{ in main()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 77 let mut pc = PeerConnectionInternal { in new() localVariable
117 pc.ice_gatherer = Arc::new(api.new_ice_gatherer(RTCIceGatherOptions { in new()
123 pc.ice_transport = pc.create_ice_transport(api).await; in new()
127 pc.dtls_transport = in new()
128 Arc::new(api.new_dtls_transport(Arc::clone(&pc.ice_transport), certificates)?); in new()
131 pc.sctp_transport = Arc::new(api.new_sctp_transport(Arc::clone(&pc.dtls_transport))?); in new()
134 let on_data_channel_handler = Arc::clone(&pc.on_data_channel_handler); in new()
135 pc.sctp_transport in new()
146 Ok((Arc::new(pc), configuration)) in new()
|
| H A D | peer_connection_test.rs | 246 pc: &mut RTCPeerConnection, in until_connection_state()
251 pc.on_peer_connection_state_change(Box::new(move |pcs: RTCPeerConnectionState| { in until_connection_state()
|
| H A D | mod.rs | 1268 let pc = Arc::clone(&pci); in set_local_description() localVariable
1271 let _ = pc.start_rtp(have_local_description, rd).await; in set_local_description()
1504 let pc = Arc::clone(&pci); in set_remote_description() localVariable
1507 let _ = pc.start_rtp(true, rd).await; in set_remote_description()
1555 let pc = Arc::clone(&pci); in set_remote_description() localVariable
1567 pc.start_transports(ice_role, dtls_role, ru, rp, fp, fp_hash) in set_remote_description()
1571 let _ = pc.start_rtp(false, rd).await; in set_remote_description()
|
| /webrtc/ |
| H A D | Cargo.lock | 2866 "winapi-i686-pc-windows-gnu",
2867 "winapi-x86_64-pc-windows-gnu",
2871 name = "winapi-i686-pc-windows-gnu"
2886 name = "winapi-x86_64-pc-windows-gnu"
|