From f3dacda90e0089d08eca073d9cdae8d694e3a37c Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 1 Jun 2023 17:21:05 +0800 Subject: [PATCH] test discov --- pkg/discoveryregistry/zookeeper/resolver.go | 1 + pkg/discoveryregistry/zookeeper/zk.go | 8 ++++---- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/discoveryregistry/zookeeper/resolver.go b/pkg/discoveryregistry/zookeeper/resolver.go index 0a7a7e191..f79027f62 100644 --- a/pkg/discoveryregistry/zookeeper/resolver.go +++ b/pkg/discoveryregistry/zookeeper/resolver.go @@ -39,6 +39,7 @@ func (s *ZkClient) Build(target resolver.Target, cc resolver.ClientConn, opts re s.lock.Lock() defer s.lock.Unlock() s.resolvers[strings.TrimLeft(target.URL.Path, "/")] = r + log.ZDebug(context.Background(), "build resolver finished", "target", target, "cc", cc) return r, nil } diff --git a/pkg/discoveryregistry/zookeeper/zk.go b/pkg/discoveryregistry/zookeeper/zk.go index 28c07e807..b27f3d826 100644 --- a/pkg/discoveryregistry/zookeeper/zk.go +++ b/pkg/discoveryregistry/zookeeper/zk.go @@ -101,11 +101,11 @@ func NewClient(zkServers []string, zkRoot string, options ...ZkOption) (*ZkClien return nil, err } resolver.Register(client) - // var wg sync.WaitGroup - // wg.Add(2) + var wg sync.WaitGroup + wg.Add(1) // go client.refresh(&wg) - // go client.watch(&wg) - // wg.Wait() + go client.watch(&wg) + wg.Wait() return client, nil }