ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [07/46] ignite git commit: Fixed updateCounter when node is removed (backport of 4fedd0fe)
Date Fri, 07 Jul 2017 09:34:10 GMT
Fixed updateCounter when node is removed (backport of 4fedd0fe)


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

Branch: refs/heads/ignite-2.1
Commit: ace802990822fa9a68ddb9824a159dacedc05901
Parents: c475f27
Author: Ivan Rakov <ivan.glukos@gmail.com>
Authored: Tue Jul 4 17:45:37 2017 +0300
Committer: Ivan Rakov <ivan.glukos@gmail.com>
Committed: Tue Jul 4 17:45:37 2017 +0300

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


http://git-wip-us.apache.org/repos/asf/ignite/blob/ace80299/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 a6f1831..f24dd45 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
@@ -1934,12 +1934,11 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology
{
         ClusterNode loc = ctx.localNode();
 
         if (node2part != null) {
-            if (loc.equals(oldest) && !node2part.nodeId().equals(loc.id())) {
-                updateSeq.setIfGreater(node2part.updateSequence());
+            updateSeq.setIfGreater(node2part.updateSequence());
 
+            if (loc.equals(oldest) && !node2part.nodeId().equals(loc.id()))
                 node2part = new GridDhtPartitionFullMap(loc.id(), loc.order(), updateSeq.incrementAndGet(),
                     node2part, false);
-            }
             else
                 node2part = new GridDhtPartitionFullMap(node2part, node2part.updateSequence());
 


Mime
View raw message