From e2bca04b99c6dd06e900e88af03c2425f831b0d4 Mon Sep 17 00:00:00 2001
From: wangwx <wangwx@tuya.com>
Date: Mon, 22 Jun 2020 14:24:28 +0800
Subject: [PATCH] add unlock
---
remoting/zookeeper/listener.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/remoting/zookeeper/listener.go b/remoting/zookeeper/listener.go
index 71d7948eb..4cafa4070 100644
--- a/remoting/zookeeper/listener.go
+++ b/remoting/zookeeper/listener.go
@@ -242,6 +242,7 @@ func (l *ZkEventListener) listenDirEvent(zkPath string, listener remoting.DataLi
//When Zk disconnected, the Conn will be set to nil, so here need check the value of Conn
l.client.RLock()
if l.client.Conn == nil {
+ l.client.RUnlock()
break
}
content, _, err := l.client.Conn.Get(dubboPath)
--
GitLab