Skip to content

Commit f269fb8

Browse files
author
Ian Craggs
committed
Stabilize test402
1 parent 127fe1d commit f269fb8

1 file changed

Lines changed: 10 additions & 3 deletions

File tree

  • org.eclipse.paho.client.mqttv3.test/src/test/java/org/eclipse/paho/client/mqttv3/test

org.eclipse.paho.client.mqttv3.test/src/test/java/org/eclipse/paho/client/mqttv3/test/BasicTest.java

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -402,9 +402,16 @@ public void test402() throws Exception {
402402

403403
int after_count = Thread.activeCount();
404404
Thread[] tarray = new Thread[after_count];
405-
after_count = Thread.enumerate(tarray);
406-
for (int i = 0; i < after_count; ++i) {
407-
log.info(i + " " + tarray[i].getName());
405+
int count = 0;
406+
while (after_count > before_thread_count) {
407+
after_count = Thread.enumerate(tarray);
408+
for (int i = 0; i < after_count; ++i) {
409+
log.info(i + " " + tarray[i].getName());
410+
}
411+
if (++count == 10) {
412+
break;
413+
}
414+
Thread.sleep(100);
408415
}
409416
Assert.assertEquals(before_thread_count, after_count);
410417
}

0 commit comments

Comments
 (0)