| /webrtc/mdns/examples/ |
| H A D | mdns_query.rs | 69 let server = matches.value_of("server").unwrap(); in main() localVariable
72 let server = DnsConn::server( in main() localVariable
73 SocketAddr::from_str(server)?, in main()
84 let (answer, src) = server.query(local_name, b).await.unwrap(); in main()
88 server.close().await.unwrap(); in main()
|
| H A D | mdns_server.rs | 68 let server = matches.value_of("server").unwrap(); in main() localVariable
71 let server = DnsConn::server( in main() localVariable
72 SocketAddr::from_str(server)?, in main()
82 server.close().await.unwrap(); in main()
|
| H A D | mdns_server_query.rs | 11 let server_a = DnsConn::server( in main()
23 let server_b = DnsConn::server( in main()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_server_reflexive_test.rs | 32 let server = turn::server::Server::new(turn::server::config::ServerConfig { in test_server_reflexive_only_connection() localVariable
35 conn_configs: vec![turn::server::config::ConnConfig { in test_server_reflexive_only_connection()
86 server.close().await?; in test_server_reflexive_only_connection()
|
| H A D | candidate_relay_test.rs | 53 let server = turn::server::Server::new(turn::server::config::ServerConfig { in test_relay_only_connection() localVariable
56 conn_configs: vec![turn::server::config::ConnConfig { in test_relay_only_connection()
111 server.close().await?; in test_relay_only_connection()
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 9 server::{
406 let server = Server::new(ServerConfig { in create_server() localVariable
422 Ok((server, server_port)) in create_server()
445 let (server, server_port) = create_server(None).await?; in test_get_allocations_info()
480 server in test_get_allocations_info()
497 let (server, server_port) = create_server(None).await?; in test_get_allocations_info_bytes_count()
513 server in test_get_allocations_info_bytes_count()
532 server in test_get_allocations_info_bytes_count()
551 server in test_get_allocations_info_bytes_count()
562 server.close().await?; in test_get_allocations_info_bytes_count()
[all …]
|
| /webrtc/turn/src/auth/ |
| H A D | auth_test.rs | 41 use crate::server::{config::*, *}; in test_new_long_term_auth_handler()
59 let server = Server::new(ServerConfig { in test_new_long_term_auth_handler() localVariable
98 server.close().await?; in test_new_long_term_auth_handler()
|
| /webrtc/mdns/src/conn/ |
| H A D | conn_test.rs | 8 let server_a = DnsConn::server( in test_multiple_close()
26 let server_a = DnsConn::server( in test_query_respect_timeout()
|
| /webrtc/turn/src/proto/ |
| H A D | addr.rs | 54 pub server: Addr, field
60 write!(f, "{}->{} ({})", self.client, self.server, self.proto) in fmt()
|
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 4 use crate::server::{config::*, *};
141 let server = Server::new(ServerConfig { in test_client_nonce_expiration() localVariable
177 let mut nonces = server.nonces.lock().await; in test_client_nonce_expiration()
187 server.close().await?; in test_client_nonce_expiration()
|
| /webrtc/turn/examples/ |
| H A D | turn_server_udp.rs | 3 use turn::server::{config::*, *};
116 let server = Server::new(ServerConfig { in main() localVariable
135 server.close().await?; in main()
|
| /webrtc/stun/examples/ |
| H A D | stun_client.rs | 38 let server = matches.value_of("server").unwrap(); in main() localVariable
46 conn.connect(server).await?; in main()
|
| /webrtc/turn/src/server/ |
| H A D | server_test.rs | 49 let server = Server::new(ServerConfig { in test_server_simple() localVariable
66 DEFAULT_LIFETIME, server.channel_bind_timeout, in test_server_simple()
92 server.close().await?; in test_server_simple()
102 server: Server, field
185 let server = Server::new(ServerConfig { in build_vnet() localVariable
216 server, in build_vnet()
|
| /webrtc/turn/src/proto/addr/ |
| H A D | addr_test.rs | 52 server: Addr { in test_five_tuple_equal()
87 server: Addr { in test_five_tuple_string()
|
| /webrtc/turn/src/ |
| H A D | lib.rs | 11 pub mod server; module
|
| /webrtc/dtls/examples/dial/selfsign/ |
| H A D | dial_selfsign.rs | 55 let server = matches.value_of("server").unwrap(); in main() localVariable
58 conn.connect(server).await?; in main()
|
| /webrtc/dtls/examples/dial/verify/ |
| H A D | dial_verify.rs | 56 let server = matches.value_of("server").unwrap(); in main() localVariable
59 conn.connect(server).await?; in main()
|
| /webrtc/dtls/examples/dial/psk/ |
| H A D | dial_psk.rs | 56 let server = matches.value_of("server").unwrap(); in main() localVariable
59 conn.connect(server).await?; in main()
|
| /webrtc/examples/examples/signal/src/ |
| H A D | lib.rs | 64 let server = Server::bind(&addr).serve(service); in http_sdp_server() localVariable
66 if let Err(e) = server.await { in http_sdp_server()
|
| /webrtc/sctp/examples/ |
| H A D | ping.rs | 59 let server = matches.value_of("server").unwrap(); in main() localVariable
62 conn.connect(server).await.unwrap(); in main()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_vnet_test.rs | 47 pub(crate) server: turn::server::Server, field
52 self.server.close().await?; in close()
107 let server = add_vnet_stun(wnet).await?; in build_simple_vnet() localVariable
113 server, in build_simple_vnet()
177 let server = add_vnet_stun(wnet).await?; in build_vnet() localVariable
183 server, in build_vnet()
218 pub(crate) async fn add_vnet_stun(wan_net: Arc<net::Net>) -> Result<turn::server::Server, Error> { in add_vnet_stun()
226 let server = turn::server::Server::new(turn::server::config::ServerConfig { in add_vnet_stun() localVariable
227 conn_configs: vec![turn::server::config::ConnConfig { in add_vnet_stun()
244 Ok(server) in add_vnet_stun()
|
| /webrtc/examples/examples/ |
| H A D | README.md | 13 …rd your webcam and save the footage (VP8/VP9 for video, Opus for audio) to disk on the server side.
14 …ecord your webcam and save the footage (H264 for video, Opus for audio) to disk on the server side.
15 … a video to multiple peers. A broadcaster uploads the video once and the server forwards it to all…
23 …e data-channels example is that the data channel is initialized from the server side in this examp…
|
| /webrtc/examples/examples/offer-answer/ |
| H A D | README.md | 6 The `answer` side acts like a HTTP server and should therefore be ran first.
|
| /webrtc/data/src/data_channel/ |
| H A D | data_channel_test.rs | 52 let server = Association::server(sctp::association::Config { in create_new_association_pair() localVariable
60 let _ = handshake1ch_tx.send(server).await; in create_new_association_pair()
67 let mut server = None; in create_new_association_pair() localVariable
87 server = Some(s); in create_new_association_pair()
101 Ok((Arc::new(client.unwrap()), Arc::new(server.unwrap()))) in create_new_association_pair()
107 server: Arc<Association>, in close_association_pair()
125 server.close().await?; in close_association_pair()
|
| /webrtc/ice/src/mdns/ |
| H A D | mod.rs | 63 let conn = DnsConn::server( in create_multicast_dns()
|