ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [18/50] incubator-ignite git commit: #ignite-237: add debug to tests.
Date Wed, 04 Mar 2015 03:33:24 GMT
#ignite-237: add debug to tests.


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

Branch: refs/heads/ignite-45
Commit: d254da4ba7e22f3ba6931e24c0e9a4ed7139db09
Parents: 7fb3890
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Fri Feb 27 15:26:57 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Fri Feb 27 15:26:57 2015 +0300

----------------------------------------------------------------------
 ...GridCacheContinuousQueryAbstractSelfTest.java | 19 +++++++++++++++++--
 1 file changed, 17 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d254da4b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
index a69ce36..0d9e189 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
@@ -159,8 +159,21 @@ public abstract class GridCacheContinuousQueryAbstractSelfTest extends
GridCommo
             }
         }
 
-        for (int i = 0; i < gridCount(); i++)
-            assertEquals("Cache is not empty: " + ((IgniteKernal)grid(i)).cache(null).entrySet(),
0, ((IgniteKernal)grid(i)).cache(null).size());
+        boolean allEmpty = true;
+
+        for (int i = 0; i < gridCount(); i++) {
+            Set<Cache.Entry<Object, Object>> entries = ((IgniteKernal) grid(i)).cache(null).entrySet();
+
+            for (Cache.Entry entry : entries) {
+                info("Not removed entry " + grid(i).affinity(null).isPrimary(grid(i).localNode(),
entry.getKey()));
+                info("Not removed entry " + grid(i).affinity(null).isBackup(grid(i).localNode(),
entry.getKey()));
+                allEmpty = false;
+            }
+
+            info("Cache is not empty: " + ((IgniteKernal) grid(i)).cache(null).entrySet());
+        }
+
+        assertTrue(allEmpty);
 
         for (int i = 0; i < gridCount(); i++) {
             GridContinuousProcessor proc = ((IgniteKernal)grid(i)).context().continuous();
@@ -831,6 +844,8 @@ public abstract class GridCacheContinuousQueryAbstractSelfTest extends
GridCommo
         finally {
             stopGrid("anotherGrid");
         }
+
+        awaitPartitionMapExchange();
     }
 
     /**


Mime
View raw message