You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by go...@apache.org on 2020/05/14 04:22:55 UTC
[incubator-tubemq] branch master updated: [TUBEMQ-102] Fix question
[TUBEMQ-101] [Optimize code] (#80)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
The following commit(s) were added to refs/heads/master by this push:
new e217acd [TUBEMQ-102] Fix question [TUBEMQ-101] [Optimize code] (#80)
e217acd is described below
commit e217acdef7187dc607f14a22cee4db9d4306b2b8
Author: viviel <37...@users.noreply.github.com>
AuthorDate: Thu May 14 12:21:18 2020 +0800
[TUBEMQ-102] Fix question [TUBEMQ-101] [Optimize code] (#80)
---
.../src/main/java/org/apache/tubemq/corebase/cluster/MasterInfo.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/tubemq-core/src/main/java/org/apache/tubemq/corebase/cluster/MasterInfo.java b/tubemq-core/src/main/java/org/apache/tubemq/corebase/cluster/MasterInfo.java
index 06deba6..2387136 100644
--- a/tubemq-core/src/main/java/org/apache/tubemq/corebase/cluster/MasterInfo.java
+++ b/tubemq-core/src/main/java/org/apache/tubemq/corebase/cluster/MasterInfo.java
@@ -71,7 +71,9 @@ public class MasterInfo {
}
int port = Integer.parseInt(hostPortItem[1].trim());
NodeAddrInfo tmpNodeAddrInfo = new NodeAddrInfo(hostName, port);
- addrMap4Failover.putIfAbsent(tmpNodeAddrInfo.getHostPortStr(), tmpNodeAddrInfo);
+ if (addrMap4Failover.get(tmpNodeAddrInfo.getHostPortStr()) == null) {
+ addrMap4Failover.put(tmpNodeAddrInfo.getHostPortStr(), tmpNodeAddrInfo);
+ }
if (this.firstNodeAddr == null) {
this.firstNodeAddr = tmpNodeAddrInfo;
}