ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a.@apache.org
Subject ignite git commit: IGNITE-4424 REPLICATED cache isn't synced across nodes
Date Mon, 26 Dec 2016 15:02:57 GMT
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 <av@apache.org>
Authored: Mon Dec 26 18:02:47 2016 +0300
Committer: Anton Vinogradov <av@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;
     }


Mime
View raw message