Skip to content

Commit 8e38590

Browse files
committed
kvserver: fix missing locking in test helper
Accidentally missed this in #134653. Epic: none
1 parent 2d56ca7 commit 8e38590

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pkg/kv/kvserver/helpers_test.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -167,6 +167,8 @@ func (s *Store) SplitQueuePurgatoryLength() int {
167167
// LeaseQueuePurgatory returns a map of RangeIDs representing the purgatory.
168168
func (s *Store) LeaseQueuePurgatory() map[roachpb.RangeID]struct{} {
169169
defer s.leaseQueue.baseQueue.lockProcessing()()
170+
s.leaseQueue.baseQueue.mu.Lock()
171+
defer s.leaseQueue.baseQueue.mu.Unlock()
170172
m := make(map[roachpb.RangeID]struct{}, len(s.leaseQueue.baseQueue.mu.purgatory))
171173
for k := range s.leaseQueue.baseQueue.mu.purgatory {
172174
m[k] = struct{}{}

0 commit comments

Comments
 (0)