diff --git a/mvcc/watchable_store.go b/mvcc/watchable_store.go index 0529993c6..4d709d644 100644 --- a/mvcc/watchable_store.go +++ b/mvcc/watchable_store.go @@ -358,9 +358,9 @@ func (s *watchableStore) syncWatchers() int { tx := s.store.b.ReadTx() tx.RLock() revs, vs := tx.UnsafeRange(keyBucketName, minBytes, maxBytes, 0) + tx.RUnlock() var evs []mvccpb.Event evs = kvsToEvents(s.store.lg, wg, revs, vs) - tx.RUnlock() var victims watcherBatch wb := newWatcherBatch(wg, evs)