diff options
| author |  peiranliushop <33286233+peiranliushop@users.noreply.github.com>
| 2019-03-23 05:45:21 -0400 |
|---|---|---|
| committer |  Miek Gieben <miek@miek.nl>
| 2019-03-23 09:45:20 +0000 |
| commit | 403d42ce200f3c2074c521e4287728f2b8d2bf0d (patch) | |
| tree | 3dc24dbdd66299fa85da8bc550034190ed35ae85 /plugin/forward/forward.go | |
| parent | 0e137b23f152c70590e82f0b5985b2faf104c8e0 (diff) | |
| download | coredns-403d42ce200f3c2074c521e4287728f2b8d2bf0d.tar.gz coredns-403d42ce200f3c2074c521e4287728f2b8d2bf0d.tar.zst coredns-403d42ce200f3c2074c521e4287728f2b8d2bf0d.zip | |
Support logging to dnstap in forward plugin (#2703)
Diffstat (limited to 'plugin/forward/forward.go')
| -rw-r--r-- | plugin/forward/forward.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/plugin/forward/forward.go b/plugin/forward/forward.go index 0b043e070..c7f7a83c4 100644 --- a/plugin/forward/forward.go +++ b/plugin/forward/forward.go @@ -74,7 +74,7 @@ func (f *Forward) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg i := 0 list := f.List() deadline := time.Now().Add(defaultTimeout) - + start := time.Now() for time.Now().Before(deadline) { if i >= len(list) { // reached the end of list, reset to begin @@ -126,6 +126,7 @@ func (f *Forward) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg if child != nil { child.Finish() } + taperr := toDnstap(ctx, proxy.addr, f, state, ret, start) upstreamErr = err @@ -147,11 +148,11 @@ func (f *Forward) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg formerr := state.ErrorMessage(dns.RcodeFormatError) w.WriteMsg(formerr) - return 0, nil + return 0, taperr } w.WriteMsg(ret) - return 0, nil + return 0, taperr } if upstreamErr != nil { |