avoid negative time normalized values

vbauerster · Aug 20, 2024 · 2ae65d2 · 2ae65d2
1 parent 67adb9c
commit 2ae65d2
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/decor/eta.go b/decor/eta.go
@@ -164,7 +164,10 @@ func MaxTolerateTimeNormalizer(maxTolerate time.Duration) TimeNormalizer {
 		}
 		normalized -= time.Since(lastCall)
 		lastCall = time.Now()
-		return normalized
+		if normalized > 0 {
+			return normalized
+		}
+		return remaining
 	})
 }
 
@@ -183,7 +186,10 @@ func FixedIntervalTimeNormalizer(updInterval int) TimeNormalizer {
 		count--
 		normalized -= time.Since(lastCall)
 		lastCall = time.Now()
-		return normalized
+		if normalized > 0 {
+			return normalized
+		}
+		return remaining
 	})
 }