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-2622 Do not keep custom messages data after message is processed
Date Fri, 12 Feb 2016 08:11:44 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-2586 02b2baaee -> 3b21802df


ignite-2622 Do not keep custom messages data after message is processed


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

Branch: refs/heads/ignite-2586
Commit: 3b21802dfde8806a93e9c20e4e3ec390ea7b2e47
Parents: 02b2baa
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Feb 12 11:11:34 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Feb 12 11:11:34 2016 +0300

----------------------------------------------------------------------
 .../cache/distributed/dht/GridDhtPartitionTopologyImpl.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/3b21802d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
index 6349df3..bf2d2c6 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
@@ -1367,6 +1367,9 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology
{
      */
     private void updateRebalanceVersion() {
         if (!rebalancedTopVer.equals(topVer)) {
+            if (node2part == null || !node2part.valid())
+                return;
+
             for (int i = 0; i < cctx.affinity().partitions(); i++) {
                 List<ClusterNode> affNodes = cctx.affinity().nodes(i, topVer);
 
@@ -1374,9 +1377,6 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology
{
                 if (affNodes.isEmpty())
                     continue;
 
-                if (node2part == null || !node2part.valid())
-                    return;
-
                 List<ClusterNode> owners = owners(i);
 
                 if (affNodes.size() != owners.size() || !owners.containsAll(affNodes))


Mime
View raw message