| /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>>>, field
87 let mut agent = self.agent.lock().await; in create_agent() localVariable
147 *agent = Some(Arc::new(ice::agent::Agent::new(config).await?)); in create_agent()
163 agent.on_candidate(Box::new( in gather()
200 agent.gather_candidates()?; in gather()
210 let agent = { in close() localVariable
215 if let Some(agent) = agent { in close()
216 agent.close().await?; in close()
286 let agent = self.agent.lock().await; in get_agent() localVariable
[all …]
|
| H A D | mod.rs | 89 if let Some(agent) = self.gatherer.get_agent().await { in get_selected_candidate_pair()
107 if let Some(agent) = self.gatherer.get_agent().await { in start()
127 agent.on_selected_candidate_pair_change(Box::new( in start()
160 agent in start()
170 agent in start()
202 if let Some(agent) = self.gatherer.get_agent().await { in restart()
203 agent in restart()
268 if let Some(agent) = self.gatherer.get_agent().await { in set_remote_candidates()
271 agent.add_remote_candidate(&c)?; in set_remote_candidates()
286 if let Some(agent) = self.gatherer.get_agent().await { in add_remote_candidate()
[all …]
|
| /webrtc/stun/src/ |
| H A D | agent.rs | 265 pub(crate) async fn run(mut agent: Agent, mut rx: mpsc::Receiver<ClientAgent>) { in run()
268 ClientAgent::Process(message) => agent.process(message), in run()
269 ClientAgent::Collect(deadline) => agent.collect(deadline), in run()
270 ClientAgent::Start(tid, deadline) => agent.start(tid, deadline), in run()
271 ClientAgent::Stop(tid) => agent.stop(tid), in run()
272 ClientAgent::Close => agent.close(), in run()
|
| H A D | lib.rs | 8 pub mod agent; module
|
| H A D | client.rs | 4 use crate::agent::*;
411 let agent = Agent::new(Some(handler_tx)); in run() localVariable
412 tokio::spawn(async move { Agent::run(agent, client_agent_rx).await }); in run()
|
| H A D | message.rs | 4 use crate::agent::*;
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_server_reflexive_test.rs | 3 use crate::agent::agent_config::AgentConfig;
4 use crate::agent::agent_vnet_test::{connect_with_vnet, on_connected};
5 use crate::agent::Agent;
|
| H A D | candidate_relay_test.rs | 3 use crate::agent::agent_config::AgentConfig;
4 use crate::agent::agent_vnet_test::{connect_with_vnet, on_connected};
5 use crate::agent::Agent;
|
| /webrtc/ice/src/agent/ |
| H A D | mod.rs | 33 use stun::{agent::*, attributes::*, fingerprint::*, integrity::*, message::*, xoraddr::*};
36 use crate::agent::agent_gather::GatherCandidatesInternalParams;
192 let agent = Self { in new() localVariable
210 agent.internal.start_on_connection_state_change_routine( in new()
217 if let Err(err) = agent.restart(config.local_ufrag, config.local_pwd).await { in new()
218 Self::close_multicast_conn(&agent.mdns_conn).await; in new()
219 let _ = agent.close().await; in new()
223 Ok(agent) in new()
|
| H A D | agent_transport_test.rs | 4 use crate::agent::agent_transport::AgentConn;
|
| H A D | agent_stats.rs | 3 use crate::agent::agent_internal::AgentInternal;
|
| H A D | agent_test.rs | 12 use crate::agent::agent_transport_test::pipe;
1771 let agent = Agent::new(AgentConfig::default()).await?; in test_agent_restart_during_gather() localVariable
1773 agent in test_agent_restart_during_gather()
1777 if let Err(err) = agent.restart("".to_owned(), "".to_owned()).await { in test_agent_restart_during_gather()
1783 agent.close().await?; in test_agent_restart_during_gather()
1792 let agent = Agent::new(AgentConfig::default()).await?; in test_agent_restart_when_closed() localVariable
1793 agent.close().await?; in test_agent_restart_when_closed()
1795 if let Err(err) = agent.restart("".to_owned(), "".to_owned()).await { in test_agent_restart_when_closed()
|
| H A D | agent_selector.rs | 1 use crate::agent::agent_internal::*;
7 use stun::{agent::*, attributes::*, fingerprint::*, integrity::*, message::*, textattrs::*};
|
| /webrtc/ice/src/ |
| H A D | lib.rs | 4 pub mod agent; module
|
| /webrtc/webrtc/src/stats/ |
| H A D | mod.rs | 9 use ice::agent::agent_stats::{CandidatePairStats, CandidateStats};
10 use ice::agent::Agent;
274 pub(crate) fn new(id: String, agent: Arc<Agent>) -> Self { in new()
277 bytes_received: agent.get_bytes_received(), in new()
278 bytes_sent: agent.get_bytes_sent(), in new()
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 4 use crate::agent::agent_config::{InterfaceFilterFn, IpFilterFn};
11 use stun::{agent::*, attributes::*, integrity::*, message::*, textattrs::*, xoraddr::*};
|
| /webrtc/stun/examples/ |
| H A D | stun_client.rs | 1 use stun::agent::*;
|
| /webrtc/stun/src/integrity/ |
| H A D | integrity_test.rs | 2 use crate::agent::TransactionId;
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 4 use ice::agent::agent_config::AgentConfig;
5 use ice::agent::Agent;
|
| /webrtc/ice/src/mdns/ |
| H A D | mdns_test.rs | 2 use crate::agent::{agent_config::*, agent_vnet_test::*, *};
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | mod.rs | 390 if let Some(agent) = dtls_transport.ice_transport.gatherer.get_agent().await { in collect_stats()
391 let stats = ICETransportStats::new("sctp_transport".to_owned(), agent); in collect_stats()
|
| /webrtc/webrtc/src/api/setting_engine/ |
| H A D | mod.rs | 7 use ice::agent::agent_config::{InterfaceFilterFn, IpFilterFn};
|
| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 14 use stun::{agent::*, message::*, textattrs::Username};
|
| /webrtc/turn/src/client/ |
| H A D | mod.rs | 21 use stun::agent::*;
|
| /webrtc/stun/benches/ |
| H A D | bench.rs | 9 use stun::agent::{noop_handler, Agent, TransactionId};
|