Repository: incubator-ignite Updated Branches: refs/heads/master c67dcde9f -> c3fbf9d3e
# Ignite minor Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c3fbf9d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c3fbf9d3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c3fbf9d3 Branch: refs/heads/master Commit: c3fbf9d3ef9c82e3bcd49df9f13e2ef8b4acefdd Parents: c67dcde Author: sboikov <sboi...@gridgain.com> Authored: Mon Dec 15 14:26:31 2014 +0400 Committer: sboikov <sboi...@gridgain.com> Committed: Mon Dec 15 14:26:31 2014 +0400 ---------------------------------------------------------------------- .../cache/distributed/dht/atomic/GridDhtAtomicCache.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c3fbf9d3/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index 4991adb..997671b 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@ -897,7 +897,7 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { boolean replicate = ctx.isDrEnabled(); - if (storeEnabled() && keys.size() > 1 && ctx.dr().receiveEnabled()) { + if (storeEnabled() && keys.size() > 1 && !ctx.dr().receiveEnabled()) { // This method can only be used when there are no replicated entries in the batch. UpdateBatchResult<K, V> updRes = updateWithBatch(node, hasNear, req, res, locked, ver, dhtFut, completionCb, replicate, taskName);
