wangjia/sing-box
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix rules lock

Browse Source
This commit is contained in:
世界
2026-04-09 22:02:38 +08:00
parent a7b02f9cb2
commit ec75e5ec0a
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dns/router.go
+4 -2
View File
@@ -589,12 +589,13 @@ func (r *Router) Exchange(ctx context.Context, message *mDNS.Msg, options adapte
return &responseMessage, nil return &responseMessage, nil
} }
r.rulesAccess.RLock() r.rulesAccess.RLock()
defer r.rulesAccess.RUnlock()
if r.closing { if r.closing {
r.rulesAccess.RUnlock()
return nil, E.New("dns router closed") return nil, E.New("dns router closed")
} }
rules := r.rules rules := r.rules
legacyDNSMode := r.legacyDNSMode legacyDNSMode := r.legacyDNSMode
r.rulesAccess.RUnlock()
r.logger.DebugContext(ctx, "exchange ", FormatQuestion(message.Question[0].String())) r.logger.DebugContext(ctx, "exchange ", FormatQuestion(message.Question[0].String()))
var ( var (
response *mDNS.Msg response *mDNS.Msg
@@ -701,12 +702,13 @@ done:
func (r *Router) Lookup(ctx context.Context, domain string, options adapter.DNSQueryOptions) ([]netip.Addr, error) { func (r *Router) Lookup(ctx context.Context, domain string, options adapter.DNSQueryOptions) ([]netip.Addr, error) {
r.rulesAccess.RLock() r.rulesAccess.RLock()
defer r.rulesAccess.RUnlock()
if r.closing { if r.closing {
r.rulesAccess.RUnlock()
return nil, E.New("dns router closed") return nil, E.New("dns router closed")
} }
rules := r.rules rules := r.rules
legacyDNSMode := r.legacyDNSMode legacyDNSMode := r.legacyDNSMode
r.rulesAccess.RUnlock()
var ( var (
responseAddrs []netip.Addr responseAddrs []netip.Addr
err error err error