1571 |
|
} |
1572 |
|
|
1573 |
|
public void await(CountDownLatch latch, long timeoutMillis) { |
1574 |
+ |
boolean timedOut = false; |
1575 |
|
try { |
1576 |
< |
if (!latch.await(timeoutMillis, MILLISECONDS)) |
1576 |
< |
fail("timed out waiting for CountDownLatch for " |
1577 |
< |
+ (timeoutMillis/1000) + " sec"); |
1576 |
> |
timedOut = !latch.await(timeoutMillis, MILLISECONDS); |
1577 |
|
} catch (Throwable fail) { |
1578 |
|
threadUnexpectedException(fail); |
1579 |
|
} |
1580 |
+ |
if (timedOut) |
1581 |
+ |
fail("timed out waiting for CountDownLatch for " |
1582 |
+ |
+ (timeoutMillis/1000) + " sec"); |
1583 |
|
} |
1584 |
|
|
1585 |
|
public void await(CountDownLatch latch) { |
1587 |
|
} |
1588 |
|
|
1589 |
|
public void await(Semaphore semaphore) { |
1590 |
+ |
boolean timedOut = false; |
1591 |
|
try { |
1592 |
< |
if (!semaphore.tryAcquire(LONG_DELAY_MS, MILLISECONDS)) |
1590 |
< |
fail("timed out waiting for Semaphore for " |
1591 |
< |
+ (LONG_DELAY_MS/1000) + " sec"); |
1592 |
> |
timedOut = !semaphore.tryAcquire(LONG_DELAY_MS, MILLISECONDS); |
1593 |
|
} catch (Throwable fail) { |
1594 |
|
threadUnexpectedException(fail); |
1595 |
|
} |
1596 |
+ |
if (timedOut) |
1597 |
+ |
fail("timed out waiting for Semaphore for " |
1598 |
+ |
+ (LONG_DELAY_MS/1000) + " sec"); |
1599 |
|
} |
1600 |
|
|
1601 |
|
public void await(CyclicBarrier barrier) { |