ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: #ignite-614: Remove code for test.
Date Thu, 14 May 2015 14:22:42 GMT
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 <ivasilinets@gridgain.com>
Authored: Thu May 14 17:20:31 2015 +0300
Committer: ivasilinets <ivasilinets@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);
+                }
             }
         }
 


Mime
View raw message