From 60c608abae97e7159203814c9c573d0a1579ae64 Mon Sep 17 00:00:00 2001
From: pantianying <601666418@qq.com>
Date: Tue, 25 Feb 2020 11:31:34 +0800
Subject: [PATCH] check log
---
protocol/dubbo/pool.go | 2 +-
registry/directory/directory.go | 4 ++--
remoting/zookeeper/client.go | 2 +-
remoting/zookeeper/listener.go | 2 +-
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/protocol/dubbo/pool.go b/protocol/dubbo/pool.go
index 9d381585b..9e43dbcc1 100644
--- a/protocol/dubbo/pool.go
+++ b/protocol/dubbo/pool.go
@@ -78,7 +78,7 @@ func newGettyRPCClientConn(pool *gettyRPCClientPool, protocol, addr string) (*ge
}
time.Sleep(1e6)
}
- logger.Infof("client init ok")
+ logger.Debug("client init ok")
c.updateActive(time.Now().Unix())
return c, nil
diff --git a/registry/directory/directory.go b/registry/directory/directory.go
index 2de34bcbe..1c6d15534 100644
--- a/registry/directory/directory.go
+++ b/registry/directory/directory.go
@@ -214,13 +214,13 @@ func (dir *registryDirectory) cacheInvoker(url *common.URL) protocol.Invoker {
newUrl := common.MergeUrl(url, referenceUrl)
dir.overrideUrl(newUrl)
if cacheInvoker, ok := dir.cacheInvokersMap.Load(newUrl.Key()); !ok {
- logger.Infof("service will be added in cache invokers: invokers url is %s!", newUrl)
+ logger.Debugf("service will be added in cache invokers: invokers url is %s!", newUrl)
newInvoker := extension.GetProtocol(protocolwrapper.FILTER).Refer(*newUrl)
if newInvoker != nil {
dir.cacheInvokersMap.Store(newUrl.Key(), newInvoker)
}
} else {
- logger.Infof("service will be updated in cache invokers: new invoker url is %s, old invoker url is %s", newUrl, cacheInvoker.(protocol.Invoker).GetUrl())
+ logger.Debugf("service will be updated in cache invokers: new invoker url is %s, old invoker url is %s", newUrl, cacheInvoker.(protocol.Invoker).GetUrl())
newInvoker := extension.GetProtocol(protocolwrapper.FILTER).Refer(*newUrl)
if newInvoker != nil {
dir.cacheInvokersMap.Store(newUrl.Key(), newInvoker)
diff --git a/remoting/zookeeper/client.go b/remoting/zookeeper/client.go
index f95231b37..21486aab5 100644
--- a/remoting/zookeeper/client.go
+++ b/remoting/zookeeper/client.go
@@ -412,7 +412,7 @@ func (z *ZookeeperClient) Create(basePath string) error {
if err != nil {
if err == zk.ErrNodeExists {
- logger.Infof("zk.create(\"%s\") exists\n", tmpPath)
+ logger.Debugf("zk.create(\"%s\") exists\n", tmpPath)
} else {
logger.Errorf("zk.create(\"%s\") error(%v)\n", tmpPath, perrors.WithStack(err))
return perrors.WithMessagef(err, "zk.Create(path:%s)", basePath)
diff --git a/remoting/zookeeper/listener.go b/remoting/zookeeper/listener.go
index 0d1d4bd27..77aa05ee9 100644
--- a/remoting/zookeeper/listener.go
+++ b/remoting/zookeeper/listener.go
@@ -245,7 +245,7 @@ func (l *ZkEventListener) listenDirEvent(zkPath string, listener remoting.DataLi
if err != nil {
logger.Errorf("Get new node path {%v} 's content error,message is {%v}", dubboPath, perrors.WithStack(err))
}
- logger.Infof("Get children!{%s}", dubboPath)
+ logger.Debugf("Get children!{%s}", dubboPath)
if !listener.DataChange(remoting.Event{Path: dubboPath, Action: remoting.EventTypeAdd, Content: string(content)}) {
continue
}
--
GitLab