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 Fri, 23 Dec 2016 09:38:14 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-4424 23b606e8c -> e5f04ccbc


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/e5f04ccb
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e5f04ccb
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e5f04ccb

Branch: refs/heads/ignite-4424
Commit: e5f04ccbcb28bc9364160c95e32efe4a802acc3e
Parents: 23b606e
Author: Anton Vinogradov <av@apache.org>
Authored: Fri Dec 23 12:38:04 2016 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Fri Dec 23 12:38:04 2016 +0300

----------------------------------------------------------------------
 .../distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java | 4 +---
 .../cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java | 2 +-
 2 files changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/e5f04ccb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
index 0870e5f..3ce1d75 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
@@ -381,7 +381,7 @@ public class GridNearAtomicSingleUpdateFuture extends GridNearAtomicAbstractUpda
     @Override protected void mapOnTopology() {
         cache.topology().readLock();
 
-        AffinityTopologyVersion topVer = null;
+        AffinityTopologyVersion topVer;
 
         try {
             if (cache.topology().stopping()) {
@@ -463,8 +463,6 @@ public class GridNearAtomicSingleUpdateFuture extends GridNearAtomicAbstractUpda
         Exception err = null;
         GridNearAtomicAbstractUpdateRequest singleReq0 = null;
 
-        GridCacheVersion futVer = cctx.versions().next(topVer);
-
         try {
             singleReq0 = mapSingleUpdate(topVer, futVer, updVer);
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/e5f04ccb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
index a4634ee..0acf351 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
@@ -490,7 +490,7 @@ public class GridNearAtomicUpdateFuture extends GridNearAtomicAbstractUpdateFutu
     @Override protected void mapOnTopology() {
         cache.topology().readLock();
 
-        AffinityTopologyVersion topVer = null;
+        AffinityTopologyVersion topVer;
 
         try {
             if (cache.topology().stopping()) {


Mime
View raw message