ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject ignite git commit: IGNITE-3477 - DEBUG failed connection
Date Thu, 06 Apr 2017 10:07:40 GMT
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 <alexey.goncharuk@gmail.com>
Authored: Thu Apr 6 13:07:47 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@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 +


Mime
View raw message