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 1924
Date Tue, 24 Nov 2015 13:24:08 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1924 e1f14d14c -> 27e1ae277


Ignite 1924


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

Branch: refs/heads/ignite-1924
Commit: 27e1ae277a46e359676cad83abad21f4253fe6c2
Parents: e1f14d1
Author: Anton Vinogradov <av@apache.org>
Authored: Tue Nov 24 16:23:58 2015 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Tue Nov 24 16:23:58 2015 +0300

----------------------------------------------------------------------
 .../cache/distributed/dht/preloader/GridDhtPartitionDemander.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/27e1ae27/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
index 31b6113..9d0879b 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
@@ -418,6 +418,9 @@ public class GridDhtPartitionDemander {
                                 // New requests will not be covered by failovers.
                                 cctx.io().sendOrderedMessage(node,
                                     rebalanceTopics.get(cnt), initD, cctx.ioPolicy(), initD.timeout());
+
+                            U.log(log, "D1>> " + cctx.name() + " " + initD.partitions().toString()
+ node.id() + " " + fut.isDone());
+
                         }
 
                         if (log.isDebugEnabled())


Mime
View raw message