middleware/httproxy: smaller timeouts

Make the timeouts smaller after we fail to connect.
This commit is contained in:
Miek Gieben 2016-11-27 15:24:50 +00:00
parent 96222927a3
commit 0876a38cd9
2 changed files with 3 additions and 3 deletions

View file

@ -73,7 +73,7 @@ func (g *google) Exchange(req *dns.Msg) (*dns.Msg, error) {
timeout := addr.FailTimeout timeout := addr.FailTimeout
if timeout == 0 { if timeout == 0 {
timeout = 10 * time.Second timeout = 5 * time.Second
} }
atomic.AddInt32(&addr.Fails, 1) atomic.AddInt32(&addr.Fails, 1)
go func(host *proxy.UpstreamHost, timeout time.Duration) { go func(host *proxy.UpstreamHost, timeout time.Duration) {
@ -185,7 +185,7 @@ func (g *google) lookup(r *dns.Msg) ([]string, error) {
timeout := host.FailTimeout timeout := host.FailTimeout
if timeout == 0 { if timeout == 0 {
timeout = 10 * time.Second timeout = 7 * time.Second
} }
atomic.AddInt32(&host.Fails, 1) atomic.AddInt32(&host.Fails, 1)
go func(host *proxy.UpstreamHost, timeout time.Duration) { go func(host *proxy.UpstreamHost, timeout time.Duration) {

View file

@ -22,7 +22,7 @@ func newSimpleUpstream(hosts []string) (*simpleUpstream, error) {
upstream := &simpleUpstream{ upstream := &simpleUpstream{
Hosts: nil, Hosts: nil,
Policy: &proxy.Random{}, Policy: &proxy.Random{},
FailTimeout: 10 * time.Second, FailTimeout: 3 * time.Second,
MaxFails: 3, MaxFails: 3,
} }