You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/05/14 16:22:42 UTC
incubator-ignite git commit: #ignite-614: Remove code for test.
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 <iv...@gridgain.com>
Authored: Thu May 14 17:20:31 2015 +0300
Committer: ivasilinets <iv...@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);
+ }
}
}