Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Adding Thread Dump to be reported on failing Wait conditions

This commit is contained in:
Clebert Suconic 2020-12-22 13:28:30 -05:00
parent 372220ad3f
commit 4dd51bc1ef
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-commons/src/test/java/org/apache/activemq/artemis/utils/Wait.java
View File

@ -68,6 +68,7 @@ public class Wait {
boolean result = waitFor(() -> condition.getCount() == size, timeout, sleepMillis); boolean result = waitFor(() -> condition.getCount() == size, timeout, sleepMillis);
if (!result) { if (!result) {
System.out.println(ThreadDumpUtil.threadDump("thread dump"));
Assert.fail(size + " != " + condition.getCount()); Assert.fail(size + " != " + condition.getCount());
} }
} }
@ -86,6 +87,7 @@ public class Wait {
boolean result = waitFor(() -> (obj == condition || obj.equals(condition.getObject())), timeout, sleepMillis); boolean result = waitFor(() -> (obj == condition || obj.equals(condition.getObject())), timeout, sleepMillis);
if (!result) { if (!result) {
System.out.println(ThreadDumpUtil.threadDump("thread dump"));
Assert.assertEquals(obj, condition.getObject()); Assert.assertEquals(obj, condition.getObject());
} }
} }
@ -94,6 +96,7 @@ public class Wait {
boolean result = waitFor(() -> condition.getCount() == size, timeout, sleepMillis); boolean result = waitFor(() -> condition.getCount() == size, timeout, sleepMillis);
if (!result) { if (!result) {
System.out.println(ThreadDumpUtil.threadDump("thread dump"));
Assert.fail(size + " != " + condition.getCount()); Assert.fail(size + " != " + condition.getCount());
} }
} }
@ -140,6 +143,7 @@ public class Wait {
boolean result = waitFor(condition, duration, sleep); boolean result = waitFor(condition, duration, sleep);
if (!result) { if (!result) {
System.out.println(ThreadDumpUtil.threadDump("thread dump"));
Assert.fail(failureMessage); Assert.fail(failureMessage);
} }
} }
@ -163,6 +167,9 @@ public class Wait {
} }
conditionSatisified = condition.isSatisfied(); conditionSatisified = condition.isSatisfied();
} }
if (!conditionSatisified) {
System.out.println(ThreadDumpUtil.threadDump("thread dump"));
}
return conditionSatisified; return conditionSatisified;
} catch (Exception e) { } catch (Exception e) {
throw new IllegalStateException(e); throw new IllegalStateException(e);