#ignite-gg-10526: fix consistentId.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/3dcf8916 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/3dcf8916 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/3dcf8916 Branch: refs/heads/ignite-1124 Commit: 3dcf89167d2c0a9b53baddf533653ad5bb8bd5a5 Parents: 9dcca80 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Fri Jul 10 10:42:17 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Fri Jul 10 10:42:17 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/internal/util/IgniteUtils.java | 6 +----- .../ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java | 8 ++++++-- 2 files changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3dcf8916/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java index 46a23d6..f457d6c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java @@ -8048,13 +8048,9 @@ public abstract class IgniteUtils { public static String consistentId(Collection<String> addrs, int port) { assert !F.isEmpty(addrs); - List<String> sortedAddrs = new ArrayList<>(addrs); - - Collections.sort(sortedAddrs); - StringBuilder sb = new StringBuilder(); - for (String addr : sortedAddrs) + for (String addr : addrs) sb.append(addr).append(','); sb.delete(sb.length() - 1, sb.length()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3dcf8916/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java index 4b4df45..22f56c3 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java @@ -143,13 +143,17 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Cluste assert ver != null; this.id = id; - this.addrs = addrs; + + List<String> sortedAddrs = new ArrayList<>(addrs); + Collections.sort(sortedAddrs); + + this.addrs = sortedAddrs; this.hostNames = hostNames; this.discPort = discPort; this.metricsProvider = metricsProvider; this.ver = ver; - consistentId = U.consistentId(addrs, discPort); + consistentId = U.consistentId(sortedAddrs, discPort); metrics = metricsProvider.metrics(); cacheMetrics = metricsProvider.cacheMetrics();
