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 2014/12/26 15:01:53 UTC
incubator-ignite git commit: # ignite-44
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-44 3eba2e1db -> d60f91e4b
# 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-44
Commit: d60f91e4baa3e54ed7777f39c6a884248241df17
Parents: 3eba2e1
Author: sboikov <sb...@gridgain.com>
Authored: Fri Dec 26 17:01:42 2014 +0300
Committer: sboikov <sb...@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 d2bad0f..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);
+ }
}
/**