ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [08/19] ignite git commit: IGNITE-6793 More debug output
Date Wed, 01 Nov 2017 09:55:38 GMT
IGNITE-6793 More debug output


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

Branch: refs/heads/ignite-6778
Commit: 0134f2b4447c97c0bf3ddb4fac3b423248030eec
Parents: 58dbbc5
Author: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Authored: Mon Oct 30 18:18:53 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Committed: Mon Oct 30 18:19:36 2017 +0300

----------------------------------------------------------------------
 .../dht/preloader/InitNewCoordinatorFuture.java          | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/0134f2b4/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
index b5acd4b..596fa8c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/InitNewCoordinatorFuture.java
@@ -38,6 +38,7 @@ import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
 import org.apache.ignite.internal.util.future.GridCompoundFuture;
 import org.apache.ignite.internal.util.future.GridFutureAdapter;
 import org.apache.ignite.internal.util.typedef.F;
+import org.apache.ignite.internal.util.typedef.internal.U;
 import org.jetbrains.annotations.Nullable;
 
 import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
@@ -113,6 +114,10 @@ public class InitNewCoordinatorFuture extends GridCompoundFuture {
 
                         nodes.add(node);
                     }
+                    else if (!node.isLocal()) {
+                        if (log.isInfoEnabled())
+                            log.info("Init new coordinator future will skip remote node:
" + node);
+                    }
                 }
 
                 if (exchFut.context().mergeExchanges() && !curDiscoCache.version().equals(discoCache.version()))
{
@@ -148,8 +153,10 @@ public class InitNewCoordinatorFuture extends GridCompoundFuture {
             }
 
             if (log.isInfoEnabled()) {
-                log.info("Try restore exchange result [allNodes=" + awaited +
-                    ", joined=" + joinedNodes.keySet() +  ']');
+                log.info("Try restore exchange result [awaited=" + awaited +
+                    ", joined=" + joinedNodes.keySet() +
+                    ", nodes=" + U.nodeIds(nodes) +
+                    ", discoAllNodes=" + U.nodeIds(discoCache.allNodes()) + ']');
             }
 
             if (!nodes.isEmpty()) {


Mime
View raw message