You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2015/07/23 04:53:23 UTC
[20/24] incubator-ignite git commit: IGNITE-104 - Ordered ATOMIC
updates
IGNITE-104 - Ordered ATOMIC updates
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/1fee0863
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/1fee0863
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/1fee0863
Branch: refs/heads/ignite-104
Commit: 1fee08635e5222a9765a8c775f5d792dc3103cc7
Parents: af8ed9a
Author: Valentin Kulichenko <vk...@gridgain.com>
Authored: Wed Jul 22 16:25:37 2015 -0700
Committer: Valentin Kulichenko <vk...@gridgain.com>
Committed: Wed Jul 22 16:25:37 2015 -0700
----------------------------------------------------------------------
.../cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1fee0863/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java
index 23b2161..f1d37f5 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java
@@ -121,6 +121,9 @@ public class GridDhtAtomicUpdateFuture extends GridFutureAdapter<Void>
boolean topLocked = updateReq.topologyLocked() || (updateReq.fastMap() && !updateReq.clientRequest());
waitForExchange = !topLocked;
+
+ // We can send entry processor instead of value to backup if updates are ordered.
+ forceTransformBackups = cctx.config().isAtomicOrderedUpdates();
}
/** {@inheritDoc} */