You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/04/06 10:07:40 UTC
ignite git commit: IGNITE-3477 - DEBUG failed connection
Repository: ignite
Updated Branches:
refs/heads/ignite-3477-debug 3409bc295 -> eefebb241
IGNITE-3477 - DEBUG failed connection
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/eefebb24
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/eefebb24
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/eefebb24
Branch: refs/heads/ignite-3477-debug
Commit: eefebb2417204130086fc2592784fe9256787e5e
Parents: 3409bc2
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Thu Apr 6 13:07:47 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Thu Apr 6 13:07:47 2017 +0300
----------------------------------------------------------------------
.../spi/communication/tcp/TcpCommunicationSpi.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/eefebb24/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 d9a13bf..b62036d 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
@@ -3209,18 +3209,23 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements Communicati
assert errs != null;
if (X.hasCause(errs, ConnectException.class))
- LT.warn(log, "Failed to connect to a remote node " +
+ log.warning("Failed to connect to a remote node " +
"(make sure that destination node is alive and " +
"operating system firewall is disabled on local and remote hosts) " +
"[addrs=" + addrs + ']');
- if (getSpiContext().node(node.id()) != null && CU.clientNode(node)) {
- LT.warn(log, "TcpCommunicationSpi failed to establish connection to node, node will be dropped from " +
+ if (getSpiContext().node(node.id()) != null && (CU.clientNode(node) || !CU.clientNode(getLocalNode())) &&
+ X.hasCause(errs, ConnectException.class, SocketTimeoutException.class, HandshakeTimeoutException.class,
+ IgniteSpiOperationTimeoutException.class)) {
+
+ log.warning("TcpCommunicationSpi failed to establish connection to node, node will be dropped from " +
"cluster [" +
"rmtNode=" + node +
", err=" + errs +
", connectErrs=" + Arrays.toString(errs.getSuppressed()) + ']');
+ errs.printStackTrace();
+
getSpiContext().failNode(node.id(), "TcpCommunicationSpi failed to establish connection to node [" +
"rmtNode=" + node +
", errs=" + errs +