From f986a575e812dc18ecea3f8f5c9fb112154bcf64 Mon Sep 17 00:00:00 2001 From: Cuong Manh Le Date: Tue, 14 Jan 2025 22:16:03 +0700 Subject: [PATCH] cmd/cli: log upstream name if endpoint is empty --- cmd/cli/upstream_monitor.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/cmd/cli/upstream_monitor.go b/cmd/cli/upstream_monitor.go index 86c191d..512a8b6 100644 --- a/cmd/cli/upstream_monitor.go +++ b/cmd/cli/upstream_monitor.go @@ -120,10 +120,14 @@ func (p *prog) checkUpstream(upstream string, uc *ctrld.UpstreamConfig) { _, err := resolver.Resolve(ctx, msg) return err } - mainLog.Load().Warn().Msgf("upstream %q is offline", uc.Endpoint) + endpoint := uc.Endpoint + if endpoint == "" { + endpoint = uc.Name + } + mainLog.Load().Warn().Msgf("upstream %q is offline", endpoint) for { if err := check(); err == nil { - mainLog.Load().Warn().Msgf("upstream %q is online", uc.Endpoint) + mainLog.Load().Warn().Msgf("upstream %q is online", endpoint) p.um.reset(upstream) if p.leakingQuery.CompareAndSwap(true, false) { p.leakingQueryMu.Lock() @@ -133,7 +137,7 @@ func (p *prog) checkUpstream(upstream string, uc *ctrld.UpstreamConfig) { } return } else { - mainLog.Load().Debug().Msgf("checked upstream %q failed: %v", uc.Endpoint, err) + mainLog.Load().Debug().Msgf("checked upstream %q failed: %v", endpoint, err) } time.Sleep(checkUpstreamBackoffSleep) }