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/07/04 08:19:33 UTC
[10/28] ignite git commit: ignite-2.1.2 detectLostPartitions minor
optimization
ignite-2.1.2 detectLostPartitions minor optimization
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5699be75
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5699be75
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5699be75
Branch: refs/heads/ignite-2.1.2-exchange
Commit: 5699be758110d007c2cae3da2edf83245c01907f
Parents: db8112f
Author: sboikov <sb...@gridgain.com>
Authored: Fri Jun 30 09:21:41 2017 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Fri Jun 30 09:21:41 2017 +0300
----------------------------------------------------------------------
.../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5699be75/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..1eab708 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
@@ -1556,8 +1556,12 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology {
for (GridDhtPartitionMap partMap : node2part.values()) {
for (Map.Entry<Integer, GridDhtPartitionState> e : partMap.entrySet()) {
- if (e.getValue() == OWNING)
+ if (e.getValue() == OWNING) {
lost.remove(e.getKey());
+
+ if (lost.isEmpty())
+ break;
+ }
}
}