#ignite-373: Revert removing only not obsolete entries in removeAll.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/cb09f7c9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/cb09f7c9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/cb09f7c9 Branch: refs/heads/ignite-373 Commit: cb09f7c9fe4c580cabc669073024355ce7d68bed Parents: 7624e44 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Tue May 12 12:04:40 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Tue May 12 12:04:40 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/distributed/GridDistributedCacheAdapter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb09f7c9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java index 8958637..b4417a0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java @@ -316,7 +316,7 @@ public abstract class GridDistributedCacheAdapter<K, V> extends GridCacheAdapter for (GridDhtLocalPartition locPart : dht.topology().currentLocalPartitions()) { if (!locPart.isEmpty() && locPart.primary(topVer)) { for (GridDhtCacheEntry o : locPart.entries()) { - //if (!o.obsoleteOrDeleted()) + if (!o.obsoleteOrDeleted()) dataLdr.removeDataInternal(o.key()); } }
