Skip to content

Commit 7d27341

Browse files
committed
dnsx/cacher: m debug log
1 parent 7cd86f9 commit 7d27341

3 files changed

Lines changed: 8 additions & 1 deletion

File tree

intra/dns53/dot.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,11 +9,13 @@ package dns53
99
import (
1010
"context"
1111
"crypto/tls"
12+
"errors"
1213
"fmt"
1314
"net"
1415
"net/netip"
1516
"net/url"
1617
"strconv"
18+
"sync/atomic"
1719
"time"
1820

1921
x "github.com/celzero/firestack/intra/backend"

intra/dnsx/alg.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1862,7 +1862,7 @@ func Req(t Transport, network string, q *dns.Msg, smm *x.DNSSummary) (*dns.Msg,
18621862
return r, nil
18631863
}
18641864

1865-
log.V("alg: Req: %s:%d servfail; by: %s, rdata: %d, status: %s, rcode %d",
1865+
log.V("alg: Req: %s:%d servfail; by: %s, rdata: %d, status: %d, rcode %d",
18661866
qname, qtyp, smm.ID, smm.RData, smm.Status, xdns.Rcode(r))
18671867
return r, err
18681868
}

intra/dnsx/cacher.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -392,6 +392,11 @@ func (t *ctransport) fetch(network string, q *dns.Msg, smmout *x.DNSSummary, cb
392392
return ccx, qerr
393393
})
394394

395+
if cc == nil {
396+
log.E("cache: barrier: %s; nil return for %s; err? %v", t.ID(), key, err)
397+
ccx = cc
398+
}
399+
395400
cachedres, fresh := cb.freshCopy(key) // always prefer value from cache
396401
cachehit := cachedres != nil
397402
// nil ans when Transport returns err (no servfail) and cache is empty

0 commit comments

Comments
 (0)