From bbbf8fd57413adaced345108afa91b484df6ef3d Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Sat, 28 Dec 2013 15:51:16 +0800 Subject: [PATCH] fix(watcher_hub.go) decrease count when remove a watcher --- store/watcher_hub.go | 1 + 1 file changed, 1 insertion(+) diff --git a/store/watcher_hub.go b/store/watcher_hub.go index ebc7efec2..f8650eb0f 100644 --- a/store/watcher_hub.go +++ b/store/watcher_hub.go @@ -76,6 +76,7 @@ func (wh *watcherHub) newWatcher(key string, recursive bool, index uint64) (*Wat wh.mutex.Lock() defer wh.mutex.Unlock() l.Remove(elem) + atomic.AddInt64(&wh.count, -1) if l.Len() == 0 { delete(wh.watchers, key) }