Repository: ignite Updated Branches: refs/heads/ignite-1093-3 9521c6815 -> fb90f3999
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fb90f399 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fb90f399 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fb90f399 Branch: refs/heads/ignite-1093-3 Commit: fb90f39998622fc3d376ab1611d93d2d3dcc3371 Parents: 9521c68 Author: Anton Vinogradov <[email protected]> Authored: Thu Nov 5 12:47:30 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Thu Nov 5 12:47:30 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtLocalPartition.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/fb90f399/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 46f4f14..1516ee4 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 @@ -284,7 +284,7 @@ public class GridDhtLocalPartition implements Comparable<GridDhtLocalPartition>, } // Attempt to evict. - cctx.preloader().evictPartitionAsync(this); + tryEvict(); } /** @@ -409,7 +409,7 @@ public class GridDhtLocalPartition implements Comparable<GridDhtLocalPartition>, // Decrement reservations. if (state.compareAndSet(s, s, reservations, --reservations)) { - cctx.preloader().evictPartitionAsync(this); + tryEvict(); break; } @@ -579,7 +579,7 @@ public class GridDhtLocalPartition implements Comparable<GridDhtLocalPartition>, * */ void onUnlock() { - cctx.preloader().evictPartitionAsync(this); + tryEvict(); } /**
