Searched refs:agent_conn (Results 1 – 7 of 7) sorted by relevance
22 let (on_connected_rx, agent_conn) = { in dial()30 Arc::clone(&self.internal.agent_conn), in dial()43 Ok(agent_conn) in dial()57 let (on_connected_rx, agent_conn) = { in accept()65 Arc::clone(&self.internal.agent_conn), in accept()79 Ok(agent_conn) in accept()
235 if self.agent_conn.get_selected_pair().is_some() { in contact_candidates()244 if let Some(p) = self.agent_conn.get_best_valid_candidate_pair().await { in contact_candidates()251 if let Some(p) = self.agent_conn.get_best_valid_candidate_pair().await { in contact_candidates()323 let selected_pair_is_none = self.agent_conn.get_selected_pair().is_none(); in handle_success_response()375 && self.agent_conn.get_selected_pair().is_none() in handle_binding_request()377 if let Some(best_pair) = self.agent_conn.get_best_available_candidate_pair().await { in handle_binding_request()413 } else if self.agent_conn.get_selected_pair().is_some() { in contact_candidates()519 if self.agent_conn.get_selected_pair().is_none() { in handle_binding_request()
62 pub(crate) agent_conn: Arc<AgentConn>, field157 agent_conn: Arc::new(AgentConn::new()), in new()338 self.agent_conn.selected_pair.store(Some(p)); in set_selected_pair()357 self.agent_conn.selected_pair.store(None); in set_selected_pair()418 let mut checklist = self.agent_conn.checklist.lock().await; in add_pair()427 let checklist = self.agent_conn.checklist.lock().await; in find_pair()440 let selected_pair = self.agent_conn.selected_pair.load(); in validate_selected_pair()482 let selected_pair = self.agent_conn.selected_pair.load(); in check_keepalive()627 self.agent_conn.buffer.close().await; in close()644 self.agent_conn.done.store(true, Ordering::SeqCst); in close()[all …]
227 self.internal.agent_conn.bytes_received() in get_bytes_received()231 self.internal.agent_conn.bytes_sent() in get_bytes_sent()349 self.internal.agent_conn.get_selected_pair() in get_selected_candidate_pair()412 let mut checklist = self.internal.agent_conn.checklist.lock().await; in restart()
217 let checklist = self.agent_conn.checklist.lock().await; in get_candidate_pairs_stats()
972 Arc::clone(&controlling_agent_tx.internal.agent_conn) as Arc<dyn Conn + Send + Sync> in test_write_use_valid_pair()993 Arc::clone(&controlled_agent.internal.agent_conn) as Arc<dyn Conn + Send + Sync> in test_write_use_valid_pair()
29 let checklist = a.internal.agent_conn.checklist.lock().await; in test_pair_search()38 .agent_conn in test_pair_search()142 .agent_conn in test_pair_priority()