diff --git a/remoting/zookeeper/client.go b/remoting/zookeeper/client.go index 95c8a011c6aecf577b52e5a2a5901142223fe952..2a31cef7bdeb6513dc7c9cfc991f6a74d37e4dae 100644 --- a/remoting/zookeeper/client.go +++ b/remoting/zookeeper/client.go @@ -51,7 +51,7 @@ var ( type ZookeeperClient struct { name string ZkAddrs []string - sync.RWMutex // for conn + sync.RWMutex // for conn Conn *zk.Conn Timeout time.Duration exit chan struct{} diff --git a/remoting/zookeeper/listener.go b/remoting/zookeeper/listener.go index 10fffe3d580a5a5f257cd266ed7ad0ba05205545..71d7948eb044e3e97803c3f8d3b3a261fd803510 100644 --- a/remoting/zookeeper/listener.go +++ b/remoting/zookeeper/listener.go @@ -241,7 +241,7 @@ func (l *ZkEventListener) listenDirEvent(zkPath string, listener remoting.DataLi l.pathMapLock.Unlock() //When Zk disconnected, the Conn will be set to nil, so here need check the value of Conn l.client.RLock() - if l.client.Conn == nil{ + if l.client.Conn == nil { break } content, _, err := l.client.Conn.Get(dubboPath)