You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2017/07/07 09:34:10 UTC
[07/46] ignite git commit: Fixed updateCounter when node is removed
(backport of 4fedd0fe)
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 <iv...@gmail.com>
Authored: Tue Jul 4 17:45:37 2017 +0300
Committer: Ivan Rakov <iv...@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());