Skip to content

Commit a5d7d88

Browse files
committed
fixup! kvserver: treat priority update as a success with onEnqueueResult
1 parent ad60270 commit a5d7d88

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
@@ -873,7 +873,7 @@ func (bq *baseQueue) addInternal(
873873
log.Dev.Infof(ctx, "updating priority: %0.3f -> %0.3f", item.priority, priority)
874874
}
875875
bq.mu.priorityQ.update(item, priority)
876-
// item.index should be updated now based on heap property now.
876+
// item.index should be updated now based on heap property now.
877877
cb.onEnqueueResult(item.index /*indexOnHeap*/, nil)
878878
}
879879
return false, nil

0 commit comments

Comments
 (0)