#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/sprint-2 Commit: d254da4ba7e22f3ba6931e24c0e9a4ed7139db09 Parents: 7fb3890 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Fri Feb 27 15:26:57 2015 +0300 Committer: ivasilinets <ivasilin...@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(); } /**
