From c42214b506fbe64f15026401f1bfa965f9a94d7c Mon Sep 17 00:00:00 2001
From: scott <scottwangsxll@gmail.com>
Date: Sun, 15 Mar 2020 21:42:43 +0800
Subject: [PATCH] Fix zookeeper wg bug
---
remoting/zookeeper/listener.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/remoting/zookeeper/listener.go b/remoting/zookeeper/listener.go
index 6c8b1720a..eaf259f44 100644
--- a/remoting/zookeeper/listener.go
+++ b/remoting/zookeeper/listener.go
@@ -249,6 +249,7 @@ func (l *ZkEventListener) listenDirEvent(zkPath string, listener remoting.DataLi
continue
}
logger.Infof("listen dubbo service key{%s}", dubboPath)
+ l.wg.Add(1)
go func(zkPath string, listener remoting.DataListener) {
if l.ListenServiceNodeEvent(zkPath) {
listener.DataChange(remoting.Event{Path: zkPath, Action: remoting.EventTypeDel})
--
GitLab