From 236dba0f6456e3c27d2e0b73898d267c963197f2 Mon Sep 17 00:00:00 2001
From: wangwx <wangwx@tuya.com>
Date: Tue, 16 Jun 2020 13:09:04 +0800
Subject: [PATCH] fmt file
---
remoting/zookeeper/client.go | 2 +-
remoting/zookeeper/listener.go | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/remoting/zookeeper/client.go b/remoting/zookeeper/client.go
index 95c8a011c..2a31cef7b 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 10fffe3d5..71d7948eb 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)
--
GitLab