From 23a7df9f49c949be5f949191950aa963dcd07544 Mon Sep 17 00:00:00 2001
From: pantianying <601666418@qq.com>
Date: Sat, 23 Nov 2019 12:29:32 +0800
Subject: [PATCH] update
---
registry/zookeeper/registry.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
index ee7154fba..31f1dc3a8 100644
--- a/registry/zookeeper/registry.go
+++ b/registry/zookeeper/registry.go
@@ -406,7 +406,9 @@ func (r *zkRegistry) subscribe(conf *common.URL) (registry.Listener, error) {
//subscribe from registry
func (r *zkRegistry) Subscribe(url *common.URL, notifyListener registry.NotifyListener) {
+ n := 0
for {
+ n++
if !r.IsAvailable() {
logger.Warnf("event listener game over.")
return
@@ -422,12 +424,10 @@ func (r *zkRegistry) Subscribe(url *common.URL, notifyListener registry.NotifyLi
time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
continue
}
- n := 0
- for {
- n++
+ for i := 0; ; i++ {
if serviceEvent, err := listener.Next(); err != nil {
logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
- if n == 1 {
+ if i == 0 {
listener.Close()
break
}
--
GitLab