diff --git a/remoting/zookeeper/client.go b/remoting/zookeeper/client.go index 008848ea61ba2deb1a70aba5c29da097c3c48da9..a7fc568f567d720448d0be63c592fae5f8df9bbf 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 46edd49bf7cd22011bd7dfc8b89227257c5ad2ab..58e0d69dcfd9bf645c147f6e920e56ed5f3951eb 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 26a34bb74b8b0687f3bc8dd1179549799730beb6..7e0140e6ed73107a8c35e641ca56ec2f9d7783e7 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()