Merge 8e209e0 into b2ae992

LaurenceLiZhixin · web-flow · commit cd8ee445553a · 2021-07-29T15:40:21.000Z
diff --git a/common/logger/logs.log b/common/logger/logs.log
@@ -0,0 +1,14 @@
+2021-07-29T23:07:37.548+0800	[35mDEBUG[0m	debug
+2021-07-29T23:07:37.549+0800	[34mINFO[0m	info
+2021-07-29T23:07:37.549+0800	[33mWARN[0m	warn
+2021-07-29T23:07:37.549+0800	[31mERROR[0m	error
+2021-07-29T23:07:37.549+0800	[35mDEBUG[0m	debug
+2021-07-29T23:07:37.549+0800	[34mINFO[0m	info
+2021-07-29T23:07:37.549+0800	[33mWARN[0m	warn
+2021-07-29T23:07:37.549+0800	[31mERROR[0m	error
+2021-07-29T23:07:37.549+0800	[35mDEBUG[0m	debug
+2021-07-29T23:07:37.549+0800	[34mINFO[0m	info
+2021-07-29T23:07:37.549+0800	[35mDEBUG[0m	debug
+2021-07-29T23:07:37.549+0800	[34mINFO[0m	info
+2021-07-29T23:07:37.566+0800	[35mDEBUG[0m	debug
+2021-07-29T23:07:37.566+0800	[34mINFO[0m	info
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
@@ -108,6 +108,7 @@ func newMockZkRegistry(url *common.URL, opts ...gxzookeeper.Option) (*zk.TestClu
 	if err != nil {
 		return nil, nil, err
 	}
+	r.WaitGroup().Add(1)
 	go zookeeper.HandleClientRestart(r)
 	r.InitListeners()
 	return c, r, nil

-Original file line number
+Diff line change
 +2021-07-29T23:07:37.548+0800	[35mDEBUG[0m	debug
 +2021-07-29T23:07:37.549+0800	[34mINFO[0m	info
 +2021-07-29T23:07:37.549+0800	[33mWARN[0m	warn
 +2021-07-29T23:07:37.549+0800	[31mERROR[0m	error
 +2021-07-29T23:07:37.549+0800	[35mDEBUG[0m	debug
 +2021-07-29T23:07:37.549+0800	[34mINFO[0m	info
 +2021-07-29T23:07:37.549+0800	[33mWARN[0m	warn
 +2021-07-29T23:07:37.549+0800	[31mERROR[0m	error
 +2021-07-29T23:07:37.549+0800	[35mDEBUG[0m	debug
 +2021-07-29T23:07:37.549+0800	[34mINFO[0m	info
 +2021-07-29T23:07:37.549+0800	[35mDEBUG[0m	debug
 +2021-07-29T23:07:37.549+0800	[34mINFO[0m	info
 +2021-07-29T23:07:37.566+0800	[35mDEBUG[0m	debug
 +2021-07-29T23:07:37.566+0800	[34mINFO[0m	info
Original file line number	Diff line number	Diff line change
`@@ -108,6 +108,7 @@ func newMockZkRegistry(url common.URL, opts ...gxzookeeper.Option) (zk.TestClu`
`108`	`108`	`if err != nil {`
`109`	`109`	`return nil, nil, err`
`110`	`110`	`}`
	`111`	`+ r.WaitGroup().Add(1)`
`111`	`112`	`go zookeeper.HandleClientRestart(r)`
`112`	`113`	`r.InitListeners()`
`113`	`114`	`return c, r, nil`