diff --git a/src/test/java/blackbox/slow/PoolIT.java b/src/test/java/blackbox/slow/PoolIT.java index a625922a..144dec54 100644 --- a/src/test/java/blackbox/slow/PoolIT.java +++ b/src/test/java/blackbox/slow/PoolIT.java @@ -25,6 +25,7 @@ import org.junit.jupiter.api.extension.RegisterExtension; import stormpot.Completion; import stormpot.GenericPoolable; +import stormpot.ManagedPool; import stormpot.Pool; import stormpot.PoolBuilder; import stormpot.PoolException; @@ -285,10 +286,12 @@ void mustGraduallyReduceAggressivenessInRepairingFailingAllocator() throws Excep })); builder.setAllocator(allocator); createPool(); + ManagedPool managedPool = pool.getManagedPool(); GenericPoolable obj = pool.claim(longTimeout); obj.expire(); obj.release(); assertThrows(PoolException.class, () -> pool.claim(longTimeout).release()); + StringBuilder sb = new StringBuilder(1024); long prev = 0, curr; for (int i = 0; i < 50; i++) { long start = System.nanoTime(); @@ -297,14 +300,22 @@ void mustGraduallyReduceAggressivenessInRepairingFailingAllocator() throws Excep if (elapsedMillis >= 150) { // Ignore outliers with very high sleep time. i--; + prev = counter.get(); continue; } curr = counter.get(); long delta = curr - prev; + sb.append("i = ").append(i).append(", delta = ").append(delta) + .append(", alloc ratio = ") + .append(managedPool.getAllocationCount()).append('/').append(managedPool.getFailedAllocationCount()) + .append('\n'); prev = curr; if (i > 40) { + if (delta > 5) { + } assertThat(delta).isLessThanOrEqualTo(5); } } + System.out.print(sb); } }