[activemq-artemis] branch master updated: NO-JIRA Adding Thread Dump to be reported on failing Wait conditions

[clebertsuconic]

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 4dd51bc  NO-JIRA Adding Thread Dump to be reported on failing Wait 
conditions
4dd51bc is described below

commit 4dd51bc1ef25c2e71edeb15a7d6e6f67476222bb
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Tue Dec 22 13:28:30 2020 -0500

    NO-JIRA Adding Thread Dump to be reported on failing Wait conditions
---
 .../src/test/java/org/apache/activemq/artemis/utils/Wait.java      | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/Wait.java 
b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/Wait.java
index 85e72bb..42cf074 100644
--- a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/Wait.java
+++ b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/Wait.java
@@ -68,6 +68,7 @@ public class Wait {
       boolean result = waitFor(() -> condition.getCount() == size, timeout, 
sleepMillis);
 
       if (!result) {
+         System.out.println(ThreadDumpUtil.threadDump("thread dump"));
          Assert.fail(size + " != " + condition.getCount());
       }
    }
@@ -86,6 +87,7 @@ public class Wait {
       boolean result = waitFor(() -> (obj == condition || 
obj.equals(condition.getObject())), timeout, sleepMillis);
 
       if (!result) {
+         System.out.println(ThreadDumpUtil.threadDump("thread dump"));
          Assert.assertEquals(obj, condition.getObject());
       }
    }
@@ -94,6 +96,7 @@ public class Wait {
       boolean result = waitFor(() -> condition.getCount() == size, timeout, 
sleepMillis);
 
       if (!result) {
+         System.out.println(ThreadDumpUtil.threadDump("thread dump"));
          Assert.fail(size + " != " + condition.getCount());
       }
    }
@@ -140,6 +143,7 @@ public class Wait {
       boolean result = waitFor(condition, duration, sleep);
 
       if (!result) {
+         System.out.println(ThreadDumpUtil.threadDump("thread dump"));
          Assert.fail(failureMessage);
       }
    }
@@ -163,6 +167,9 @@ public class Wait {
             }
             conditionSatisified = condition.isSatisfied();
          }
+         if (!conditionSatisified) {
+            System.out.println(ThreadDumpUtil.threadDump("thread dump"));
+         }
          return conditionSatisified;
       } catch (Exception e) {
          throw new IllegalStateException(e);