From 828dce733b52d4462a5a77102a0212e63ad1c4b3 Mon Sep 17 00:00:00 2001
From: amudong <xiaoxiong5288@gmail.com>
Date: Tue, 13 Aug 2019 20:47:12 +0800
Subject: [PATCH] Mod: translate Chinese comments to English
---
cluster/cluster_impl/base_cluster_invoker.go | 2 +-
config_center/zookeeper/impl.go | 2 +-
.../dubbo/with-configcenter-go-client/app/client.go | 4 ++--
.../dubbo/with-configcenter-go-client/app/user.go | 2 +-
.../dubbo/with-configcenter-go-server/app/server.go | 2 +-
.../dubbo/with-configcenter-go-server/app/user.go | 2 +-
.../jsonrpc/with-configcenter-go-client/app/client.go | 2 +-
.../jsonrpc/with-configcenter-go-server/app/server.go | 2 +-
examples/general/dubbo/go-client/app/client.go | 2 +-
examples/general/dubbo/go-client/app/user.go | 2 +-
examples/general/dubbo/go-server/app/server.go | 2 +-
examples/general/dubbo/go-server/app/user.go | 4 ++--
.../src/main/java/com/ikurento/user/Consumer.java | 6 +++---
.../java/com/ikurento/user/UserProviderAnotherImpl.java | 4 ++--
.../src/main/java/com/ikurento/user/UserProviderImpl.java | 4 ++--
examples/general/jsonrpc/go-client/app/client.go | 2 +-
examples/general/jsonrpc/go-server/app/server.go | 2 +-
.../src/main/java/com/ikurento/user/Consumer.java | 6 +++---
.../java/com/ikurento/user/UserProviderAnotherImpl.java | 4 ++--
.../src/main/java/com/ikurento/user/UserProviderImpl.java | 4 ++--
examples/helloworld/dubbo/go-server/app/server.go | 2 +-
.../src/main/java/com/ikurento/user/UserProviderImpl.java | 2 +-
registry/zookeeper/listener.go | 2 +-
registry/zookeeper/registry.go | 8 ++++----
remoting/zookeeper/facade.go | 4 ++--
25 files changed, 39 insertions(+), 39 deletions(-)
diff --git a/cluster/cluster_impl/base_cluster_invoker.go b/cluster/cluster_impl/base_cluster_invoker.go
index 2426258b9..d42a099bb 100644
--- a/cluster/cluster_impl/base_cluster_invoker.go
+++ b/cluster/cluster_impl/base_cluster_invoker.go
@@ -84,7 +84,7 @@ func (invoker *baseClusterInvoker) checkWhetherDestroyed() error {
}
func (invoker *baseClusterInvoker) doSelect(lb cluster.LoadBalance, invocation protocol.Invocation, invokers []protocol.Invoker, invoked []protocol.Invoker) protocol.Invoker {
- //todo:ticky connect 绮樼焊杩炴帴
+ //todo:sticky connect
if len(invokers) == 1 {
return invokers[0]
}
diff --git a/config_center/zookeeper/impl.go b/config_center/zookeeper/impl.go
index ef0761efc..f2827b2bb 100644
--- a/config_center/zookeeper/impl.go
+++ b/config_center/zookeeper/impl.go
@@ -196,7 +196,7 @@ func (r *zookeeperDynamicConfiguration) closeConfigs() {
r.cltLock.Lock()
defer r.cltLock.Unlock()
logger.Infof("begin to close provider zk client")
- // 鍏堝叧闂棫client锛屼互鍏抽棴tmp node
+ // Close the old client first to close the tmp node
r.client.Close()
r.client = nil
}
diff --git a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/client.go b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/client.go
index fb2e0ef7e..5da8506d5 100644
--- a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/client.go
+++ b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/client.go
@@ -27,7 +27,7 @@ import (
)
import (
- "github.com/apache/dubbo-go-hessian2"
+ hessian "github.com/apache/dubbo-go-hessian2"
)
import (
@@ -140,7 +140,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.//
fmt.Println("app exit now...")
return
}
diff --git a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/user.go b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/user.go
index 8140acaef..5bddf1e19 100644
--- a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/user.go
+++ b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/user.go
@@ -83,7 +83,7 @@ type User struct {
Name string
Age int32
Time time.Time
- Sex Gender // 娉ㄦ剰姝ゅ锛宩ava enum Object <--> go string
+ Sex Gender // notice: java enum Object <--> go string
}
func (u User) String() string {
diff --git a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/server.go b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/server.go
index 814978566..cd9829921 100644
--- a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/server.go
+++ b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/server.go
@@ -78,7 +78,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.
fmt.Println("provider app exit now...")
return
}
diff --git a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/user.go b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/user.go
index d0ac61e4c..0e4d05766 100644
--- a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/user.go
+++ b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/user.go
@@ -84,7 +84,7 @@ type (
Name string
Age int32
Time time.Time
- Sex Gender // 娉ㄦ剰姝ゅ锛宩ava enum Object <--> go string
+ Sex Gender // notice: java enum Object <--> go string
}
UserProvider struct {
diff --git a/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-client/app/client.go b/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-client/app/client.go
index 642b45a93..5b1634788 100644
--- a/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-client/app/client.go
+++ b/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-client/app/client.go
@@ -125,7 +125,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.
fmt.Println("app exit now...")
return
}
diff --git a/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-server/app/server.go b/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-server/app/server.go
index 851a97c15..0a0e72915 100644
--- a/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-server/app/server.go
+++ b/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-server/app/server.go
@@ -67,7 +67,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.
fmt.Println("provider app exit now...")
return
}
diff --git a/examples/general/dubbo/go-client/app/client.go b/examples/general/dubbo/go-client/app/client.go
index b7ee0e662..47f453c3a 100644
--- a/examples/general/dubbo/go-client/app/client.go
+++ b/examples/general/dubbo/go-client/app/client.go
@@ -86,7 +86,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.
fmt.Println("app exit now...")
return
}
diff --git a/examples/general/dubbo/go-client/app/user.go b/examples/general/dubbo/go-client/app/user.go
index affa5418a..104d325d0 100644
--- a/examples/general/dubbo/go-client/app/user.go
+++ b/examples/general/dubbo/go-client/app/user.go
@@ -89,7 +89,7 @@ type User struct {
Name string
Age int32
Time time.Time
- Sex Gender // 娉ㄦ剰姝ゅ锛宩ava enum Object <--> go string
+ Sex Gender // notice: java enum Object <--> go string
}
func (u User) String() string {
diff --git a/examples/general/dubbo/go-server/app/server.go b/examples/general/dubbo/go-server/app/server.go
index de9c28737..ac92b879b 100644
--- a/examples/general/dubbo/go-server/app/server.go
+++ b/examples/general/dubbo/go-server/app/server.go
@@ -79,7 +79,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.
fmt.Println("provider app exit now...")
return
}
diff --git a/examples/general/dubbo/go-server/app/user.go b/examples/general/dubbo/go-server/app/user.go
index ce53bca08..e07a02e77 100644
--- a/examples/general/dubbo/go-server/app/user.go
+++ b/examples/general/dubbo/go-server/app/user.go
@@ -24,7 +24,7 @@ import (
)
import (
- "github.com/apache/dubbo-go-hessian2"
+ hessian "github.com/apache/dubbo-go-hessian2"
)
type Gender hessian.JavaEnum
@@ -73,7 +73,7 @@ type (
Name string
Age int32
Time time.Time
- Sex Gender // 娉ㄦ剰姝ゅ锛宩ava enum Object <--> go string
+ Sex Gender // notice: java enum Object <--> go string
}
)
diff --git a/examples/general/dubbo/java-client/src/main/java/com/ikurento/user/Consumer.java b/examples/general/dubbo/java-client/src/main/java/com/ikurento/user/Consumer.java
index 9122a629f..5c9870eec 100644
--- a/examples/general/dubbo/java-client/src/main/java/com/ikurento/user/Consumer.java
+++ b/examples/general/dubbo/java-client/src/main/java/com/ikurento/user/Consumer.java
@@ -17,12 +17,12 @@ import com.alibaba.dubbo.rpc.service.EchoService;
import java.util.List;
public class Consumer {
- //瀹氫箟涓€涓鏈夊彉閲� 锛圫pring涓姹傦級
+ // Define a private variable (Required in Spring)
private UserProvider userProvider;
private UserProvider userProvider1;
private UserProvider userProvider2;
- //Spring娉ㄥ叆锛圫pring涓姹傦級
+ // Spring DI (Required in Spring)
public void setUserProvider(UserProvider u) {
this.userProvider = u;
}
@@ -33,7 +33,7 @@ public class Consumer {
this.userProvider2 = u;
}
- //鍚姩consumer鐨勫叆鍙ｅ嚱鏁�(鍦ㄩ厤缃枃浠朵腑鎸囧畾)
+ // Start the entry function for consumer (Specified in the configuration file)
public void start() throws Exception {
System.out.println("\n\ntest");
testGetUser();
diff --git a/examples/general/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderAnotherImpl.java b/examples/general/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderAnotherImpl.java
index d600545c5..04729fb7a 100644
--- a/examples/general/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderAnotherImpl.java
+++ b/examples/general/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderAnotherImpl.java
@@ -9,8 +9,8 @@ import org.slf4j.LoggerFactory;
import java.util.*;
public class UserProviderAnotherImpl implements UserProvider {
- // private static final Logger logger = LoggerFactory.getLogger(getClass()); // 鍙緭鍑哄埌dubbo鐨刲og(logs/server.log)
- private static final Logger logger = LoggerFactory.getLogger("userLogger"); // 杈撳嚭鍒皍ser-server.log
+ // private static final Logger logger = LoggerFactory.getLogger(getClass()); // Only output to dubbo's log(logs/server.log)
+ private static final Logger logger = LoggerFactory.getLogger("userLogger"); // Output to user-server.log
private Map<String, User> userMap = new HashMap<String, User>();
diff --git a/examples/general/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java b/examples/general/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
index 47a4e2d97..1efbf8237 100644
--- a/examples/general/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
+++ b/examples/general/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
@@ -14,8 +14,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class UserProviderImpl implements UserProvider {
- // private static final Logger logger = LoggerFactory.getLogger(getClass()); // 鍙緭鍑哄埌dubbo鐨刲og(logs/server.log)
- private static final Logger LOG = LoggerFactory.getLogger("UserLogger"); // 杈撳嚭鍒皍ser-server.log
+ // private static final Logger logger = LoggerFactory.getLogger(getClass()); // Only output to dubbo's log(logs/server.log)
+ private static final Logger LOG = LoggerFactory.getLogger("UserLogger"); // Output to user-server.log
Map<String, User> userMap = new HashMap<String, User>();
public UserProviderImpl() {
diff --git a/examples/general/jsonrpc/go-client/app/client.go b/examples/general/jsonrpc/go-client/app/client.go
index b781f860b..abbe586de 100644
--- a/examples/general/jsonrpc/go-client/app/client.go
+++ b/examples/general/jsonrpc/go-client/app/client.go
@@ -78,7 +78,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.
fmt.Println("app exit now...")
return
}
diff --git a/examples/general/jsonrpc/go-server/app/server.go b/examples/general/jsonrpc/go-server/app/server.go
index 231082b5b..e36b6efe9 100644
--- a/examples/general/jsonrpc/go-server/app/server.go
+++ b/examples/general/jsonrpc/go-server/app/server.go
@@ -69,7 +69,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.
fmt.Println("provider app exit now...")
return
}
diff --git a/examples/general/jsonrpc/java-client/src/main/java/com/ikurento/user/Consumer.java b/examples/general/jsonrpc/java-client/src/main/java/com/ikurento/user/Consumer.java
index 2c7b27b5e..1a38dbfba 100644
--- a/examples/general/jsonrpc/java-client/src/main/java/com/ikurento/user/Consumer.java
+++ b/examples/general/jsonrpc/java-client/src/main/java/com/ikurento/user/Consumer.java
@@ -17,12 +17,12 @@ import com.alibaba.dubbo.rpc.service.EchoService;
import java.util.List;
public class Consumer {
- //瀹氫箟涓€涓鏈夊彉閲� 锛圫pring涓姹傦級
+ // Define a private variable (Required in Spring)
private UserProvider userProvider;
private UserProvider userProvider1;
private UserProvider userProvider2;
- //Spring娉ㄥ叆锛圫pring涓姹傦級
+ // Spring DI (Required in Spring)
public void setUserProvider(UserProvider u) {
this.userProvider = u;
}
@@ -33,7 +33,7 @@ public class Consumer {
this.userProvider2 = u;
}
- //鍚姩consumer鐨勫叆鍙ｅ嚱鏁�(鍦ㄩ厤缃枃浠朵腑鎸囧畾)
+ // Start the entry function for consumer (Specified in the configuration file)
public void start() throws Exception {
System.out.println("\n\ntest");
testGetUser();
diff --git a/examples/general/jsonrpc/java-server/src/main/java/com/ikurento/user/UserProviderAnotherImpl.java b/examples/general/jsonrpc/java-server/src/main/java/com/ikurento/user/UserProviderAnotherImpl.java
index 753a6f89a..9e22b78b3 100644
--- a/examples/general/jsonrpc/java-server/src/main/java/com/ikurento/user/UserProviderAnotherImpl.java
+++ b/examples/general/jsonrpc/java-server/src/main/java/com/ikurento/user/UserProviderAnotherImpl.java
@@ -9,8 +9,8 @@ import org.slf4j.LoggerFactory;
import java.util.*;
public class UserProviderAnotherImpl implements UserProvider {
- // private static final Logger logger = LoggerFactory.getLogger(getClass()); // 鍙緭鍑哄埌dubbo鐨刲og(logs/server.log)
- private static final Logger logger = LoggerFactory.getLogger("userLogger"); // 杈撳嚭鍒皍ser-server.log
+ // private static final Logger logger = LoggerFactory.getLogger(getClass()); // Only output to dubbo's log(logs/server.log)
+ private static final Logger logger = LoggerFactory.getLogger("userLogger"); // Output to user-server.log
private Map<String, User> userMap = new HashMap<String, User>();
diff --git a/examples/general/jsonrpc/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java b/examples/general/jsonrpc/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
index 960c678cf..1ff8afa62 100644
--- a/examples/general/jsonrpc/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
+++ b/examples/general/jsonrpc/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
@@ -14,8 +14,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class UserProviderImpl implements UserProvider {
- // private static final Logger logger = LoggerFactory.getLogger(getClass()); // 鍙緭鍑哄埌dubbo鐨刲og(logs/server.log)
- private static final Logger LOG = LoggerFactory.getLogger("UserLogger"); // 杈撳嚭鍒皍ser-server.log
+ // private static final Logger logger = LoggerFactory.getLogger(getClass()); // Only output to dubbo's log(logs/server.log)
+ private static final Logger LOG = LoggerFactory.getLogger("UserLogger"); // Output to user-server.log
Map<String, User> userMap = new HashMap<String, User>();
public UserProviderImpl() {
diff --git a/examples/helloworld/dubbo/go-server/app/server.go b/examples/helloworld/dubbo/go-server/app/server.go
index 29f2ad57e..f02a6ba05 100644
--- a/examples/helloworld/dubbo/go-server/app/server.go
+++ b/examples/helloworld/dubbo/go-server/app/server.go
@@ -69,7 +69,7 @@ func initSignal() {
os.Exit(1)
})
- // 瑕佷箞fastFailTimeout鏃堕棿鍐呮墽琛屽畬姣曚笅闈㈢殑閫昏緫鐒跺悗绋嬪簭閫€鍑猴紝瑕佷箞鎵ц涓婇潰鐨勮秴鏃跺嚱鏁扮▼搴忓己琛岄€€鍑�
+ // The program exits normally or timeout forcibly exits.
fmt.Println("provider app exit now...")
return
}
diff --git a/examples/helloworld/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java b/examples/helloworld/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
index ddbccab37..d57ae54e3 100644
--- a/examples/helloworld/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
+++ b/examples/helloworld/dubbo/java-server/src/main/java/com/ikurento/user/UserProviderImpl.java
@@ -6,7 +6,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class UserProviderImpl implements UserProvider {
- private static final Logger LOG = LoggerFactory.getLogger("UserLogger"); // 杈撳嚭鍒皍ser-server.log
+ private static final Logger LOG = LoggerFactory.getLogger("UserLogger"); // Output to user埌user-server.log
public User GetUser(String userId) {
return new User(userId, "zhangsan", 18);
diff --git a/registry/zookeeper/listener.go b/registry/zookeeper/listener.go
index 67f203706..19f25693c 100644
--- a/registry/zookeeper/listener.go
+++ b/registry/zookeeper/listener.go
@@ -45,7 +45,7 @@ func (l *RegistryDataListener) AddInterestedURL(url *common.URL) {
}
func (l *RegistryDataListener) DataChange(eventType remoting.Event) bool {
- //鎴彇鏈€鍚庝竴浣�
+ // Intercept the last bit
url := eventType.Path[strings.Index(eventType.Path, "/providers/")+len("/providers/"):]
serviceURL, err := common.NewURL(context.TODO(), url)
if err != nil {
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
index c272c5bba..9ce3ee580 100644
--- a/registry/zookeeper/registry.go
+++ b/registry/zookeeper/registry.go
@@ -230,7 +230,7 @@ func (r *zkRegistry) Register(conf common.URL) error {
case common.PROVIDER:
- // 妫€楠屾湇鍔℃槸鍚﹀凡缁忔敞鍐岃繃
+ // Check if the service has been registered
r.cltLock.Lock()
// 娉ㄦ剰姝ゅ涓巆onsumerZookeeperRegistry鐨勫樊寮傦紝consumer鐢ㄧ殑鏄痗onf.Path锛�
// 鍥犱负consumer瑕佹彁渚泈atch鍔熻兘缁檚elector浣跨敤, provider鍏佽娉ㄥ唽鍚屼竴涓猻ervice鐨勫涓猤roup or version
@@ -320,7 +320,7 @@ func (r *zkRegistry) register(c common.URL) error {
rawURL = fmt.Sprintf("%s://%s%s?%s", c.Protocol, host, c.Path, params.Encode())
encodedURL = url.QueryEscape(rawURL)
- // 鎶婅嚜宸辨敞鍐宻ervice providers
+ // Print your own registration service providers.
dubboPath = fmt.Sprintf("/dubbo/%s/%s", c.Service(), (common.RoleType(common.PROVIDER)).String())
logger.Debugf("provider path:%s, url:%s", dubboPath, rawURL)
@@ -416,7 +416,7 @@ func (r *zkRegistry) getListener(conf common.URL) (*RegistryConfigurationListene
r.listenerLock.Unlock()
}
- //娉ㄥ唽鍒癲ataconfig鐨刬nterested
+ //Interested register to dataconfig.
r.dataListener.AddInterestedURL(&conf)
go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/providers", conf.Service()), r.dataListener)
@@ -428,7 +428,7 @@ func (r *zkRegistry) closeRegisters() {
r.cltLock.Lock()
defer r.cltLock.Unlock()
logger.Infof("begin to close provider zk client")
- // 鍏堝叧闂棫client锛屼互鍏抽棴tmp node
+ // Close the old client first to close the tmp node.
r.client.Close()
r.client = nil
r.services = nil
diff --git a/remoting/zookeeper/facade.go b/remoting/zookeeper/facade.go
index 4eace5e9d..cdc7ead61 100644
--- a/remoting/zookeeper/facade.go
+++ b/remoting/zookeeper/facade.go
@@ -63,14 +63,14 @@ LOOP:
r.SetZkClient(nil)
r.ZkClientLock().Unlock()
- // 鎺k锛岀洿鑷虫垚鍔�
+ // Connect zk until success.
failTimes = 0
for {
select {
case <-r.GetDone():
logger.Warnf("(ZkProviderRegistry)reconnectZkRegistry goroutine exit now...")
break LOOP
- case <-getty.GetTimeWheel().After(timeSecondDuration(failTimes * ConnDelay)): // 闃叉鐤媯閲嶈繛zk
+ case <-getty.GetTimeWheel().After(timeSecondDuration(failTimes * ConnDelay)): // Prevent crazy reconnection zk.
}
err = ValidateZookeeperClient(r, WithZkName(zkName))
logger.Infof("ZkProviderRegistry.validateZookeeperClient(zkAddr{%s}) = error{%#v}",
--
GitLab