Repository: incubator-ignite Updated Branches: refs/heads/ignite-757 78cf60adf -> aefb06558
ignite-656: compilation fix Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/075ed821 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/075ed821 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/075ed821 Branch: refs/heads/ignite-757 Commit: 075ed821343c200b20c1b0f7a0ce67236c26f148 Parents: 7735951 Author: Denis Magda <dma...@gridgain.com> Authored: Mon Apr 20 13:05:58 2015 +0300 Committer: Denis Magda <dma...@gridgain.com> Committed: Mon Apr 20 13:05:58 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/atomic/GridDhtAtomicCache.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/075ed821/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index 1d0555c..c56ff2a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@ -286,6 +286,8 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { final ExpiryPolicy expiryPlc = skipVals ? null : prj != null ? prj.expiry() : null; + final boolean skipStore = prj != null && prj.skipStore(); + return asyncOp(new CO<IgniteInternalFuture<Map<K, V>>>() { @Override public IgniteInternalFuture<Map<K, V>> apply() { return getAllAsync0(ctx.cacheKeysView(keys), @@ -296,7 +298,7 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { deserializePortable, expiryPlc, skipVals, - prj != null && prj.skipStore()); + skipStore); } }); }
