Lines Matching refs:agent_conn
62 pub(crate) agent_conn: Arc<AgentConn>, field
157 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()
370 let mut checklist = self.agent_conn.checklist.lock().await; in ping_all_candidates()
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()
1065 &*ai.agent_conn.selected_pair.load(), in start_on_connection_state_change_routine()
1183 } else if let Err(err) = self.agent_conn.buffer.write(buf).await { in handle_inbound_candidate_msg()