Merge 119079d into 1558d48

mesos · Aug 31, 2018 · 5502ced · 5502ced
2 parents 1558d48 + 119079d
commit 5502ced
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/api/v1/lib/backoff/backoff.go b/api/v1/lib/backoff/backoff.go
@@ -72,6 +72,10 @@ func Notifier(minWait, maxWait time.Duration, until <-chan struct{}) <-chan stru
 					d = maxWait
 				}
 				limiter = nil
+				// drain the timer to avoid Reset problems
+				if !t.Stop() {
+					<-t.C
+				}
 			case <-t.C:
 				if limiter != nil {
 					d /= 2
@@ -82,7 +86,7 @@ func Notifier(minWait, maxWait time.Duration, until <-chan struct{}) <-chan stru
 				return
 			}
 			// important to have non-zero minWait otherwise we busy-loop
-			if d == 0 {
+			if d < minWait {
 				d = minWait
 			}
 			t.Reset(d)