You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/03/17 08:24:22 UTC
ignite git commit: Fixed assert.
Repository: ignite
Updated Branches:
refs/heads/ignite-2.0 decb0c7aa -> 9020d12fc
Fixed assert.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9020d12f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9020d12f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9020d12f
Branch: refs/heads/ignite-2.0
Commit: 9020d12fc9dbcf39db545b0c8abfc50a324fbd77
Parents: decb0c7
Author: sboikov <sb...@gridgain.com>
Authored: Fri Mar 17 11:24:15 2017 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Fri Mar 17 11:24:15 2017 +0300
----------------------------------------------------------------------
.../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/9020d12f/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 53257d3..c476886 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
@@ -1434,12 +1434,12 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology {
ClusterNode oldest = discoCache.oldestAliveServerNode();
- assert oldest != null;
+ assert oldest != null || cctx.kernalContext().clientNode();
ClusterNode loc = cctx.localNode();
if (node2part != null) {
- if (oldest.equals(loc) && !node2part.nodeId().equals(loc.id())) {
+ if (loc.equals(oldest) && !node2part.nodeId().equals(loc.id())) {
updateSeq.setIfGreater(node2part.updateSequence());
node2part = new GridDhtPartitionFullMap(loc.id(), loc.order(), updateSeq.incrementAndGet(),