Repository: incubator-ignite Updated Branches: refs/heads/ignite-96-tests fd63cfde0 -> aae71de5f
# IGNITE-56 Added isLocked() isThreadLocked() methods temporary. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/aae71de5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/aae71de5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/aae71de5 Branch: refs/heads/ignite-96-tests Commit: aae71de5fdb59d0ec4248c639f26212983de2e50 Parents: fd63cfd Author: sevdokimov <sevdoki...@gridgain.com> Authored: Tue Feb 10 12:36:10 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Tue Feb 10 12:36:10 2015 +0300 ---------------------------------------------------------------------- .../core/src/main/java/org/apache/ignite/IgniteCache.java | 2 ++ .../ignite/internal/processors/cache/IgniteCacheProxy.java | 8 ++++++++ 2 files changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/aae71de5/modules/core/src/main/java/org/apache/ignite/IgniteCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCache.java b/modules/core/src/main/java/org/apache/ignite/IgniteCache.java index 8d87d5d..ebe4757 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteCache.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteCache.java @@ -64,6 +64,8 @@ public interface IgniteCache<K, V> extends javax.cache.Cache<K, V>, IgniteAsyncS public void evict(K key); public void promote(K key); CacheConfiguration configuration(); + boolean isLocked(K key); + boolean isLockedByThread(K key); //public void clear(K key); /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/aae71de5/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 de3f01c..d9006b2 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 @@ -1083,4 +1083,12 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V @Override public CacheConfiguration configuration() { return getConfiguration(CacheConfiguration.class); } + + @Override public boolean isLocked(K key) { + return isLocalLocked(key, false); + } + + @Override public boolean isLockedByThread(K key) { + return isLocalLocked(key, true); + } }
