use first public os reolver response when no LAN servers exist

os resolver debugging improvement

use first public non success answer when no LAN nameservers exist

use first public non success answer when no LAN nameservers exist

fix the os resolver test
This commit is contained in:
Alex authored and Cuong Manh Le committed 2025-02-18 20:23:36 +07:00
1 parent e6de78c1fa
commit 23e6ad6e1f
2 files changed
+61 -23

No files matched your search

+28 -8
View File
@@ -290,7 +290,7 @@ func (o *osResolver) Resolve(ctx context.Context, msg *dns.Msg) (*dns.Msg, error
} }
} }
Log(ctx, ProxyLogger.Load().Debug(), "os resolver query with nameservers: %v", nss) Log(ctx, ProxyLogger.Load().Debug(), "os resolver query with nameservers: %v public: %v", nss, publicServers)
// New check: If no resolvers are available, return an error. // New check: If no resolvers are available, return an error.
if numServers == 0 { if numServers == 0 {
@@ -343,11 +343,15 @@ func (o *osResolver) Resolve(ctx context.Context, msg *dns.Msg) (*dns.Msg, error
} }
// try local nameservers // try local nameservers
do(nss, true) if len(nss) > 0 {
do(nss, true)
}
// we must always try the public servers too, since DCHP may have only public servers // we must always try the public servers too, since DCHP may have only public servers
// this is okay to do since we always prefer LAN nameserver responses // this is okay to do since we always prefer LAN nameserver responses
do(publicServers, false) if len(publicServers) > 0 {
do(publicServers, false)
}
var ( var (
nonSuccessAnswer *dns.Msg nonSuccessAnswer *dns.Msg
@@ -369,33 +373,49 @@ func (o *osResolver) Resolve(ctx context.Context, msg *dns.Msg) (*dns.Msg, error
case res.server == controldPublicDnsWithPort: case res.server == controldPublicDnsWithPort:
controldSuccessAnswer = res.answer controldSuccessAnswer = res.answer
case !res.lan: case !res.lan:
// if there are no LAN nameservers, we should not wait
// just use the first response
if len(nss) == 0 {
Log(ctx, ProxyLogger.Load().Debug(), "using public answer from: %s", res.server)
cancel()
logAnswer(res.server)
return res.answer, nil
}
publicResponses = append(publicResponses, publicResponse{ publicResponses = append(publicResponses, publicResponse{
answer: res.answer, answer: res.answer,
server: res.server, server: res.server,
}) })
} }
case res.answer != nil: case res.answer != nil:
nonSuccessAnswer = res.answer
nonSuccessServer = res.server
Log(ctx, ProxyLogger.Load().Debug(), "got non-success answer from: %s with code: %d", Log(ctx, ProxyLogger.Load().Debug(), "got non-success answer from: %s with code: %d",
res.server, res.answer.Rcode) res.server, res.answer.Rcode)
// When there are no LAN nameservers, we should not wait
// for other nameservers to respond.
if len(nss) == 0 {
Log(ctx, ProxyLogger.Load().Debug(), "no lan nameservers using public non success answer")
cancel()
logAnswer(res.server)
return res.answer, nil
}
nonSuccessAnswer = res.answer
nonSuccessServer = res.server
} }
errs = append(errs, res.err) errs = append(errs, res.err)
} }
if len(publicResponses) > 0 { if len(publicResponses) > 0 {
resp := publicResponses[0] resp := publicResponses[0]
Log(ctx, ProxyLogger.Load().Debug(), "got public answer from: %s", resp.server) Log(ctx, ProxyLogger.Load().Debug(), "using public answer from: %s", resp.server)
logAnswer(resp.server) logAnswer(resp.server)
return resp.answer, nil return resp.answer, nil
} }
if controldSuccessAnswer != nil { if controldSuccessAnswer != nil {
Log(ctx, ProxyLogger.Load().Debug(), "got ControlD answer from: %s", controldPublicDnsWithPort) Log(ctx, ProxyLogger.Load().Debug(), "using ControlD answer from: %s", controldPublicDnsWithPort)
logAnswer(controldPublicDnsWithPort) logAnswer(controldPublicDnsWithPort)
return controldSuccessAnswer, nil return controldSuccessAnswer, nil
} }
if nonSuccessAnswer != nil { if nonSuccessAnswer != nil {
Log(ctx, ProxyLogger.Load().Debug(), "got non-success answer from: %s", nonSuccessServer) Log(ctx, ProxyLogger.Load().Debug(), "using non-success answer from: %s", nonSuccessServer)
logAnswer(nonSuccessServer) logAnswer(nonSuccessServer)
return nonSuccessAnswer, nil return nonSuccessAnswer, nil
} }
+33 -15
View File
@@ -70,41 +70,59 @@ func Test_osResolver_ResolveLanHostname(t *testing.T) {
} }
func Test_osResolver_ResolveWithNonSuccessAnswer(t *testing.T) { func Test_osResolver_ResolveWithNonSuccessAnswer(t *testing.T) {
ns := make([]string, 0, 2) // Set up a LAN nameserver that returns a success response.
servers := make([]*dns.Server, 0, 2) lanPC, err := net.ListenPacket("udp", "127.0.0.1:0") // 127.0.0.1 is considered LAN (loopback)
handlers := []dns.Handler{ if err != nil {
t.Fatalf("failed to listen on LAN address: %v", err)
}
lanServer, lanAddr, err := runLocalPacketConnTestServer(t, lanPC, successHandler())
if err != nil {
t.Fatalf("failed to run LAN test server: %v", err)
}
defer lanServer.Shutdown()
// Set up two public nameservers that return non-success responses.
publicHandlers := []dns.Handler{
nonSuccessHandlerWithRcode(dns.RcodeRefused), nonSuccessHandlerWithRcode(dns.RcodeRefused),
nonSuccessHandlerWithRcode(dns.RcodeNameError), nonSuccessHandlerWithRcode(dns.RcodeNameError),
successHandler(),
} }
for i := range handlers { var publicNS []string
var publicServers []*dns.Server
for _, handler := range publicHandlers {
pc, err := net.ListenPacket("udp", ":0") pc, err := net.ListenPacket("udp", ":0")
if err != nil { if err != nil {
t.Fatalf("unexpected error: %v", err) t.Fatalf("failed to listen on public address: %v", err)
} }
s, addr, err := runLocalPacketConnTestServer(t, pc, handler)
s, addr, err := runLocalPacketConnTestServer(t, pc, handlers[i])
if err != nil { if err != nil {
t.Fatalf("unexpected error: %v", err) t.Fatalf("failed to run public test server: %v", err)
} }
ns = append(ns, addr) publicNS = append(publicNS, addr)
servers = append(servers, s) publicServers = append(publicServers, s)
} }
defer func() { defer func() {
for _, server := range servers { for _, s := range publicServers {
server.Shutdown() s.Shutdown()
} }
}() }()
// We now create an osResolver which has both a LAN and public nameserver.
resolver := &osResolver{} resolver := &osResolver{}
resolver.publicServers.Store(&ns) // Explicitly store the LAN nameserver.
resolver.lanServers.Store(&[]string{lanAddr})
// And store the public nameservers.
resolver.publicServers.Store(&publicNS)
msg := new(dns.Msg) msg := new(dns.Msg)
msg.SetQuestion(".", dns.TypeNS) msg.SetQuestion(".", dns.TypeNS)
answer, err := resolver.Resolve(context.Background(), msg) answer, err := resolver.Resolve(context.Background(), msg)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
// Since a LAN nameserver is available and returns a success answer, we expect RcodeSuccess.
if answer.Rcode != dns.RcodeSuccess { if answer.Rcode != dns.RcodeSuccess {
t.Errorf("unexpected return code: %s", dns.RcodeToString[answer.Rcode]) t.Errorf("expected a success answer from LAN nameserver (RcodeSuccess) but got: %s", dns.RcodeToString[answer.Rcode])
} }
} }