| /webrtc/media/src/io/h264_writer/ |
| H A D | h264_writer_test.rs | 76 let w = Cursor::new(&mut writer); in test_write_rtp() localVariable
77 let mut h264writer = H264Writer::new(w); in test_write_rtp()
108 let w = Cursor::new(&mut writer); in test_write_rtp_fu() localVariable
109 let mut h264writer = H264Writer::new(w); in test_write_rtp_fu()
|
| /webrtc/turn/src/server/ |
| H A D | server_test.rs | 127 let mut w = wan.lock().await; in build_vnet() localVariable
128 w.add_net(Arc::clone(&nic0)).await?; in build_vnet()
129 w.add_net(Arc::clone(&nic1)).await?; in build_vnet()
167 let mut w = wan.lock().await; in build_vnet() localVariable
168 w.add_router(Arc::clone(&lan)).await?; in build_vnet()
178 let mut w = wan.lock().await; in build_vnet() localVariable
179 w.start().await?; in build_vnet()
202 let mut w = wan.lock().await; in build_vnet() localVariable
203 w.add_host("stun.webrtc.rs".to_owned(), "1.2.3.4".to_owned()) in build_vnet()
205 w.add_host("turn.webrtc.rs".to_owned(), "1.2.3.4".to_owned()) in build_vnet()
[all …]
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_test.rs | 34 let mut w = wan.lock().await; in create_vnet_pair() localVariable
35 w.add_net(Arc::clone(&nic)).await?; in create_vnet_pair()
59 let mut w = wan.lock().await; in create_vnet_pair() localVariable
60 w.add_net(Arc::clone(&nic)).await?; in create_vnet_pair()
77 let mut w = wan.lock().await; in create_vnet_pair() localVariable
78 w.start().await?; in create_vnet_pair()
250 let w = Arc::new(Mutex::new(Some(wg.worker()))); in until_connection_state() localVariable
252 let w2 = Arc::clone(&w); in until_connection_state()
|
| /webrtc/ice/src/rand/ |
| H A D | rand_test.rs | 40 let w = wg.worker(); in test_random_generator_collision() localVariable
44 let _d = w; in test_random_generator_collision()
|
| /webrtc/examples/examples/save-to-disk-h264/ |
| H A D | save-to-disk-h264.rs | 33 let mut w = writer.lock().await; in save_to_disk() localVariable
34 w.write_rtp(&rtp_packet)?; in save_to_disk()
37 let mut w = writer.lock().await; in save_to_disk() localVariable
38 if let Err(err) = w.close() { in save_to_disk()
47 let mut w = writer.lock().await; in save_to_disk() localVariable
48 if let Err(err) = w.close() { in save_to_disk()
|
| /webrtc/examples/examples/save-to-disk-vpx/ |
| H A D | save-to-disk-vpx.rs | 34 let mut w = writer.lock().await; in save_to_disk() localVariable
35 w.write_rtp(&rtp_packet)?; in save_to_disk()
38 let mut w = writer.lock().await; in save_to_disk() localVariable
39 if let Err(err) = w.close() { in save_to_disk()
48 let mut w = writer.lock().await; in save_to_disk() localVariable
49 if let Err(err) = w.close() { in save_to_disk()
|
| /webrtc/util/src/vnet/router/ |
| H A D | router_test.rs | 170 let mut w = wan.lock().await; in test_router_standalone_add_net() localVariable
215 let mut w = wan.lock().await; in test_router_standalone_routing() localVariable
216 w.add_net(n).await?; in test_router_standalone_routing()
295 let mut w = wan.lock().await; in test_router_standalone_add_chunk_filter() localVariable
296 w.add_net(n).await?; in test_router_standalone_add_chunk_filter()
398 let mut w = wan.lock().await; in delay_sub_test() localVariable
399 w.add_net(n).await?; in delay_sub_test()
550 let mut w = r.lock().await; in test_router_one_child() localVariable
551 w.add_net(n).await?; in test_router_one_child()
712 let mut w = wan.lock().await; in test_router_static_ips_1to1_nat() localVariable
[all …]
|
| /webrtc/media/src/io/ivf_writer/ |
| H A D | mod.rs | 25 let mut w = IVFWriter { in new() localVariable
33 w.write_header(header)?; in new()
35 Ok(w) in new()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 475 let mut w = wan.lock().await; in test_net_virtual_dail_eth0() localVariable
476 w.add_net(Arc::clone(&nic)).await?; in test_net_virtual_dail_eth0()
513 let mut w = wan.lock().await; in test_net_virtual_resolver() localVariable
514 w.add_net(Arc::clone(&nic)).await?; in test_net_virtual_resolver()
658 let mut w = wan.lock().await; in test_net_virtual_end2end() localVariable
673 let mut w = wan.lock().await; in test_net_virtual_end2end() localVariable
688 let mut w = wan.lock().await; in test_net_virtual_end2end() localVariable
689 w.start().await?; in test_net_virtual_end2end()
804 let mut w = wan.lock().await; in test_net_virtual_two_ips_on_a_nic() localVariable
813 let mut w = wan.lock().await; in test_net_virtual_two_ips_on_a_nic() localVariable
[all …]
|
| /webrtc/ice/src/agent/ |
| H A D | agent_vnet_test.rs | 53 let mut w = self.wan.lock().await; in close() localVariable
54 w.stop().await?; in close()
369 w.take(); in gather_and_exchange_candidates()
383 w.take(); in gather_and_exchange_candidates()
410 let mut w = router.lock().await; in start_router() localVariable
411 Ok(w.start().await?) in start_router()
421 let mut w = router.lock().await; in connect_net2router() localVariable
871 let mut w = wan.lock().await; in test_disconnected_to_connected() localVariable
872 w.stop().await?; in test_disconnected_to_connected()
1005 let mut w = wan.lock().await; in test_write_use_valid_pair() localVariable
[all …]
|
| H A D | agent_gather.rs | 104 let w = wg.worker(); in gather_candidates_internal() localVariable
106 let _d = w; in gather_candidates_internal()
155 let w = wg.worker(); in gather_candidates_internal() localVariable
157 let _d = w; in gather_candidates_internal()
474 let w = wg.worker(); in gather_candidates_srflx_mapped() localVariable
476 let _d = w; in gather_candidates_srflx_mapped()
602 let w = wg.worker(); in gather_candidates_srflx() localVariable
604 let _d = w; in gather_candidates_srflx()
748 let w = wg.worker(); in gather_candidates_relay() localVariable
750 let _d = w; in gather_candidates_relay()
|
| H A D | agent_transport_test.rs | 116 let w = wg.worker(); in test_conn_stats() localVariable
118 let _d = w; in test_conn_stats()
|
| H A D | agent_test.rs | 494 let mut w = wan.lock().await; in test_connectivity_on_startup() localVariable
495 w.stop().await?; in test_connectivity_on_startup()
|
| /webrtc/media/src/io/ogg_writer/ |
| H A D | mod.rs | 30 let mut w = OggWriter { in new() localVariable
46 w.write_headers()?; in new()
48 Ok(w) in new()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | sender_test.rs | 21 let w = wg.worker(); in test_twcc_sender_interceptor() localVariable
25 let _d = w; in test_twcc_sender_interceptor()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | rtp_receiver_test.rs | 153 let mut w = wan.lock().await; in test_set_rtp_parameters() localVariable
154 w.stop().await?; in test_set_rtp_parameters()
224 let mut w = wan.lock().await; in test_rtp_receiver_set_read_deadline() localVariable
225 w.stop().await?; in test_rtp_receiver_set_read_deadline()
|
| /webrtc/webrtc/src/peer_connection/operation/ |
| H A D | mod.rs | 95 let mut w = Some(wg.worker()); in done() localVariable
99 let _d = w.take(); in done()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 109 let mut w = { in bind_rtcp_writer() localVariable
116 let _d = w.take(); in bind_rtcp_writer()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 151 let mut w = { in bind_rtcp_writer() localVariable
158 let _d = w.take(); in bind_rtcp_writer()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 185 let mut w = { in bind_rtcp_writer() localVariable
192 let _d = w.take(); in bind_rtcp_writer()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 175 let mut w = { in bind_rtcp_writer() localVariable
182 let _d = w.take(); in bind_rtcp_writer()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | rtp_sender_test.rs | 185 let mut w = wan.lock().await; in test_rtp_sender_set_read_deadline() localVariable
186 w.stop().await?; in test_rtp_sender_set_read_deadline()
|
| /webrtc/mdns/src/message/ |
| H A D | message_test.rs | 1290 let w = tt_m.pack()?; in test_option_pack_unpack() localVariable
1292 assert_eq!(&w[w.len() - tt_w.len()..], &tt_w[..]); in test_option_pack_unpack()
1295 m.unpack(&w)?; in test_option_pack_unpack()
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | data_channel_test.rs | 1048 let w = wg.worker(); in test_eof_detach() localVariable
1050 let _d = w; in test_eof_detach()
1088 let w = wg.worker(); in test_eof_detach() localVariable
1090 let _d = w; in test_eof_detach()
|