Repository: incubator-ignite Updated Branches: refs/heads/ignite-614 37e60c1a0 -> 95bbb443f
#ignite-614: Remove code for test. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/95bbb443 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/95bbb443 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/95bbb443 Branch: refs/heads/ignite-614 Commit: 95bbb443f5f2a24b27c5c1e7fde5f8bf0b4bd0c1 Parents: 37e60c1 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Thu May 14 17:20:31 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Thu May 14 17:20:31 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/GridCacheSwapManager.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/95bbb443/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java index c179b31..b489a68 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java @@ -801,6 +801,13 @@ public class GridCacheSwapManager extends GridCacheManagerAdapter { key.valueBytes(cctx.cacheObjectContext())); unprocessedKeys.add(swapKey); + + Collection<GridCacheSwapListener> lsnrs = swapLsnrs.get(cctx.affinity().partition(key)); + + if (lsnrs != null) { + for (GridCacheSwapListener lsnr : lsnrs) + lsnr.onEntryUnswapping(key); + } } }
