Skip to content

Commit 2ae65d2

Browse files
committed
avoid negative time normalized values
1 parent 67adb9c commit 2ae65d2

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

decor/eta.go

+8-2
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,10 @@ func MaxTolerateTimeNormalizer(maxTolerate time.Duration) TimeNormalizer {
164164
}
165165
normalized -= time.Since(lastCall)
166166
lastCall = time.Now()
167-
return normalized
167+
if normalized > 0 {
168+
return normalized
169+
}
170+
return remaining
168171
})
169172
}
170173

@@ -183,7 +186,10 @@ func FixedIntervalTimeNormalizer(updInterval int) TimeNormalizer {
183186
count--
184187
normalized -= time.Since(lastCall)
185188
lastCall = time.Now()
186-
return normalized
189+
if normalized > 0 {
190+
return normalized
191+
}
192+
return remaining
187193
})
188194
}
189195

0 commit comments

Comments
 (0)