Repository: incubator-ignite Updated Branches: refs/heads/ignite-614 95bbb443f -> 04408696d
#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/04408696 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/04408696 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/04408696 Branch: refs/heads/ignite-614 Commit: 04408696d3eeaca1a113e4a71bb8085714c5d9e5 Parents: 95bbb44 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Thu May 14 17:27:04 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Thu May 14 17:27:04 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/GridCacheSwapManager.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04408696/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 b489a68..af79632 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 @@ -786,6 +786,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); + } } }
