diff options
Diffstat (limited to 'plugin/proxy/down.go')
| -rw-r--r-- | plugin/proxy/down.go | 16 |
1 files changed, 2 insertions, 14 deletions
diff --git a/plugin/proxy/down.go b/plugin/proxy/down.go index 5dc8b678d..11f839b46 100644 --- a/plugin/proxy/down.go +++ b/plugin/proxy/down.go @@ -2,7 +2,6 @@ package proxy import ( "sync/atomic" - "time" "github.com/coredns/coredns/plugin/pkg/healthcheck" ) @@ -10,21 +9,10 @@ import ( // Default CheckDown functions for use in the proxy plugin. var checkDownFunc = func(upstream *staticUpstream) healthcheck.UpstreamHostDownFunc { return func(uh *healthcheck.UpstreamHost) bool { - - down := false - - uh.Lock() - until := uh.OkUntil - uh.Unlock() - - if !until.IsZero() && time.Now().After(until) { - down = true - } - fails := atomic.LoadInt32(&uh.Fails) if fails >= upstream.MaxFails && upstream.MaxFails != 0 { - down = true + return true } - return down + return false } } |