From 99bafc63f87e0d648e9e949bafc26f4f6eb71a36 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=AB=98=E8=BE=9B=E6=A0=BC?= <xg.gao@tianrang-inc.com>
Date: Tue, 20 Aug 2019 15:04:19 +0800
Subject: [PATCH] typo
---
remoting/zookeeper/client.go | 6 +++---
remoting/zookeeper/facade_test.go | 2 +-
remoting/zookeeper/listener.go | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/remoting/zookeeper/client.go b/remoting/zookeeper/client.go
index 008848ea6..a7fc568f5 100644
--- a/remoting/zookeeper/client.go
+++ b/remoting/zookeeper/client.go
@@ -65,7 +65,7 @@ func StateToString(state zk.State) string {
case zk.StateConnectedReadOnly:
return "zookeeper connect readonly"
case zk.StateSaslAuthenticated:
- return "zookeeper sasl authenticaed"
+ return "zookeeper sasl authenticated"
case zk.StateExpired:
return "zookeeper connection expired"
case zk.StateConnected:
@@ -118,7 +118,7 @@ func ValidateZookeeperClient(container zkClientFacade, opts ...Option) error {
defer lock.Unlock()
if container.ZkClient() == nil {
- //in dubbp ,every registry only connect one node ,so this is []string{r.Address}
+ //in dubbo ,every registry only connect one node ,so this is []string{r.Address}
timeout, err := time.ParseDuration(url.GetParam(constant.REGISTRY_TIMEOUT_KEY, constant.DEFAULT_REG_TIMEOUT))
if err != nil {
logger.Errorf("timeout config %v is invalid ,err is %v",
@@ -128,7 +128,7 @@ func ValidateZookeeperClient(container zkClientFacade, opts ...Option) error {
zkAddresses := strings.Split(url.Location, ",")
newClient, err := newZookeeperClient(opions.zkName, zkAddresses, timeout)
if err != nil {
- logger.Warnf("newZookeeperClient(name{%s}, zk addresss{%v}, timeout{%d}) = error{%v}",
+ logger.Warnf("newZookeeperClient(name{%s}, zk address{%v}, timeout{%d}) = error{%v}",
opions.zkName, url.Location, timeout.String(), err)
return perrors.WithMessagef(err, "newZookeeperClient(address:%+v)", url.Location)
}
diff --git a/remoting/zookeeper/facade_test.go b/remoting/zookeeper/facade_test.go
index 46edd49bf..58e0d69dc 100644
--- a/remoting/zookeeper/facade_test.go
+++ b/remoting/zookeeper/facade_test.go
@@ -75,7 +75,7 @@ func (r *mockFacade) IsAvailable() bool {
return true
}
-func Test_Fascade(t *testing.T) {
+func Test_Facade(t *testing.T) {
ts, z, event, err := NewMockZookeeperClient("test", 15*time.Second)
assert.NoError(t, err)
defer ts.Stop()
diff --git a/remoting/zookeeper/listener.go b/remoting/zookeeper/listener.go
index 26a34bb74..7e0140e6e 100644
--- a/remoting/zookeeper/listener.go
+++ b/remoting/zookeeper/listener.go
@@ -208,7 +208,7 @@ func (l *ZkEventListener) listenDirEvent(zkPath string, listener remoting.DataLi
// listen l service node
dubboPath := path.Join(zkPath, c)
- //Save the path to avoid listen repeatly
+ //Save the path to avoid listen repeatedly
l.pathMapLock.Lock()
_, ok := l.pathMap[dubboPath]
l.pathMapLock.Unlock()
--
GitLab