Fixed unexpected cancel watch which WatchID equal to 0.

etcd-io · Aug 2, 2022 · 680314f · 680314f
1 parent 4f0e92d
commit 680314f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/storage/mvcc/watchable_store.go b/server/storage/mvcc/watchable_store.go
@@ -108,6 +108,7 @@ func (s *watchableStore) NewWatchStream() WatchStream {
 	return &watchStream{
 		watchable: s,
 		ch:        make(chan WatchResponse, chanBufLen),
+		nextID:    1,
 		cancels:   make(map[WatchID]cancelFunc),
 		watchers:  make(map[WatchID]*watcher),
 	}