ignite-2720 Need call 'initializeLocalAddresses' before starting client message worker.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c951fc06 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c951fc06 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c951fc06 Branch: refs/heads/ignite-2801 Commit: c951fc06be5fd731fe192456c6547fa116a64485 Parents: 9c9129f Author: sboikov <[email protected]> Authored: Fri Feb 26 15:49:37 2016 +0300 Committer: sboikov <[email protected]> Committed: Fri Feb 26 15:49:37 2016 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java | 6 +++--- .../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 2 +- .../tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java | 1 + 3 files changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/c951fc06/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java index 9b2bf46..65b94ca 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java @@ -242,12 +242,12 @@ class ClientImpl extends TcpDiscoveryImpl { sockReader = new SocketReader(); sockReader.start(); - msgWorker = new MessageWorker(); - msgWorker.start(); - if (spi.ipFinder.isShared()) registerLocalNodeAddress(); + msgWorker = new MessageWorker(); + msgWorker.start(); + try { joinLatch.await(); http://git-wip-us.apache.org/repos/asf/ignite/blob/c951fc06/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java index d9507b6..f0de546 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java @@ -313,7 +313,7 @@ class ServerImpl extends TcpDiscoveryImpl { else { if (F.isEmpty(spi.ipFinder.getRegisteredAddresses())) throw new IgniteSpiException("Non-shared IP finder must have IP addresses specified in " + - "GridTcpDiscoveryIpFinder.getRegisteredAddresses() configuration property " + + "TcpDiscoveryIpFinder.getRegisteredAddresses() configuration property " + "(specify list of IP addresses in configuration)."); ipFinderHasLocAddr = spi.ipFinderHasLocalAddress(); http://git-wip-us.apache.org/repos/asf/ignite/blob/c951fc06/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java index 8402cbf..8b29efd 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java @@ -136,6 +136,7 @@ public class TcpDiscoveryMulticastIpFinder extends TcpDiscoveryVmIpFinder { /** */ private boolean mcastErr; + /** */ @GridToStringExclude private Set<InetSocketAddress> locNodeAddrs;
