Skip to content

Commit

Permalink
fixup! fix multiple enqueues skipping waitForWake
Browse files Browse the repository at this point in the history
  • Loading branch information
jkasten2 committed Mar 28, 2024
1 parent 4a64d97 commit 60a4280
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -129,8 +129,7 @@ internal class OperationRepo(
// 2. Wait at least the time defined in opRepoExecutionInterval
// so operations can be grouped, unless one of them used
// flush=true (AKA force)
val startTime = _time.currentTimeMillis
var lastTime = startTime
var lastTime = _time.currentTimeMillis
var remainingTime = _configModelStore.model.opRepoExecutionInterval
while (!force && remainingTime > 0) {
withTimeoutOrNull(remainingTime) {
Expand Down

0 comments on commit 60a4280

Please sign in to comment.