| /webrtc/turn/examples/ |
| H A D | turn_client_udp.rs | 1 use turn::client::*;
93 let client = Client::new(cfg).await?; in main() localVariable
96 client.listen().await?; in main()
101 let relay_conn = client.allocate().await?; in main()
110 do_ping_test(&client, relay_conn).await?; in main()
113 client.close().await?; in main()
119 client: &Client, in do_ping_test()
123 let mapped_addr = client.send_binding_request().await?; in do_ping_test()
|
| /webrtc/turn/src/auth/ |
| H A D | auth_test.rs | 39 use crate::client::*; in test_new_long_term_auth_handler()
80 let client = Client::new(ClientConfig { in test_new_long_term_auth_handler() localVariable
93 client.listen().await?; in test_new_long_term_auth_handler()
95 let _allocation = client.allocate().await?; in test_new_long_term_auth_handler()
97 client.close().await?; in test_new_long_term_auth_handler()
|
| /webrtc/turn/src/server/ |
| H A D | server_test.rs | 4 use crate::client::*;
72 let client = Client::new(ClientConfig { in test_server_simple() localVariable
85 client.listen().await?; in test_server_simple()
87 client in test_server_simple()
91 client.close().await?; in test_server_simple()
226 let client = Client::new(ClientConfig { in test_server_vnet_send_binding_request() localVariable
239 client.listen().await?; in test_server_vnet_send_binding_request()
253 client.close().await?; in test_server_vnet_send_binding_request()
276 client.listen().await?; in test_server_vnet_echo_via_relay()
279 let conn = client.allocate().await?; in test_server_vnet_echo_via_relay()
[all …]
|
| /webrtc/stun/examples/ |
| H A D | stun_client.rs | 2 use stun::client::*;
48 let mut client = ClientBuilder::new().with_conn(Arc::new(conn)).build()?; in main() localVariable
53 client.send(&msg, Some(Arc::new(handler_tx))).await?; in main()
62 client.close().await?; in main()
|
| /webrtc/stun/src/client/ |
| H A D | client_test.rs | 5 let client = ClientSettings::default(); in ensure_client_settings_is_send() localVariable
7 ensure_send(client); in ensure_client_settings_is_send()
|
| /webrtc/examples/examples/ortc/ |
| H A D | README.md | 18 ### Run first client as offerer
22 ## Run the second client as answerer
24 Run the second client. This should be launched with the message you copied in the previous step as …
32 Each client will send random messages every 5 seconds that will appear in the terminal
|
| /webrtc/turn/src/proto/ |
| H A D | addr.rs | 53 pub client: Addr, field
60 write!(f, "{}->{} ({})", self.client, self.server, self.proto) in fmt()
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 5 client::{Client, ClientConfig},
499 let client = create_client("foo".to_owned(), server_port).await?; in test_get_allocations_info_bytes_count() localVariable
501 client.listen().await?; in test_get_allocations_info_bytes_count()
505 let conn = client.allocate().await?; in test_get_allocations_info_bytes_count()
506 let addr = client in test_get_allocations_info_bytes_count()
561 client.close().await?; in test_get_allocations_info_bytes_count()
580 let client = create_client("foo".to_owned(), server_port).await?; in test_alloc_close_notify() localVariable
582 client.listen().await?; in test_alloc_close_notify()
586 let conn = client.allocate().await?; in test_alloc_close_notify()
587 let addr = client in test_alloc_close_notify()
[all …]
|
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 159 let client = Client::new(ClientConfig { in test_client_nonce_expiration() localVariable
172 client.listen().await?; in test_client_nonce_expiration()
174 let allocation = client.allocate().await?; in test_client_nonce_expiration()
186 client.close().await?; in test_client_nonce_expiration()
|
| /webrtc/turn/src/proto/addr/ |
| H A D | addr_test.rs | 64 client: Addr { in test_five_tuple_equal()
91 client: Addr { in test_five_tuple_string()
|
| /webrtc/turn/src/ |
| H A D | lib.rs | 7 pub mod client; module
|
| /webrtc/stun/src/ |
| H A D | lib.rs | 11 pub mod client; module
|
| H A D | client.rs | 201 let client = Client { in build() localVariable
207 Ok(client) in build()
|
| H A D | agent.rs | 4 use crate::client::ClientTransaction;
|
| /webrtc/ice/src/agent/ |
| H A D | agent_gather.rs | 785 let cfg = turn::client::ClientConfig { in gather_candidates_relay()
796 let client = match turn::client::Client::new(cfg).await { in gather_candidates_relay() localVariable
797 Ok(client) => Arc::new(client), in gather_candidates_relay()
808 if let Err(err) = client.listen().await { in gather_candidates_relay()
809 let _ = client.close().await; in gather_candidates_relay()
819 let relay_conn = match client.allocate().await { in gather_candidates_relay()
822 let _ = client.close().await; in gather_candidates_relay()
845 relay_client: Some(Arc::clone(&client)), in gather_candidates_relay()
852 let _ = client.close().await; in gather_candidates_relay()
|
| /webrtc/data/src/data_channel/ |
| H A D | data_channel_test.rs | 36 let client = Association::client(sctp::association::Config { in create_new_association_pair() localVariable
44 let _ = handshake0ch_tx.send(client).await; in create_new_association_pair()
66 let mut client = None; in create_new_association_pair() localVariable
81 client = Some(c); in create_new_association_pair()
101 Ok((Arc::new(client.unwrap()), Arc::new(server.unwrap()))) in create_new_association_pair()
106 client: Arc<Association>, in close_association_pair()
116 client.close().await?; in close_association_pair()
|
| H A D | mod.rs | 71 Self::client(stream, config).await in dial()
103 pub async fn client(stream: Arc<Stream>, config: Config) -> Result<Self> { in client() method
|
| /webrtc/sctp/src/association/ |
| H A D | association_test.rs | 33 let client = Association::client(Config { in create_new_association_pair() localVariable
63 let mut client = None; in create_new_association_pair() localVariable
78 client = Some(c); in create_new_association_pair()
98 let (client, server) = (client.unwrap(), server.unwrap()); in create_new_association_pair()
108 Ok((client, server)) in create_new_association_pair()
119 client.close().await?; in close_association_pair()
183 client: &Association, in establish_session_pair()
188 let s0 = client in establish_session_pair()
195 flush_buffers(br, client, server).await; in establish_session_pair()
219 flush_buffers(br, client, server).await; in establish_session_pair()
[all …]
|
| /webrtc/dtls/src/conn/ |
| H A D | conn_test.rs | 47 let client = create_test_client( in pipe_conn() localVariable
57 let _ = c_tx.send(client).await; in pipe_conn()
72 let client = match c_rx.recv().await.unwrap() { in pipe_conn() localVariable
73 Ok(client) => client, in pipe_conn()
77 Ok((client, sever)) in pipe_conn()
561 if let Ok(client) = result { in test_psk()
562 client.close().await?; in test_psk()
626 if let Some(client) = result { in test_psk_hint_fail()
627 if let Err(client_err) = client { in test_psk_hint_fail()
1059 let client = res.unwrap(); in test_client_certificate() localVariable
[all …]
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_relay.rs | 19 pub relay_client: Option<Arc<turn::client::Client>>,
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 200 let client = Arc::new(Client::new()); in main() localVariable
203 let client2 = Arc::clone(&client); in main()
259 let resp = match client.request(req).await { in main()
|
| /webrtc/sctp/examples/ |
| H A D | ping.rs | 71 let a = Association::client(config).await?; in main()
|
| H A D | throughput.rs | 116 let a = Association::client(config).await.unwrap(); in main()
|
| /webrtc/dtls/examples/certificates/ |
| H A D | README.md | 19 $ CLIENT_NAME='client'
|
| /webrtc/examples/examples/rtp-to-webrtc/ |
| H A D | README.md | 3 rtp-to-webrtc demonstrates how to consume a RTP stream video UDP, and then send to a WebRTC client.
|