CalvinBackup/ctrld
1
0
Fork 0
mirror of https://github.com/Control-D-Inc/ctrld.git synced 2026-07-04 01:07:49 +02:00
Code Issues Packages Projects Releases Wiki Activity

cmd/cli: log upstream name if endpoint is empty

Browse Source
This commit is contained in:
Cuong Manh Le
2025-01-14 22:16:03 +07:00
committed by Cuong Manh Le
parent 9c2fe8d21f
commit f986a575e8
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/cli/upstream_monitor.go
+7 -3
View File
@@ -120,10 +120,14 @@ func (p *prog) checkUpstream(upstream string, uc *ctrld.UpstreamConfig) {
_, err := resolver.Resolve(ctx, msg) _, err := resolver.Resolve(ctx, msg)
return err 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 { for {
if err := check(); err == nil { 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) p.um.reset(upstream)
if p.leakingQuery.CompareAndSwap(true, false) { if p.leakingQuery.CompareAndSwap(true, false) {
p.leakingQueryMu.Lock() p.leakingQueryMu.Lock()
@@ -133,7 +137,7 @@ func (p *prog) checkUpstream(upstream string, uc *ctrld.UpstreamConfig) {
} }
return return
} else { } 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) time.Sleep(checkUpstreamBackoffSleep)
} }