From 2f80784fa26355953478e7478206191ef297b795 Mon Sep 17 00:00:00 2001 From: kylin Date: Wed, 11 Sep 2019 19:49:32 +0800 Subject: [PATCH] FIX --- util/service/clientV2.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/util/service/clientV2.go b/util/service/clientV2.go index eda0341..69b6ab5 100644 --- 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