Repository: ignite Updated Branches: refs/heads/ignite-5578 66e0a4255 -> e2a491faf
ignite-5578 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e2a491fa Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e2a491fa Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e2a491fa Branch: refs/heads/ignite-5578 Commit: e2a491faf3b157fb038628a5c038c561f62f92ad Parents: 66e0a42 Author: sboikov <[email protected]> Authored: Thu Aug 3 12:00:32 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu Aug 3 12:00:32 2017 +0300 ---------------------------------------------------------------------- .../GridCacheAbstractDataStructuresFailoverSelfTest.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e2a491fa/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java index 5656138..7858d90 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java @@ -778,6 +778,8 @@ public abstract class GridCacheAbstractDataStructuresFailoverSelfTest extends Ig } }); + long endTime = System.currentTimeMillis() + getTestTimeout(); + while (!fut.isDone()) { try { lock.lock(); @@ -797,6 +799,9 @@ public abstract class GridCacheAbstractDataStructuresFailoverSelfTest extends Ig assertFalse(lock.isHeldByCurrentThread()); } } + + if (System.currentTimeMillis() > endTime) + fail("Failed to wait for topology change threads."); } fut.get();
