ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-1758 Discovery fixes.
Date Tue, 17 Nov 2015 06:34:38 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1758-debug 91ae91cbf -> dc263f6ef


ignite-1758 Discovery fixes.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/dc263f6e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/dc263f6e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/dc263f6e

Branch: refs/heads/ignite-1758-debug
Commit: dc263f6ef286d889c97ee69d850e307399db52be
Parents: 91ae91c
Author: sboikov <sboikov@gridgain.com>
Authored: Tue Nov 17 09:34:29 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Tue Nov 17 09:34:29 2015 +0300

----------------------------------------------------------------------
 .../apache/ignite/spi/discovery/tcp/ServerImpl.java    | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/dc263f6e/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 92d616a..ae23d0e 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
@@ -1790,9 +1790,14 @@ class ServerImpl extends TcpDiscoveryImpl {
 
                 if (failedNode != null) {
                     if (!failedNode.isLocal()) {
+                        boolean added;
+
                         synchronized (mux) {
-                            failedNodes.add(failedNode);
+                            added = failedNodes.add(failedNode);
                         }
+
+                        if (added && log.isDebugEnabled())
+                            log.debug("Added node to failed nodes list [node=" + failedNode
+ ", msg=" + msg + ']');
                     }
                 }
             }
@@ -4593,8 +4598,12 @@ class ServerImpl extends TcpDiscoveryImpl {
             }
 
             if (msgs != null) {
-                for (TcpDiscoveryNodeFailedMessage msg : msgs)
+                for (TcpDiscoveryNodeFailedMessage msg : msgs) {
+                    if (log.isDebugEnabled())
+                        log.debug("Add node failed message for node from failed nodes list:
" + msg);
+
                     addMessage(msg);
+                }
             }
         }
 


Mime
View raw message