Home
last modified time | relevance | path

Searched refs:awaitUninterruptibly (Results 1 – 25 of 37) sorted by relevance

12

/external/guava/guava/src/com/google/common/util/concurrent/
DUninterruptibles.java55 public static void awaitUninterruptibly(CountDownLatch latch) { in awaitUninterruptibly() method in Uninterruptibles
82 public static boolean awaitUninterruptibly(CountDownLatch latch, Duration timeout) { in awaitUninterruptibly() method in Uninterruptibles
83 return awaitUninterruptibly(latch, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); in awaitUninterruptibly()
93 public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) { in awaitUninterruptibly() method in Uninterruptibles
123 public static boolean awaitUninterruptibly(Condition condition, Duration timeout) { in awaitUninterruptibly() method in Uninterruptibles
124 return awaitUninterruptibly(condition, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); in awaitUninterruptibly()
135 public static boolean awaitUninterruptibly(Condition condition, long timeout, TimeUnit unit) { in awaitUninterruptibly() method in Uninterruptibles
DForwardingCondition.java36 public void awaitUninterruptibly() { in awaitUninterruptibly() method in ForwardingCondition
37 delegate().awaitUninterruptibly(); in awaitUninterruptibly()
DMonitor.java580 awaitUninterruptibly(guard, signalBeforeWaiting);
874 awaitUninterruptibly(guard, true);
1192 private void awaitUninterruptibly(Guard guard, boolean signalBeforeWaiting) {
1199 guard.condition.awaitUninterruptibly();
/external/guava/android/guava/src/com/google/common/util/concurrent/
DForwardingCondition.java36 public void awaitUninterruptibly() { in awaitUninterruptibly() method in ForwardingCondition
37 delegate().awaitUninterruptibly(); in awaitUninterruptibly()
DUninterruptibles.java53 public static void awaitUninterruptibly(CountDownLatch latch) { in awaitUninterruptibly() method in Uninterruptibles
78 public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) { in awaitUninterruptibly() method in Uninterruptibles
108 public static boolean awaitUninterruptibly(Condition condition, long timeout, TimeUnit unit) { in awaitUninterruptibly() method in Uninterruptibles
DMonitor.java526 awaitUninterruptibly(guard, signalBeforeWaiting); in enterWhenUninterruptibly()
775 awaitUninterruptibly(guard, true); in waitForUninterruptibly()
1082 private void awaitUninterruptibly(Guard guard, boolean signalBeforeWaiting) { in awaitUninterruptibly() method in Monitor
1089 guard.condition.awaitUninterruptibly(); in awaitUninterruptibly()
/external/webrtc/rtc_base/java/src/org/webrtc/
DThreadUtils.java114 public static void awaitUninterruptibly(final CountDownLatch latch) { in awaitUninterruptibly() method in ThreadUtils
123 public static boolean awaitUninterruptibly(CountDownLatch barrier, long timeoutMs) { in awaitUninterruptibly() method in ThreadUtils
180 awaitUninterruptibly(barrier); in invokeAtFrontUninterruptibly()
/external/guava/android/guava-tests/test/com/google/common/collect/
DMapMakerTest.java19 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
50 awaitUninterruptibly(delayLatch); in apply()
/external/guava/guava-tests/test/com/google/common/collect/
DMapMakerTest.java19 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
50 awaitUninterruptibly(delayLatch); in apply()
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DUninterruptiblesTest.java21 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
108 boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 500, MILLISECONDS); in testConditionAwaitTimeoutExceeded()
119 boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 1500, MILLISECONDS); in testConditionAwaitTimeoutNotExceeded()
131 boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 1000, MILLISECONDS); in testConditionAwaitInterruptedTimeoutExceeded()
143 boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 1500, MILLISECONDS); in testConditionAwaitInterruptedTimeoutNotExceeded()
855 awaitUninterruptibly(latch);
914 public void awaitUninterruptibly() {
917 condition.awaitUninterruptibly();
DClosingFutureTest.java28 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
178 awaitUninterruptibly(futureCancelled); in testEventuallyClosing_cancelledPipeline()
239 awaitUninterruptibly(futureCancelled); in testSubmit_cancelledPipeline()
471 awaitUninterruptibly(futureCancelled); in testTransform_cancelledPipeline()
542 awaitUninterruptibly(futureCancelled); in testTransformAsync_cancelledPipeline()
673 awaitUninterruptibly(futureCancelled); in testWhenAllComplete_call_cancelledPipeline()
759 awaitUninterruptibly(futureCancelled); in testWhenAllComplete_callAsync_cancelledPipeline()
885 awaitUninterruptibly(futureCancelled); in testWhenAllSucceed2_call_cancelledPipeline()
978 awaitUninterruptibly(futureCancelled); in testWhenAllSucceed2_callAsync_cancelledPipeline()
1075 awaitUninterruptibly(futureCancelled); in testWhenAllSucceed3_call_cancelledPipeline()
[all …]
DGeneratedMonitorTest.java19 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
481 awaitUninterruptibly(doingCallLatch); in runTest()
487 !awaitUninterruptibly(callCompletedLatch, hangDelayMillis, TimeUnit.MILLISECONDS); in runTest()
678 awaitUninterruptibly(startedLatch); in enterSatisfyGuardAndLeaveInAnotherThread()
690 awaitUninterruptibly(tearDownLatch); in enterAndRemainOccupyingInAnotherThread()
697 awaitUninterruptibly(enteredLatch); in enterAndRemainOccupyingInAnotherThread()
DFuturesTransformAsyncTest.java22 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
69 awaitUninterruptibly(funcCompletionLatch); in apply()
DSequentialExecutorTest.java21 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
323 awaitUninterruptibly(latch); in testRejectedExecutionThrownWithMultipleCalls()
DInterruptibleTaskTest.java163 Uninterruptibles.awaitUninterruptibly(exitClose); in implCloseChannel()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DUninterruptiblesTest.java21 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
109 boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 500, MILLISECONDS); in testConditionAwaitTimeoutExceeded()
120 boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 1500, MILLISECONDS); in testConditionAwaitTimeoutNotExceeded()
132 boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 1000, MILLISECONDS); in testConditionAwaitInterruptedTimeoutExceeded()
144 boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 1500, MILLISECONDS); in testConditionAwaitInterruptedTimeoutNotExceeded()
876 awaitUninterruptibly(latch);
935 public void awaitUninterruptibly() {
938 condition.awaitUninterruptibly();
DClosingFutureTest.java28 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
178 awaitUninterruptibly(futureCancelled); in testEventuallyClosing_cancelledPipeline()
239 awaitUninterruptibly(futureCancelled); in testSubmit_cancelledPipeline()
488 awaitUninterruptibly(futureCancelled); in testTransform_cancelledPipeline()
559 awaitUninterruptibly(futureCancelled); in testTransformAsync_cancelledPipeline()
690 awaitUninterruptibly(futureCancelled); in testWhenAllComplete_call_cancelledPipeline()
776 awaitUninterruptibly(futureCancelled); in testWhenAllComplete_callAsync_cancelledPipeline()
902 awaitUninterruptibly(futureCancelled); in testWhenAllSucceed2_call_cancelledPipeline()
995 awaitUninterruptibly(futureCancelled); in testWhenAllSucceed2_callAsync_cancelledPipeline()
1092 awaitUninterruptibly(futureCancelled); in testWhenAllSucceed3_call_cancelledPipeline()
[all …]
DGeneratedMonitorTest.java19 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
506 awaitUninterruptibly(doingCallLatch); in runTest()
512 !awaitUninterruptibly(callCompletedLatch, hangDelayMillis, TimeUnit.MILLISECONDS); in runTest()
704 awaitUninterruptibly(startedLatch); in enterSatisfyGuardAndLeaveInAnotherThread()
716 awaitUninterruptibly(tearDownLatch); in enterAndRemainOccupyingInAnotherThread()
723 awaitUninterruptibly(enteredLatch); in enterAndRemainOccupyingInAnotherThread()
DFuturesTransformAsyncTest.java22 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
69 awaitUninterruptibly(funcCompletionLatch); in apply()
DSequentialExecutorTest.java21 import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
323 awaitUninterruptibly(latch); in testRejectedExecutionThrownWithMultipleCalls()
DInterruptibleTaskTest.java163 Uninterruptibles.awaitUninterruptibly(exitClose); in implCloseChannel()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/
DErrorHandlingClient.java136 if (!Uninterruptibles.awaitUninterruptibly(latch, 1, TimeUnit.SECONDS)) { in futureCallCallback()
168 if (!Uninterruptibles.awaitUninterruptibly(latch, 1, TimeUnit.SECONDS)) { in asyncCall()
198 if (!Uninterruptibles.awaitUninterruptibly(latch, 1, TimeUnit.SECONDS)) { in advancedAsyncCall()
DDetailErrorSample.java160 if (!Uninterruptibles.awaitUninterruptibly(latch, 1, TimeUnit.SECONDS)) { in futureCallCallback()
189 if (!Uninterruptibles.awaitUninterruptibly(latch, 1, TimeUnit.SECONDS)) { in asyncCall()
224 if (!Uninterruptibles.awaitUninterruptibly(latch, 1, TimeUnit.SECONDS)) { in advancedAsyncCall()
/external/webrtc/sdk/android/instrumentationtests/src/org/webrtc/
DCamera2CapturerTest.java63 ThreadUtils.awaitUninterruptibly(startedSignal); in waitToStart()
135 ThreadUtils.awaitUninterruptibly(openDoneSignal); in SimpleCamera2()
/external/webrtc/sdk/android/api/org/webrtc/
DSurfaceEglRenderer.java119 ThreadUtils.awaitUninterruptibly(completionLatch); in surfaceDestroyed()

12