ignite-656: passing skipStore flag to higher API
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/83c55558 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/83c55558 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/83c55558 Branch: refs/heads/ignite-157-1 Commit: 83c555586666f1536fd02125d2ab03a8d548045b Parents: 63c3230 Author: Denis Magda <dma...@gridgain.com> Authored: Tue Apr 21 16:26:01 2015 +0300 Committer: Denis Magda <dma...@gridgain.com> Committed: Tue Apr 21 16:26:01 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/colocated/GridDhtColocatedCache.java | 2 +- .../cache/distributed/near/GridNearTransactionalCache.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/83c55558/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java index cafd268..654e1ea 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java @@ -164,7 +164,7 @@ public class GridDhtColocatedCache<K, V> extends GridDhtTransactionalCacheAdapte IgniteTxLocalAdapter tx = ctx.tm().threadLocalTx(ctx); - CacheOperationContext opCtx = ctx.operationContextPerCall(); + final CacheOperationContext opCtx = ctx.operationContextPerCall(); if (tx != null && !tx.implicit() && !skipTx) { return asyncOp(tx, new AsyncOp<Map<K, V>>(keys) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/83c55558/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTransactionalCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTransactionalCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTransactionalCache.java index 00b18a4..ca292dc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTransactionalCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTransactionalCache.java @@ -115,7 +115,7 @@ public class GridNearTransactionalCache<K, V> extends GridNearCacheAdapter<K, V> CacheOperationContext opCtx = ctx.operationContextPerCall(); - boolean skipStore = opCtx != null && opCtx.skipStore(); + final boolean skipStore = opCtx != null && opCtx.skipStore(); if (tx != null && !tx.implicit() && !skipTx) { return asyncOp(tx, new AsyncOp<Map<K, V>>(keys) {
