msg format
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d7623b47 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d7623b47 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d7623b47 Branch: refs/heads/ignite-gg-9615 Commit: d7623b47abea23c685856b36ade75027efbb3cc5 Parents: 2173b0e Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Thu Aug 6 12:38:24 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Thu Aug 6 12:38:24 2015 +0300 ---------------------------------------------------------------------- .../ignite/spi/discovery/tcp/ClientImpl.java | 27 +++++++++++++++----- 1 file changed, 21 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d7623b47/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 0f9c100..d5d6ea2 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 @@ -29,6 +29,7 @@ import org.apache.ignite.lang.*; import org.apache.ignite.spi.*; import org.apache.ignite.spi.discovery.*; import org.apache.ignite.spi.discovery.tcp.internal.*; +import org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.*; import org.apache.ignite.spi.discovery.tcp.messages.*; import org.jetbrains.annotations.*; import org.jsr166.*; @@ -159,7 +160,9 @@ class ClientImpl extends TcpDiscoveryImpl { /** {@inheritDoc} */ @Override public void spiStart(@Nullable String gridName) throws IgniteSpiException { - spi.initLocalNode(0, true); + spi.initLocalNode( + 0, + true); locNode = spi.locNode; @@ -190,7 +193,10 @@ class ClientImpl extends TcpDiscoveryImpl { throw new IgniteSpiException("Thread has been interrupted.", e); } - timer.schedule(new HeartbeatSender(), spi.hbFreq, spi.hbFreq); + timer.schedule( + new HeartbeatSender(), + spi.hbFreq, + spi.hbFreq); spi.printStartInfo(); } @@ -408,7 +414,11 @@ class ClientImpl extends TcpDiscoveryImpl { if (timeout > 0 && (U.currentTimeMillis() - startTime) > timeout) return null; - LT.warn(log, null, "No addresses registered in the IP finder (will retry in 2000ms): " + LT.warn(log, null, "IP finder returned empty addresses list. " + + "Please check IP finder configuration" + + (spi.ipFinder instanceof TcpDiscoveryMulticastIpFinder ? + " and make sure multicast works on your network. " : ". ") + + "Will retry every 2 secs." + spi.ipFinder, true); Thread.sleep(2000); @@ -460,7 +470,7 @@ class ClientImpl extends TcpDiscoveryImpl { return null; LT.warn(log, null, "Failed to connect to any address from IP finder (will retry to join topology " + - "in 2000ms): " + toOrderedList(addrs0), true); + "every 2 secs): " + toOrderedList(addrs0), true); Thread.sleep(2000); } @@ -682,7 +692,9 @@ class ClientImpl extends TcpDiscoveryImpl { U.interrupt(msgWorker); U.join(sockWriter, log); - U.join(msgWorker, log); + U.join( + msgWorker, + log); } /** {@inheritDoc} */ @@ -987,7 +999,10 @@ class ClientImpl extends TcpDiscoveryImpl { } } - spi.writeToSocket(sock, msg, socketTimeout); + spi.writeToSocket( + sock, + msg, + socketTimeout); msg = null;
