Repository: ignite Updated Branches: refs/heads/ignite-1537 b0ad04490 -> 84aba5aa1
ignite-1911 Added special stop method to avoid hangs inside Ignition.start. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/84aba5aa Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/84aba5aa Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/84aba5aa Branch: refs/heads/ignite-1537 Commit: 84aba5aa19323c089c1f44b9cd85fbd8fbe836c5 Parents: b0ad044 Author: sboikov <[email protected]> Authored: Thu Dec 10 09:43:24 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Dec 10 09:43:24 2015 +0300 ---------------------------------------------------------------------- .../cache/IgniteCacheEntryListenerAbstractTest.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/84aba5aa/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java index 8a3d756..27edb0c 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java @@ -113,7 +113,13 @@ public abstract class IgniteCacheEntryListenerAbstractTest extends IgniteCacheAb for (int i = 0; i < gridCount(); i++) { GridContinuousProcessor proc = grid(i).context().continuous(); - ConcurrentMap<?, ?> syncMsgFuts = GridTestUtils.getFieldValue(proc, "syncMsgFuts"); + final ConcurrentMap<?, ?> syncMsgFuts = GridTestUtils.getFieldValue(proc, "syncMsgFuts"); + + GridTestUtils.waitForCondition(new GridAbsPredicate() { + @Override public boolean apply() { + return syncMsgFuts.size() == 0; + } + }, 5000); assertEquals(0, syncMsgFuts.size()); }
