Merge pull request #70 from kylin2017/feature/gin

FIX
shawnfeng · Sep 11, 2019 · 767f7de · 767f7de
2 parents 8fe4f12 + 2f80784
commit 767f7de
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/util/service/clientV2.go b/util/service/clientV2.go
@@ -165,8 +165,8 @@ func (m *ClientEtcdV2) startWatch(chg chan *etcd.Response, path string) {
 		r, err := m.etcdClient.Get(context.Background(), path, &etcd.GetOptions{Recursive: true, Sort: false})
 		if err != nil {
 			slog.Warnf("%s get path:%s err:%s", fun, path, err)
-			//close(chg)
-			//return
+			close(chg)
+			return
 
 		} else {
 			chg <- r