Repository: incubator-ignite Updated Branches: refs/heads/ignite-sql-tests b26fac930 -> 1c1178423
# ignite-57 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/dbea639e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/dbea639e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/dbea639e Branch: refs/heads/ignite-sql-tests Commit: dbea639e224e98a0ce57c57d5b9d6fb2fe31e9b4 Parents: 082bd57 Author: sboikov <sboi...@gridgain.com> Authored: Thu Feb 5 11:52:48 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Feb 5 11:52:48 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/cache/CacheProjection.java | 7 +++++++ .../internal/processors/cache/GridCacheAdapter.java | 13 +++++++++++++ .../internal/processors/cache/IgniteCacheProxy.java | 6 ++++-- 3 files changed, 24 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dbea639e/modules/core/src/main/java/org/apache/ignite/cache/CacheProjection.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheProjection.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheProjection.java index 2cf10aa..ee469f9 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheProjection.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheProjection.java @@ -1854,6 +1854,13 @@ public interface CacheProjection<K, V> extends Iterable<CacheEntry<K, V>> { public int size(); /** + * @param peekModes Peek modes. + * @return Local cache size. + * @throws IgniteCheckedException If failed. + */ + public int localSize(CachePeekMode... peekModes) throws IgniteCheckedException; + + /** * Gets the number of all entries cached across all nodes. * <p> * NOTE: this operation is distributed and will query all participating nodes for their cache sizes. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dbea639e/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java index 393a3fc..8933690 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java @@ -3868,6 +3868,19 @@ public abstract class GridCacheAdapter<K, V> implements GridCache<K, V>, } /** {@inheritDoc} */ + @Override public int localSize(CachePeekMode... peekModes) throws IgniteCheckedException { + boolean primary; + boolean backup; + boolean near; + + boolean heap; + boolean offheap; + boolean swap; + + return 0; + } + + /** {@inheritDoc} */ @Override public int size() { return map.publicSize(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dbea639e/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 43d231e..87a4f2d 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 @@ -323,11 +323,13 @@ public class IgniteCacheProxy<K, V> extends IgniteAsyncSupportAdapter<IgniteCach /** {@inheritDoc} */ @Override public int localSize(CachePeekMode... peekModes) { - // TODO IGNITE-1. GridCacheProjectionImpl<K, V> prev = gate.enter(prj); try { - return delegate.size(); + return delegate.localSize(peekModes); + } + catch (IgniteCheckedException e) { + throw cacheException(e); } finally { gate.leave(prev);
