diff --git a/easytier/src/dns/server.rs b/easytier/src/dns/server.rs index 63903425..1e75811c 100644 --- a/easytier/src/dns/server.rs +++ b/easytier/src/dns/server.rs @@ -233,73 +233,6 @@ impl DnsServer { tokio::time::sleep(Duration::from_secs(1)).await; } } - - // pub async fn run(&self) { - // let server = self.clone(); - // tokio::spawn(async move { - // loop { - // tokio::time::sleep(Duration::from_secs(5)).await; - // let mut expired = Vec::new(); - // let now = Instant::now(); - // - // let mut clients_guard = server.clients.write().await; - // // Check expired - // for (id, (_, last_heartbeat, _)) in clients_guard.iter() { - // if now.duration_since(*last_heartbeat) > Duration::from_secs(30) { - // expired.push(*id); - // } - // } - // - // let mut changed = !expired.is_empty(); - // for id in expired { - // clients_guard.remove(&id); - // } - // drop(clients_guard); - // - // if changed { - // server.rebuild_catalog().await; - // } - // } - // }); - // } - // - // async fn update_listeners_from_clients(&self) { - // let guard = self.clients.read().await; - // // Collect all unique listeners - // let mut listeners = std::collections::HashSet::new(); - // for (_, (snapshot, _, _)) in guard.iter() { - // for listener in &snapshot.listeners { - // if let Ok(addr) = NameServerAddr::try_from(PbUrl::from(listener.clone())) { - // // We need SocketAddr. NameServerAddr -> Url -> SocketAddrs -> SocketAddr. - // // Or assume NameServerAddr stores SocketAddr. - // if let Ok(url) = Url::parse(&addr.to_string()) { - // if let Ok(addrs) = url.socket_addrs(|| None) { - // listeners.extend(addrs); - // } - // } - // } - // } - // } - // drop(guard); - // - // let listeners_vec: Vec<_> = listeners.into_iter().collect(); - // // We should check if listeners changed before restarting server. - // // But update_listeners handles simple restart. - // // TODO: optimize to check diff. - // - // let _ = self.update_listeners(&listeners_vec).await; - // } - // - // pub async fn get_hijack_addresses(&self) -> Vec { - // let guard = self.clients.read().await; - // let mut addresses = std::collections::HashSet::new(); - // for (_, (snapshot, _, _)) in guard.iter() { - // for addr in &snapshot.addresses { - // addresses.insert(SocketAddr::from(addr.clone())); - // } - // } - // addresses.into_iter().collect() - // } } #[async_trait::async_trait]