diff --git a/store/store.go b/store/store.go index 6190e354d..debf1192e 100644 --- a/store/store.go +++ b/store/store.go @@ -444,7 +444,7 @@ func (s *store) deleteExpiredKeys(cutoff time.Time, index uint64, term uint64) { for { node := s.ttlKeyHeap.top() if node == nil || node.ExpireTime.After(cutoff) { - return + break } s.ttlKeyHeap.pop() @@ -453,7 +453,6 @@ func (s *store) deleteExpiredKeys(cutoff time.Time, index uint64, term uint64) { s.Stats.Inc(ExpireCount) s.WatcherHub.notify(newEvent(Expire, node.Path, s.Index, s.Term)) } - s.WatcherHub.clearPendingWatchers() }