Aggressively wait and log

io7m-com · Apr 27, 2023 · f3e1751 · f3e1751
1 parent fca2042
commit f3e1751
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 9 deletions.
diff --git a/com.io7m.hibiscus.tests/src/test/java/com/io7m/hibiscus/tests/HBClientAsynchronousTest.java b/com.io7m.hibiscus.tests/src/test/java/com/io7m/hibiscus/tests/HBClientAsynchronousTest.java
@@ -202,11 +202,22 @@ private void waitForClose(
   {
     LOG.debug("{}: waiting for close", this.testInfo.getDisplayName());
 
-    while (!leakedClient.isClosed()) {
+    for (int index = 0; index < 1000_000_00; ++index) {
+      LOG.debug(
+        "{}: still waiting ({})",
+        this.testInfo.getDisplayName(),
+        leakedClient.stateNow()
+      );
+
+      if (leakedClient.isClosed()) {
+        break;
+      }
       sleep();
     }
 
-    LOG.debug("{}: waited for close successfully", this.testInfo.getDisplayName());
+    LOG.debug(
+      "{}: waited for close successfully",
+      this.testInfo.getDisplayName());
   }
 
   private static void sleep()

diff --git a/com.io7m.hibiscus.tests/src/test/java/com/io7m/hibiscus/tests/HBClientSynchronousTest.java b/com.io7m.hibiscus.tests/src/test/java/com/io7m/hibiscus/tests/HBClientSynchronousTest.java
@@ -189,13 +189,11 @@ private void waitForClose(
     LOG.debug("{}: waiting for close", this.testInfo.getDisplayName());
 
     for (int index = 0; index < 1000_000_00; ++index) {
-      if (index % 100 == 0) {
-        LOG.debug(
-          "{}: still waiting ({})",
-          this.testInfo.getDisplayName(),
-          leakedClient.stateNow()
-        );
-      }
+      LOG.debug(
+        "{}: still waiting ({})",
+        this.testInfo.getDisplayName(),
+        leakedClient.stateNow()
+      );
 
       if (leakedClient.isClosed()) {
         break;