Commit 6b9b17ad authored by wangwx's avatar wangwx

remove logger form zk client

parent 1556cdf1
...@@ -29,10 +29,6 @@ import ( ...@@ -29,10 +29,6 @@ import (
perrors "github.com/pkg/errors" perrors "github.com/pkg/errors"
) )
import (
"github.com/apache/dubbo-go/common/logger"
)
var ( var (
errNilZkClientConn = perrors.New("zookeeper client{conn} is nil") errNilZkClientConn = perrors.New("zookeeper client{conn} is nil")
errNilChildren = perrors.Errorf("has none children") errNilChildren = perrors.Errorf("has none children")
...@@ -244,7 +240,6 @@ func (z *ZookeeperClient) RegisterEvent(zkPath string, event *chan struct{}) { ...@@ -244,7 +240,6 @@ func (z *ZookeeperClient) RegisterEvent(zkPath string, event *chan struct{}) {
a := z.eventRegistry[zkPath] a := z.eventRegistry[zkPath]
a = append(a, event) a = append(a, event)
z.eventRegistry[zkPath] = a z.eventRegistry[zkPath] = a
logger.Debugf("zkClient{%s} register event{path:%s, ptr:%p}", z.name, zkPath, event)
} }
// UnregisterEvent unregisters zookeeper events // UnregisterEvent unregisters zookeeper events
...@@ -262,11 +257,8 @@ func (z *ZookeeperClient) UnregisterEvent(zkPath string, event *chan struct{}) { ...@@ -262,11 +257,8 @@ func (z *ZookeeperClient) UnregisterEvent(zkPath string, event *chan struct{}) {
for i, e := range infoList { for i, e := range infoList {
if e == event { if e == event {
infoList = append(infoList[:i], infoList[i+1:]...) infoList = append(infoList[:i], infoList[i+1:]...)
logger.Infof("zkClient{%s} unregister event{path:%s, event:%p}", z.name, zkPath, event)
} }
} }
logger.Debugf("after zkClient{%s} unregister event{path:%s, event:%p}, array length %d",
z.name, zkPath, event, len(infoList))
if len(infoList) == 0 { if len(infoList) == 0 {
delete(z.eventRegistry, zkPath) delete(z.eventRegistry, zkPath)
} else { } else {
......
This source diff could not be displayed because it is too large. You can view the blob instead.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment