Repository: ignite Updated Branches: refs/heads/ignite-1093-2 524539ebe -> 427ea5169
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/427ea516 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/427ea516 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/427ea516 Branch: refs/heads/ignite-1093-2 Commit: 427ea51694960d63fa5c715dd6b5cd5b9f7a4c65 Parents: 524539e Author: Anton Vinogradov <[email protected]> Authored: Fri Oct 9 20:42:58 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Fri Oct 9 20:42:58 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtLocalPartition.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/427ea516/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java index eb2cee2..0eccad8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java @@ -546,7 +546,13 @@ public class GridDhtLocalPartition implements Comparable<GridDhtLocalPartition>, } while (!map.isEmpty()) { - clearAll(0); + cctx.closures().callLocalSafe(new GPC<Boolean>() { + @Override public Boolean call() { + return tryEvict(true); + } + }, /*system pool*/ true); + + return false; } if (map.isEmpty() && state.compareAndSet(EVICTING, EVICTED, 0, 0)) {
