ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: 1093
Date Fri, 16 Oct 2015 17:15:59 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1093-2 57064970f -> 80ec3457c


1093


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

Branch: refs/heads/ignite-1093-2
Commit: 80ec3457c27c9b27bb34356b6fefe1531400e06b
Parents: 5706497
Author: Anton Vinogradov <avinogradov@gridgain.com>
Authored: Fri Oct 16 20:15:41 2015 +0300
Committer: Anton Vinogradov <avinogradov@gridgain.com>
Committed: Fri Oct 16 20:15:41 2015 +0300

----------------------------------------------------------------------
 .../distributed/dht/preloader/GridDhtPartitionSupplier.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/80ec3457/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 00d1b9c..c7f1909 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
@@ -197,12 +197,14 @@ class GridDhtPartitionSupplier {
                 try {
                     cctx.io().sendOrderedMessage(cctx.localNode(), GridCachePartitionExchangeManager.rebalanceTopic(idx),
                         d, cctx.ioPolicy(), cctx.config().getRebalanceTimeout());
+
+                    log.info("Demand request resended [current=" + cctx.affinity().affinityTopologyVersion()
+ ", demanded=" + d.topologyVersion() + "]");
                 }
                 catch (IgniteCheckedException e) {
                     U.error(log, "Failed to resend partition supply message to local node:
" + cctx.localNode().id());
                 }
             else if (log.isDebugEnabled())
-                log.debug("Demand request cancelled [current=" + cctx.affinity().affinityTopologyVersion()
+ ", demanded=" + d.topologyVersion() + "]");
+                log.info("Demand request cancelled [current=" + cctx.affinity().affinityTopologyVersion()
+ ", demanded=" + d.topologyVersion() + "]");
 
             return;
         }


Mime
View raw message