From fb877d09eb0af3f20d899f6576aec9767f0595e6 Mon Sep 17 00:00:00 2001
From: pantianying <601666418@qq.com>
Date: Mon, 19 Aug 2019 16:25:42 +0800
Subject: [PATCH] log change
---
registry/zookeeper/listener.go | 9 +++++++--
registry/zookeeper/registry.go | 2 +-
2 files changed, 8 insertions(+), 3 deletions(-)
diff --git a/registry/zookeeper/listener.go b/registry/zookeeper/listener.go
index 19f25693c..7d58cee12 100644
--- a/registry/zookeeper/listener.go
+++ b/registry/zookeeper/listener.go
@@ -46,10 +46,15 @@ func (l *RegistryDataListener) AddInterestedURL(url *common.URL) {
func (l *RegistryDataListener) DataChange(eventType remoting.Event) bool {
// Intercept the last bit
- url := eventType.Path[strings.Index(eventType.Path, "/providers/")+len("/providers/"):]
+ index := strings.Index(eventType.Path, "/providers/")
+ if index == -1 {
+ logger.Warn("Listen with no url, event.path={%v}", eventType.Path)
+ return false
+ }
+ url := eventType.Path[index+len("/providers/"):]
serviceURL, err := common.NewURL(context.TODO(), url)
if err != nil {
- logger.Errorf("Listen NewURL(r{%s}) = error{%v}", url, err)
+ logger.Errorf("Listen NewURL(r{%s}) = error{%v} eventType.Path={%v}", url, err, eventType.Path)
return false
}
for _, v := range l.interestedURL {
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
index e2fca9723..eea573dab 100644
--- a/registry/zookeeper/registry.go
+++ b/registry/zookeeper/registry.go
@@ -381,7 +381,7 @@ func (r *zkRegistry) registerTempZookeeperNode(root string, node string) error {
}
zkPath, err = r.client.RegisterTemp(root, node)
if err != nil {
- logger.Errorf("RegisterTempNode(root{%s}, node{%s}) = error{%v}", root, node, perrors.WithStack(err))
+ logger.Warnf("RegisterTempNode(root{%s}, node{%s}) = error{%v}", root, node, perrors.WithStack(err))
return perrors.WithMessagef(err, "RegisterTempNode(root{%s}, node{%s})", root, node)
}
logger.Debugf("create a zookeeper node:%s", zkPath)
--
GitLab