remove cap and len checking

etcd-io · Nov 16, 2021 · 9643999 · 9643999
1 parent 23626d8
commit 9643999
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/storage/mvcc/watchable_store.go b/server/storage/mvcc/watchable_store.go
@@ -372,7 +372,7 @@ func (s *watchableStore) syncWatchers() int {
 	tx.RUnlock()
 	evs, err := s.kvsToEvents(wg, revs, vs)
 	if err != nil {
-		if s.errorc != nil && cap(s.errorc) > len(s.errorc) {
+		if s.errorc != nil {
 			s.lg.Fatal("kvsToEvents failed", zap.Error(err))
 			s.errorc <- err
 			return 0