ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [11/50] [abbrv] incubator-ignite git commit: # ignite-44
Date Mon, 19 Jan 2015 14:20:48 GMT
# ignite-44


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d60f91e4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d60f91e4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d60f91e4

Branch: refs/heads/ignite-54
Commit: d60f91e4baa3e54ed7777f39c6a884248241df17
Parents: 3eba2e1
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Dec 26 17:01:42 2014 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Dec 26 17:01:42 2014 +0300

----------------------------------------------------------------------
 .../internal/processors/cache/IgniteCacheProxy.java   | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d60f91e4/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
index d2bad0f0..892bbd8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
@@ -610,7 +610,19 @@ public class IgniteCacheProxy<K, V> extends IgniteAsyncSupportAdapter
implements
 
     /** {@inheritDoc} */
     @Override public void removeAll(Set<? extends K> keys) {
-        removeAll(keys);
+        try {
+            GridCacheProjectionImpl<K, V> prev = gate.enter(prj);
+
+            try {
+                delegate.removeAll(keys);
+            }
+            finally {
+                gate.leave(prev);
+            }
+        }
+        catch (IgniteCheckedException e) {
+            throw cacheException(e);
+        }
     }
 
     /**


Mime
View raw message