Skip to content

Commit 293983e

Browse files
committed
fixup! kvserver: treat priority update as a success with onEnqueueResult
1 parent ccb5a00 commit 293983e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/kv/kvserver/queue.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -897,7 +897,7 @@ func (bq *baseQueue) addInternal(
897897
log.Infof(ctx, "updating priority: %0.3f -> %0.3f", item.priority, priority)
898898
}
899899
bq.mu.priorityQ.update(item, priority)
900-
// item.index should be updated now based on heap property now.
900+
// item.index should be updated now based on heap property now.
901901
cb.onEnqueueResult(item.index /*indexOnHeap*/, nil)
902902
}
903903
return false, nil

0 commit comments

Comments
 (0)