We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents aeaa401 + 8e38590 commit eb447f5Copy full SHA for eb447f5
pkg/kv/kvserver/helpers_test.go
@@ -167,6 +167,8 @@ func (s *Store) SplitQueuePurgatoryLength() int {
167
// LeaseQueuePurgatory returns a map of RangeIDs representing the purgatory.
168
func (s *Store) LeaseQueuePurgatory() map[roachpb.RangeID]struct{} {
169
defer s.leaseQueue.baseQueue.lockProcessing()()
170
+ s.leaseQueue.baseQueue.mu.Lock()
171
+ defer s.leaseQueue.baseQueue.mu.Unlock()
172
m := make(map[roachpb.RangeID]struct{}, len(s.leaseQueue.baseQueue.mu.purgatory))
173
for k := range s.leaseQueue.baseQueue.mu.purgatory {
174
m[k] = struct{}{}
0 commit comments