Skip to content

Commit

Permalink
fix runlock bug
Browse files Browse the repository at this point in the history
  • Loading branch information
leoyang.yl committed Nov 25, 2021
1 parent 7572a61 commit 8deda4c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion server/storage/mvcc/watchable_store.go
Original file line number Diff line number Diff line change
Expand Up @@ -355,8 +355,8 @@ func (s *watchableStore) syncWatchers() int {
tx := s.store.b.ReadTx()
tx.RLock()
revs, vs := tx.UnsafeRange(schema.Key, minBytes, maxBytes, 0)
tx.RUnlock()
evs := kvsToEvents(s.store.lg, wg, revs, vs)
tx.RUnlock()

victims := make(watcherBatch)
wb := newWatcherBatch(wg, evs)
Expand Down

0 comments on commit 8deda4c

Please sign in to comment.