diff options
Diffstat (limited to 'plugin/forward/connect.go')
| -rw-r--r-- | plugin/forward/connect.go | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/plugin/forward/connect.go b/plugin/forward/connect.go index 9dd6ac855..6b335c5b1 100644 --- a/plugin/forward/connect.go +++ b/plugin/forward/connect.go @@ -18,10 +18,14 @@ import ( func (p *Proxy) readTimeout() time.Duration { rtt := time.Duration(atomic.LoadInt64(&p.avgRtt)) - if rtt < timeout/2 { + + if rtt < minTimeout { + return minTimeout + } + if rtt < maxTimeout/2 { return 2 * rtt } - return timeout + return maxTimeout } func (p *Proxy) updateRtt(newRtt time.Duration) { |