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: perform leaking queries in non-cd mode

Browse Source
This commit is contained in:
Cuong Manh Le
2024-12-13 14:41:46 +07:00
committed by Cuong Manh Le
parent 89f7874fc6
commit cb49d0d947
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/cli/dns_proxy.go
+1 -1
View File
@@ -595,7 +595,7 @@ func (p *prog) proxy(ctx context.Context, req *proxyRequest) *proxyResponse {
return res return res
} }
ctrld.Log(ctx, mainLog.Load().Error(), "all %v endpoints failed", upstreams) ctrld.Log(ctx, mainLog.Load().Error(), "all %v endpoints failed", upstreams)
if cdUID != "" && p.leakOnUpstreamFailure() { if p.leakOnUpstreamFailure() {
p.leakingQueryMu.Lock() p.leakingQueryMu.Lock()
if !p.leakingQueryWasRun { if !p.leakingQueryWasRun {
p.leakingQueryWasRun = true p.leakingQueryWasRun = true
cmd/cli/dns_proxy_test.go
+1
View File
@@ -75,6 +75,7 @@ func Test_canonicalName(t *testing.T) {
func Test_prog_upstreamFor(t *testing.T) { func Test_prog_upstreamFor(t *testing.T) {
cfg := testhelper.SampleConfig(t) cfg := testhelper.SampleConfig(t)
cfg.Service.LeakOnUpstreamFailure = func(v bool) *bool { return &v }(false)
p := &prog{cfg: cfg} p := &prog{cfg: cfg}
p.um = newUpstreamMonitor(p.cfg) p.um = newUpstreamMonitor(p.cfg)
p.lanLoopGuard = newLoopGuard() p.lanLoopGuard = newLoopGuard()