From 23f63f1e4a5e0e2653b252224d9834c2a5f2ec6c Mon Sep 17 00:00:00 2001 From: Luna Yao <40349250+ZnqbuZ@users.noreply.github.com> Date: Fri, 3 Apr 2026 15:07:08 +0200 Subject: [PATCH] log & clippy --- easytier/src/dns/config/dns.rs | 2 +- easytier/src/dns/node.rs | 2 ++ easytier/src/dns/peer_mgr.rs | 2 ++ easytier/src/dns/server.rs | 6 +++--- easytier/src/instance/proxy_cidrs_monitor.rs | 2 +- easytier/src/launcher.rs | 2 +- 6 files changed, 10 insertions(+), 6 deletions(-) diff --git a/easytier/src/dns/config/dns.rs b/easytier/src/dns/config/dns.rs index 69bcfb61..f3a2b54c 100644 --- a/easytier/src/dns/config/dns.rs +++ b/easytier/src/dns/config/dns.rs @@ -109,6 +109,6 @@ impl DnsGlobalCtxExt for GlobalCtx { } fn dns_iter_zones(&self) -> impl Iterator { - iter::once(self.dns_self_zone()).chain(self.config.get_dns().zones.into_iter()) + iter::once(self.dns_self_zone()).chain(self.config.get_dns().zones) } } diff --git a/easytier/src/dns/node.rs b/easytier/src/dns/node.rs index 991b5132..816e36b2 100644 --- a/easytier/src/dns/node.rs +++ b/easytier/src/dns/node.rs @@ -237,8 +237,10 @@ impl DnsNode { .scoped_client::>("".to_string()) .await?; + tracing::trace!(?request, "sending heartbeat"); let response = client.heartbeat(BaseController::default(), request).await?; if response.resync { + tracing::trace!("resync requested by server, sending full snapshot"); client .heartbeat(BaseController::default(), heartbeat.clone()) .await?; diff --git a/easytier/src/dns/peer_mgr.rs b/easytier/src/dns/peer_mgr.rs index 9380abc0..30292112 100644 --- a/easytier/src/dns/peer_mgr.rs +++ b/easytier/src/dns/peer_mgr.rs @@ -18,6 +18,7 @@ use itertools::Itertools; use moka::future::Cache; use std::sync::Arc; use std::time::Duration; +use tracing::instrument; #[derive(Debug, Clone)] pub struct DnsPeerInfo { @@ -111,6 +112,7 @@ impl DnsPeerMgr { self.dirty.notify_one(); } + #[instrument(skip(self), level = "trace", ret)] async fn fetch(&self, peer_id: PeerId) -> anyhow::Result { self.peer_mgr .get_peer_rpc_mgr() diff --git a/easytier/src/dns/server.rs b/easytier/src/dns/server.rs index 1e8f66c5..5b8ec42f 100644 --- a/easytier/src/dns/server.rs +++ b/easytier/src/dns/server.rs @@ -36,7 +36,7 @@ use tokio_util::sync::CancellationToken; use tracing::{instrument, Instrument}; #[derive(Clone)] -struct DynamicCatalog { +pub struct DynamicCatalog { inner: Arc>, } @@ -121,7 +121,7 @@ impl DnsServer { ) -> anyhow::Result<()> { let listeners = listeners.into_iter().collect(); - if &*self.listeners.read() == &listeners { + if *self.listeners.read() == listeners { tracing::info!("listeners unchanged, no need to reload"); return Ok(()); } @@ -169,7 +169,7 @@ impl DnsServer { ) -> anyhow::Result<()> { let addresses = addresses.into_iter().collect(); - if &*self.addresses.read() == &addresses { + if *self.addresses.read() == addresses { tracing::info!("addresses unchanged, no need to reload"); return Ok(()); } diff --git a/easytier/src/instance/proxy_cidrs_monitor.rs b/easytier/src/instance/proxy_cidrs_monitor.rs index 4c7264a8..55701b91 100644 --- a/easytier/src/instance/proxy_cidrs_monitor.rs +++ b/easytier/src/instance/proxy_cidrs_monitor.rs @@ -77,7 +77,7 @@ impl ProxyCidrsMonitor { pub fn start(self) -> ScopedTask<()> { ScopedTask::from(tokio::spawn(async move { let mut cur_proxy_cidrs = BTreeSet::new(); - let mut last_update = None::; + // let last_update = None::; loop { tokio::time::sleep(std::time::Duration::from_secs(1)).await; diff --git a/easytier/src/launcher.rs b/easytier/src/launcher.rs index 69e354a7..78dc8ae3 100644 --- a/easytier/src/launcher.rs +++ b/easytier/src/launcher.rs @@ -492,7 +492,7 @@ impl NetworkConfig { .parse() .with_context(|| format!("failed to parse instance id: {:?}", self.instance_id))?, ); - self.hostname.as_ref().map(|n| cfg.set_hostname(n)); + if let Some(n) = self.hostname.as_ref() { cfg.set_hostname(n) } cfg.set_dhcp(self.dhcp.unwrap_or_default()); cfg.set_inst_name(self.network_name.clone().unwrap_or_default());