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 11:48:57 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1924 639723ffd -> 5933d876a


Ignite 1924


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

Branch: refs/heads/ignite-1924
Commit: 5933d876afbce9bb5eb102e82bb064ca886e5e79
Parents: 639723f
Author: Anton Vinogradov <av@apache.org>
Authored: Tue Nov 24 14:48:44 2015 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Tue Nov 24 14:48:44 2015 +0300

----------------------------------------------------------------------
 .../distributed/dht/preloader/GridDhtPartitionDemander.java     | 2 ++
 .../distributed/dht/preloader/GridDhtPartitionSupplier.java     | 5 +++--
 2 files changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/5933d876/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 5fca3f2..31b6113 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
@@ -509,6 +509,8 @@ public class GridDhtPartitionDemander {
 
         ClusterNode node = cctx.node(id);
 
+        U.log(log, "D>> "+cctx.name() + " "+supply.last().toString());
+
         if (node == null)
             return;
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/5933d876/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
index 778c184..4819716 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
@@ -614,6 +614,8 @@ class GridDhtPartitionSupplier {
 
             cctx.io().sendOrderedMessage(n, d.topic(), s, cctx.ioPolicy(), d.timeout());
 
+            U.log(log, "S>> "+cctx.name() + " "+s.last().toString());
+
             // Throttle preloading.
             if (cctx.config().getRebalanceThrottle() > 0)
                 U.sleep(cctx.config().getRebalanceThrottle());
@@ -621,8 +623,7 @@ class GridDhtPartitionSupplier {
             return true;
         }
         catch (ClusterTopologyCheckedException ignore) {
-            if (log.isDebugEnabled())
-                log.debug("Failed to send partition supply message because node left grid:
" + n.id());
+            U.log(log,"Failed to send partition supply message because node left grid: "
+ n.id());
 
             synchronized (scMap) {
                 clearContext(scMap.remove(scId), log);


Mime
View raw message