ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [01/11] incubator-ignite git commit: # Ignite minor
Date Fri, 19 Dec 2014 10:04:09 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-41 023013412 -> 784fadaf7


# 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/ignite-41
Commit: c3fbf9d3ef9c82e3bcd49df9f13e2ef8b4acefdd
Parents: c67dcde
Author: sboikov <sboikov@gridgain.com>
Authored: Mon Dec 15 14:26:31 2014 +0400
Committer: sboikov <sboikov@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);


Mime
View raw message