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 <vkuliche...@gridgain.com> Authored: Wed Jul 22 16:25:37 2015 -0700 Committer: Valentin Kulichenko <vkuliche...@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} */
