| /webrtc/ice/src/mdns/ |
| H A D | mdns_test.rs | 24 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_multicast_dns_only_connection()
35 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_multicast_dns_only_connection()
58 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_multicast_dns_mixed_connection()
69 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_multicast_dns_mixed_connection()
92 if let Err(err) = Agent::new(cfg0).await { in test_multicast_dns_static_host_name()
106 let a = Agent::new(cfg1).await?; in test_multicast_dns_static_host_name()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport_test.rs | 11 ) -> Result<(Arc<impl Conn>, Arc<impl Conn>, Arc<Agent>, Arc<Agent>)> { in pipe() argument
23 let a_agent = Arc::new(Agent::new(cfg0).await?); in pipe()
34 let b_agent = Arc::new(Agent::new(cfg1).await?); in pipe()
|
| H A D | agent_test.rs | 25 let a = Agent::new(config).await?; in test_pair_search()
51 let a = Agent::new(AgentConfig::default()).await?; in test_pair_priority()
1457 let a = Agent::new(AgentConfig { in test_init_ext_ip_mapping()
1471 if let Err(err) = Agent::new(AgentConfig { in test_init_ext_ip_mapping()
1490 if let Err(err) = Agent::new(AgentConfig { in test_init_ext_ip_mapping()
1509 if let Err(err) = Agent::new(AgentConfig { in test_init_ext_ip_mapping()
1527 if let Err(err) = Agent::new(AgentConfig { in test_init_ext_ip_mapping()
1606 if let Err(err) = Agent::new(AgentConfig { in test_agent_credentials()
1617 if let Err(err) = Agent::new(AgentConfig { in test_agent_credentials()
2130 Agent::new(AgentConfig { in test_lite_lifecycle()
[all …]
|
| H A D | agent_gather_test.rs | 15 let a = Agent::new(AgentConfig { in test_vnet_gather_no_local_ip_address()
47 let a = Agent::new(AgentConfig { in test_vnet_gather_dynamic_ip_address()
81 let a = Agent::new(AgentConfig { in test_vnet_gather_listen_udp()
146 let a = Agent::new(AgentConfig { in test_vnet_gather_with_nat_1to1_as_host_candidates()
262 let a = Agent::new(AgentConfig { in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
332 let a = Agent::new(AgentConfig { in test_vnet_gather_with_interface_filter()
354 let a = Agent::new(AgentConfig { in test_vnet_gather_with_interface_filter()
406 let a_agent = Agent::new(cfg0).await?; in test_vnet_gather_turn_connection_leak()
410 Agent::gather_candidates_relay( in test_vnet_gather_turn_connection_leak()
446 let a = Agent::new(AgentConfig { in test_vnet_gather_muxed_udp()
|
| H A D | agent_vnet_test.rs | 248 a_agent: &Arc<Agent>, in connect_with_vnet() argument
249 b_agent: &Arc<Agent>, in connect_with_vnet() argument
310 let a_agent = Arc::new(Agent::new(cfg0).await?); in pipe_with_vnet()
328 let b_agent = Arc::new(Agent::new(cfg1).await?); in pipe_with_vnet()
357 a_agent: &Arc<Agent>, in gather_and_exchange_candidates() argument
358 b_agent: &Arc<Agent>, in gather_and_exchange_candidates() argument
793 Agent::new(AgentConfig { in test_disconnected_to_connected()
806 Agent::new(AgentConfig { in test_disconnected_to_connected()
940 Agent::new(AgentConfig { in test_write_use_valid_pair()
950 Agent::new(AgentConfig { in test_write_use_valid_pair()
|
| H A D | mod.rs | 95 pub struct Agent { struct
116 impl Agent { argument
|
| H A D | agent_transport.rs | 10 impl Agent { impl
|
| H A D | agent_gather.rs | 78 impl Agent { implementation
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_server_reflexive_test.rs | 5 use crate::agent::Agent;
59 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_server_reflexive_only_connection()
75 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_server_reflexive_only_connection()
|
| H A D | candidate_relay_test.rs | 5 use crate::agent::Agent;
82 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_relay_only_connection()
100 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_relay_only_connection()
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 11 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_process_in_transaction()
37 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_process()
73 let mut a = Agent::new(noop_handler()); in test_agent_start()
125 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_stop()
|
| /webrtc/stun/src/ |
| H A D | agent.rs | 28 pub struct Agent { struct
115 impl Agent { implementation
118 Agent { in new()
265 pub(crate) async fn run(mut agent: Agent, mut rx: mpsc::Receiver<ClientAgent>) { in run() argument
|
| H A D | client.rs | 411 let agent = Agent::new(Some(handler_tx)); in run()
412 tokio::spawn(async move { Agent::run(agent, client_agent_rx).await }); in run()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_gatherer.rs | 13 use ice::agent::Agent;
58 pub(crate) agent: Mutex<Option<Arc<ice::agent::Agent>>>,
147 *agent = Some(Arc::new(ice::agent::Agent::new(config).await?)); in create_agent()
285 pub(crate) async fn get_agent(&self) -> Option<Arc<Agent>> { in get_agent() argument
|
| /webrtc/ice/ |
| H A D | CHANGELOG.md | 16 - `Agent`:
|
| /webrtc/stun/benches/ |
| H A D | bench.rs | 9 use stun::agent::{noop_handler, Agent, TransactionId};
61 let mut a = Agent::new(noop_handler()); in benchmark_agent()
76 let mut a = Agent::new(noop_handler()); in benchmark_agent()
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 5 use ice::agent::Agent;
192 Agent::new(AgentConfig { in main()
|
| /webrtc/webrtc/src/stats/ |
| H A D | mod.rs | 10 use ice::agent::Agent;
274 pub(crate) fn new(id: String, agent: Arc<Agent>) -> Self { in new()
|