Repository: ignite Updated Branches: refs/heads/ignite-5075-pds 9275ad878 -> 0bbe5c593
ignite-5075 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0bbe5c59 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0bbe5c59 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0bbe5c59 Branch: refs/heads/ignite-5075-pds Commit: 0bbe5c59378a677830500cc90cd72bd179888673 Parents: 9275ad8 Author: sboikov <[email protected]> Authored: Mon May 22 19:52:35 2017 +0300 Committer: sboikov <[email protected]> Committed: Mon May 22 19:52:35 2017 +0300 ---------------------------------------------------------------------- .../cache/database/GridCacheOffheapManager.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0bbe5c59/modules/pds/src/main/java/org/apache/ignite/internal/processors/cache/database/GridCacheOffheapManager.java ---------------------------------------------------------------------- diff --git a/modules/pds/src/main/java/org/apache/ignite/internal/processors/cache/database/GridCacheOffheapManager.java b/modules/pds/src/main/java/org/apache/ignite/internal/processors/cache/database/GridCacheOffheapManager.java index f8f91df..0be5652 100644 --- a/modules/pds/src/main/java/org/apache/ignite/internal/processors/cache/database/GridCacheOffheapManager.java +++ b/modules/pds/src/main/java/org/apache/ignite/internal/processors/cache/database/GridCacheOffheapManager.java @@ -1095,6 +1095,20 @@ public class GridCacheOffheapManager extends IgniteCacheOffheapManagerImpl imple } /** {@inheritDoc} */ + @Override public GridCursor<? extends CacheDataRow> cursor(int cacheId, + KeyCacheObject lower, + KeyCacheObject upper, + Object x) + throws IgniteCheckedException { + CacheDataStore delegate = init0(true); + + if (delegate != null) + return delegate.cursor(cacheId, lower, upper, x); + + return EMPTY_CURSOR; + } + + /** {@inheritDoc} */ @Override public void destroy() throws IgniteCheckedException { // No need to destroy delegate. }
