mirror/Easytier
1
0
Fork 0
mirror of https://github.com/EasyTier/EasyTier.git synced 2026-08-06 20:49:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

server: remove comments

Browse Source
This commit is contained in:
Luna Yao
2026-02-21 19:26:11 +01:00
parent d3ca03e20e
commit f83816ac16
1 changed files with 0 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files
easytier/src/dns/server.rs
-67
View File
@@ -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<SocketAddr> {
// 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]