mirror/Easytier
1
0
Fork 0
mirror of https://github.com/EasyTier/EasyTier.git synced 2026-09-03 09:35:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

structured log

Browse Source
This commit is contained in:
Luna Yao
2026-04-06 11:55:25 +02:00
parent 8610234ee2
commit 9e8a4c94cb
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
easytier/src/dns/node.rs
+2 -2
View File
@@ -159,8 +159,8 @@ impl DnsNode {
} }
_ = &mut sleep => { _ = &mut sleep => {
if let Err(e) = self.heartbeat(&mut rpc, &mut heartbeat).await { if let Err(error) = self.heartbeat(&mut rpc, &mut heartbeat).await {
tracing::error!("heartbeat failed: {:?}", e); tracing::error!(?error, "heartbeat failed");
self.elect.notify_one(); self.elect.notify_one();
} }
easytier/src/dns/server.rs
+6 -6
View File
@@ -182,8 +182,8 @@ impl DnsServer {
tracing::info!(?listeners, "reloading"); tracing::info!(?listeners, "reloading");
if let Some(runtime) = runtime.as_ref() { if let Some(runtime) = runtime.as_ref() {
if let Some(Err(e)) = runtime.stop().await { if let Some(Err(error)) = runtime.stop().await {
tracing::error!("failed to stop old DNS server runtime: {}", e); tracing::error!(?error, "failed to stop old DNS server runtime");
} }
} }
@@ -237,8 +237,8 @@ impl DnsServer {
loop { loop {
dirty.addresses.wait().await; dirty.addresses.wait().await;
if dirty.addresses.reset() { if dirty.addresses.reset() {
if let Err(e) = self.reload_addresses(self.mgr.iter_addresses()).await { if let Err(error) = self.reload_addresses(self.mgr.iter_addresses()).await {
tracing::error!("failed to reload addresses: {:?}", e); tracing::error!(?error, "failed to reload addresses");
dirty.addresses.mark(); dirty.addresses.mark();
} }
} }
@@ -250,11 +250,11 @@ impl DnsServer {
loop { loop {
dirty.listeners.wait().await; dirty.listeners.wait().await;
if dirty.listeners.reset() { if dirty.listeners.reset() {
if let Err(e) = self if let Err(error) = self
.reload_listeners(self.mgr.iter_listeners(), &mut runtime) .reload_listeners(self.mgr.iter_listeners(), &mut runtime)
.await .await
{ {
tracing::error!("failed to reload listeners: {:?}", e); tracing::error!(?error, "failed to reload listeners");
dirty.listeners.mark(); dirty.listeners.mark();
} }
} }