You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2015/02/03 07:32:47 UTC

[46/46] incubator-ignite git commit: GG-9655 - Fixing tests after merge.

GG-9655 - Fixing tests after merge.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/bc891395
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/bc891395
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/bc891395

Branch: refs/heads/ingite-9655-merge
Commit: bc8913950a1aa95ae9713a59bb278543d097c39f
Parents: be5b908
Author: Alexey Goncharuk <ag...@gridgain.com>
Authored: Mon Feb 2 22:31:50 2015 -0800
Committer: Alexey Goncharuk <ag...@gridgain.com>
Committed: Mon Feb 2 22:31:50 2015 -0800

----------------------------------------------------------------------
 .../ignite/internal/processors/cache/GridCacheReturn.java | 10 ++++++++++
 .../cache/distributed/dht/GridDhtTxPrepareFuture.java     |  2 ++
 .../processors/cache/IgniteCacheInvokeAbstractTest.java   |  6 +++---
 3 files changed, 15 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bc891395/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java
index 09a566f..93e5a0f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java
@@ -109,6 +109,13 @@ public class GridCacheReturn<V> implements Externalizable, IgniteOptimizedMarsha
     }
 
     /**
+     * @param invokeRes Invoke result flag.
+     */
+    public void invokeResult(boolean invokeRes) {
+        this.invokeRes = invokeRes;
+    }
+
+    /**
      * @param v Value.
      * @return This instance for chaining.
      */
@@ -177,6 +184,9 @@ public class GridCacheReturn<V> implements Externalizable, IgniteOptimizedMarsha
         assert invokeRes || v == null : "Invalid state to merge: " + this;
         assert other.invokeRes;
 
+        if (other.v == null)
+            return;
+
         invokeRes = true;
 
         HashMap<Object, EntryProcessorResult> resMap = (HashMap<Object, EntryProcessorResult>)v;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bc891395/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java
index 406a589..ea9aa00 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java
@@ -342,6 +342,8 @@ public final class GridDhtTxPrepareFuture<K, V> extends GridCompoundIdentityFutu
                             if (err != null || procRes != null)
                                 ret.addEntryProcessResult(key,
                                     err == null ? new CacheInvokeResult<>(procRes) : new CacheInvokeResult<>(err));
+                            else
+                                ret.invokeResult(true);
                         }
                         else
                             ret.value(val);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bc891395/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java
index ca760e9..5d55546 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java
@@ -339,7 +339,7 @@ public abstract class IgniteCacheInvokeAbstractTest extends IgniteCacheAbstractT
 
             switch (key % 4) {
                 case 0: {
-                    assertNotNull("No result for " + key);
+                    assertNotNull("No result for " + key, res);
 
                     assertEquals(62, (int)res.get());
 
@@ -357,7 +357,7 @@ public abstract class IgniteCacheInvokeAbstractTest extends IgniteCacheAbstractT
                 }
 
                 case 2: {
-                    assertNotNull("No result for " + key);
+                    assertNotNull("No result for " + key, res);
 
                     assertEquals(3, (int)res.get());
 
@@ -367,7 +367,7 @@ public abstract class IgniteCacheInvokeAbstractTest extends IgniteCacheAbstractT
                 }
 
                 case 3: {
-                    assertNotNull("No result for " + key);
+                    assertNotNull("No result for " + key, res);
 
                     GridTestUtils.assertThrows(log, new Callable<Void>() {
                         @Override public Void call() throws Exception {