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
Date Thu, 06 Apr 2017 14:00:55 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-3477-debug 42a2d707e -> 61d95f6d2


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/61d95f6d
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/61d95f6d
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/61d95f6d

Branch: refs/heads/ignite-3477-debug
Commit: 61d95f6d27416a4a03768d0f764633c63074212b
Parents: 42a2d70
Author: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Authored: Thu Apr 6 17:01:07 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Committed: Thu Apr 6 17:01:07 2017 +0300

----------------------------------------------------------------------
 .../internal/managers/discovery/GridDiscoveryManager.java      | 2 ++
 .../ignite/spi/communication/tcp/TcpCommunicationSpi.java      | 6 ++++++
 .../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java   | 3 +++
 3 files changed, 11 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/61d95f6d/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
index e5f2278..a3e7873 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
@@ -1948,6 +1948,8 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi>
{
             return;
 
         try {
+            U.dumpStack(log, "Failing node: " + nodeId + ", warn=" + warning);
+
             getSpi().failNode(nodeId, warning);
         }
         finally {

http://git-wip-us.apache.org/repos/asf/ignite/blob/61d95f6d/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 0cff479..73689ac 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
@@ -3229,6 +3229,12 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements
Communicati
                     ", err=" + errs +
                     ", connectErrs=" + Arrays.toString(errs.getSuppressed()) + ']');
 
+                System.err.println("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 [" +

http://git-wip-us.apache.org/repos/asf/ignite/blob/61d95f6d/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 b07a3f7..353b89e 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
@@ -4653,6 +4653,9 @@ class ServerImpl extends TcpDiscoveryImpl {
             }
 
             if (msg.verified()) {
+                if (locNode.id().equals(failedNodeId))
+                    U.debug(log, ">>>>>>> received self-kill message:
" + msg);
+
                 failedNode = ring.removeNode(failedNodeId);
 
                 interruptPing(failedNode);


Mime
View raw message