Repository: ignite Updated Branches: refs/heads/ignite-3477-debug 460e744dd -> 42a2d707e
IGNITE-3477 - DEBUG Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/42a2d707 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/42a2d707 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/42a2d707 Branch: refs/heads/ignite-3477-debug Commit: 42a2d707e98d2e04a971af0da3bd188c30675f9b Parents: 460e744 Author: Alexey Goncharuk <alexey.goncha...@gmail.com> Authored: Thu Apr 6 16:52:59 2017 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Thu Apr 6 16:52:59 2017 +0300 ---------------------------------------------------------------------- .../ignite/spi/communication/tcp/TcpCommunicationSpi.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/42a2d707/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java index b62036d..0cff479 100755 --- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java @@ -3171,6 +3171,8 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements Communicati if (log.isDebugEnabled()) log.debug("Client creation failed [addr=" + addr + ", err=" + e + ']'); + U.debug(log, "Client creation failed [addr=" + addr + ", err=" + e + ']'); + boolean failureDetThrReached = timeoutHelper.checkFailureTimeoutReached(e); if (failureDetThrReached) @@ -3196,6 +3198,9 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements Communicati continue; } + else { + U.debug(log, "Will not reconnect: " + e); + } break; }
