aboutsummaryrefslogtreecommitdiff
path: root/plugin/forward/forward.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugin/forward/forward.go')
-rw-r--r--plugin/forward/forward.go16
1 files changed, 6 insertions, 10 deletions
diff --git a/plugin/forward/forward.go b/plugin/forward/forward.go
index 861ff61a8..6eb2e0084 100644
--- a/plugin/forward/forward.go
+++ b/plugin/forward/forward.go
@@ -112,7 +112,7 @@ func (f *Forward) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg
if err == ErrCachedClosed { // Remote side closed conn, can only happen with TCP.
continue
}
- // Retry with TCP if truncated and prefer_udp configured
+ // Retry with TCP if truncated and prefer_udp configured.
if err == dns.ErrTruncated && !opts.forceTCP && f.opts.preferUDP {
opts.forceTCP = true
continue
@@ -166,9 +166,7 @@ func (f *Forward) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg
}
func (f *Forward) match(state request.Request) bool {
- from := f.from
-
- if !plugin.Name(from).Matches(state.Name()) || !f.isAllowedDomain(state.Name()) {
+ if !plugin.Name(f.from).Matches(state.Name()) || !f.isAllowedDomain(state.Name()) {
return false
}
@@ -188,9 +186,6 @@ func (f *Forward) isAllowedDomain(name string) bool {
return true
}
-// From returns the base domain to match for the request to be forwarded.
-func (f *Forward) From() string { return f.from }
-
// ForceTCP returns if TCP is forced to be used even when the request comes in over UDP.
func (f *Forward) ForceTCP() bool { return f.opts.forceTCP }
@@ -201,11 +196,11 @@ func (f *Forward) PreferUDP() bool { return f.opts.preferUDP }
func (f *Forward) List() []*Proxy { return f.p.List(f.proxies) }
var (
- // ErrNoHealthy means no healthy proxies left
+ // ErrNoHealthy means no healthy proxies left.
ErrNoHealthy = errors.New("no healthy proxies")
- // ErrNoForward means no forwarder defined
+ // ErrNoForward means no forwarder defined.
ErrNoForward = errors.New("no forwarder defined")
- // ErrCachedClosed means cached connection was closed by peer
+ // ErrCachedClosed means cached connection was closed by peer.
ErrCachedClosed = errors.New("cached connection was closed by peer")
)
@@ -218,6 +213,7 @@ const (
sequentialPolicy
)
+// options holds various options that can be set.
type options struct {
forceTCP bool
preferUDP bool