commit a1443f854f2c4e1b24bba3615fb8baa40005af67
author Anton Vinogradov <av@apache.org> Mon Dec 26 18:02:47 2016 +0300
committer Anton Vinogradov <av@apache.org> Mon Dec 26 18:02:47 2016 +0300
tree 30acb7df3f13c2e059962844e9b7eda7d0efa18b
parent 8c47ab468004c8449449069a77c5a81cd2f4236f

IGNITE-4424 REPLICATED cache isn't synced across nodes

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 @@
             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;
     }