Repository: ignite Updated Branches: refs/heads/ignite-4424 8c47ab468 -> a1443f854
IGNITE-4424 REPLICATED cache isn't synced across nodes Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a1443f85 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a1443f85 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a1443f85 Branch: refs/heads/ignite-4424 Commit: a1443f854f2c4e1b24bba3615fb8baa40005af67 Parents: 8c47ab4 Author: Anton Vinogradov <a...@apache.org> Authored: Mon Dec 26 18:02:47 2016 +0300 Committer: Anton Vinogradov <a...@apache.org> Committed: Mon Dec 26 18:02:47 2016 +0300 ---------------------------------------------------------------------- .../dht/atomic/GridNearAtomicAbstractUpdateFuture.java | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a1443f85/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateFuture.java index 2a2aa55..c92e0f5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateFuture.java @@ -337,13 +337,8 @@ public abstract class GridNearAtomicAbstractUpdateFuture extends GridFutureAdapt this.futVer = futVer; } - if (storeFuture()) { - if (!cctx.mvcc().addAtomicFuture(futVer, this)) { - assert isDone() : this; - - return null; - } - } + if (storeFuture() && !cctx.mvcc().addAtomicFuture(futVer, this)) + return null; return futVer; }
