From 02b986bb60bee6705e08febf16bad28a75d83feb Mon Sep 17 00:00:00 2001
From: pantianying <601666418@qq.com>
Date: Sun, 1 Dec 2019 12:31:20 +0800
Subject: [PATCH] fix bug
---
registry/zookeeper/registry.go | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
index 137aa5423..e41991556 100644
--- a/registry/zookeeper/registry.go
+++ b/registry/zookeeper/registry.go
@@ -435,6 +435,7 @@ func (r *zkRegistry) Subscribe(url *common.URL, notifyListener registry.NotifyLi
for {
if serviceEvent, err := listener.Next(); err != nil {
+ logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
listener.Close()
break
} else {
@@ -454,8 +455,8 @@ func (r *zkRegistry) getListener(conf *common.URL) (*RegistryConfigurationListen
r.listenerLock.Lock()
if r.configListener.isClosed {
- return nil, perrors.New("configListener already been closed")
r.listenerLock.Unlock()
+ return nil, perrors.New("configListener already been closed")
}
zkListener = r.configListener
r.listenerLock.Unlock()
--
GitLab