| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractScheduledServiceTest.java | 77 service.runFirstBarrier.await(); in testFailOnExceptionFromRun()
78 service.runSecondBarrier.await(); in testFailOnExceptionFromRun()
107 service.runFirstBarrier.await(); in testFailOnExceptionFromShutDown()
109 service.runSecondBarrier.await(); in testFailOnExceptionFromShutDown()
123 service.runFirstBarrier.await(); in testRunOneIterationCalledMultipleTimes()
125 service.runSecondBarrier.await(); in testRunOneIterationCalledMultipleTimes()
127 service.runFirstBarrier.await(); in testRunOneIterationCalledMultipleTimes()
129 service.runSecondBarrier.await(); in testRunOneIterationCalledMultipleTimes()
139 service.runFirstBarrier.await(); in testExecutorOnlyCalledOnce()
141 service.runSecondBarrier.await(); in testExecutorOnlyCalledOnce()
[all …]
|
| D | ListenableFutureTaskTest.java | 50 taskLatch.await();
92 runLatch.await(); in testListenerDoesNotRunUntilTaskCompletes()
101 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS)); in testListenerDoesNotRunUntilTaskCompletes()
111 runLatch.await(); in testListenerCalledOnException()
121 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS)); in testListenerCalledOnException()
133 listenerLatch.await(5, TimeUnit.SECONDS); in testListenerCalledOnCancelFromNotRunning()
143 runLatch.await(); in testListenerCalledOnCancelFromRunning()
152 listenerLatch.await(5, TimeUnit.SECONDS); in testListenerCalledOnCancelFromRunning()
|
| D | ListenableFutureTester.java | 72 assertTrue(latch.await(5, TimeUnit.SECONDS)); in testCompletedFuture()
84 assertTrue(latch.await(5, TimeUnit.SECONDS)); in testCancelledFuture()
99 assertTrue(latch.await(5, TimeUnit.SECONDS)); in testFailedFuture()
|
| D | AbstractExecutionThreadServiceTest.java | 71 enterRun.await(); // to avoid stopping the service until run() is invoked in testServiceStartStop()
84 enterRun.await(); // to avoid stopping the service until run() is invoked in testServiceStopIdempotence()
140 exitRun.await(); in run()
269 enterRun.await(); in run()
313 started.await(); in testStopWhileStarting_runNotCalled()
338 enterRun.await(); in testDefaultService()
|
| D | JdkFutureAdaptersTest.java | 137 submitSuccessful.await(); in testListenInPoolThreadCustomExecutorInterrupted()
183 allowGetToComplete.await(1, SECONDS); in get()
242 assertTrue(earlyListener.wasRun.await(1, SECONDS)); in testListenInPoolThreadRunsListenerAfterRuntimeException()
247 assertTrue(lateListener.wasRun.await(1, SECONDS)); in testListenInPoolThreadRunsListenerAfterRuntimeException()
|
| D | ExecutionListTest.java | 52 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in testRunOnPopulatedList()
74 okayToRun.await(); in testExecute_idempotentConcurrently()
105 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in testAddAfterRun()
|
| D | SerializingExecutorTest.java | 191 barrier.await(); in testTaskThrowsError()
201 barrier.await(10, TimeUnit.SECONDS); in testTaskThrowsError()
204 barrier.await(10, TimeUnit.SECONDS); in testTaskThrowsError()
|
| D | JSR166TestCase.java | 916 latch.await(); in latchAwaitingStringTask()
925 await(latch);
929 public void await(CountDownLatch latch) {
931 assertTrue(latch.await(LONG_DELAY_MS, MILLISECONDS));
937 public void await(Semaphore semaphore) {
1172 public int await() {
1174 return super.await(2 * LONG_DELAY_MS, MILLISECONDS);
|
| /external/guice/core/test/com/google/inject/internal/ |
| D | CycleDetectingLockTest.java | 45 signal3.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS); in testSingletonThreadsRuntimeCircularDependency()
61 signal2.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS); in testSingletonThreadsRuntimeCircularDependency()
62 signal3.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS); in testSingletonThreadsRuntimeCircularDependency()
76 signal1.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS); in testSingletonThreadsRuntimeCircularDependency()
89 signal1.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS); in testSingletonThreadsRuntimeCircularDependency()
90 signal2.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS); in testSingletonThreadsRuntimeCircularDependency()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | AbstractListenableFutureTest.java | 96 assertTrue(successLatch.await(10, TimeUnit.SECONDS)); in testGetBlocksUntilValueAvailable()
158 assertTrue(successLatch.await(200, TimeUnit.MILLISECONDS)); in testCanceledFutureThrowsCancellation()
194 assertTrue(successLatch.await(200, TimeUnit.MILLISECONDS)); in testListenersNotifiedOnError()
195 assertTrue(listenerLatch.await(200, TimeUnit.MILLISECONDS)); in testListenersNotifiedOnError()
241 listenerLatch.await(500, TimeUnit.MILLISECONDS); in testAllListenersCompleteSuccessfully()
|
| D | MockFutureListener.java | 62 Assert.assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in assertSuccess()
78 Assert.assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in assertException()
91 Assert.assertFalse(countDownLatch.await(1L, TimeUnit.SECONDS)); in assertTimeout()
|
| D | AbstractCheckedFutureTest.java | 124 assertTrue(startingGate.await(500, TimeUnit.MILLISECONDS)); in testCheckedGetThrowsApplicationExceptionOnInterruption()
127 assertTrue(successLatch.await(500, TimeUnit.MILLISECONDS)); in testCheckedGetThrowsApplicationExceptionOnInterruption()
|
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| D | GcFinalization.java | 165 public static void await(CountDownLatch latch) { in await() method in GcFinalization
178 if (latch.await(1L, SECONDS)) { in await()
231 await(done); in awaitDone()
291 await(finalizerRan); in awaitFullGc()
|
| /external/blktrace/btt/ |
| D | iostat.c | 87 double dt, nios, avgrq_sz, p_util, nrqm, await, svctm; in __dump_stats() local
109 await = ((nios + nrqm) > 0.0) ? TO_MSEC(sp->wait) / (nios+nrqm) : 0.0; in __dump_stats()
129 fprintf(iostat_ofp, "%7.2lf ", await); in __dump_stats()
155 asp->await += await; in __dump_stats()
176 fprintf(iostat_ofp, "%7.2lf ", asp->await / asp->n); in __dump_stats_t()
|
| /external/sl4a/Utils/src/com/googlecode/android_scripting/future/ |
| D | FutureResult.java | 45 mLatch.await(); in get()
51 mLatch.await(timeout, unit); in get()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | Ping.java | 55 latch.await(); in roundTripTime()
65 if (latch.await(timeout, unit)) { in roundTripTime()
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| D | WaitingThread.java | 142 public boolean await(Date deadline) in await() method in WaitingThread
164 this.cond.await(); in await()
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ |
| D | TextToSpeechFacade.java | 59 mOnInitLock.await(); in ttsSpeak()
67 mOnInitLock.await(); in ttsIsSpeaking()
|
| /external/guice/core/test/com/google/inject/ |
| D | BindingOrderTest.java | 76 ready.await(); in testBindingWithExtraThreads()
90 done.await(); in testBindingWithExtraThreads()
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| D | AutobahnTester.java | 107 if (!latch.await(10, TimeUnit.SECONDS)) { in runTest()
142 if (!latch.await(10, TimeUnit.SECONDS)) { in getTestCount()
177 if (!latch.await(10, TimeUnit.SECONDS)) { in updateReports()
|
| /external/webrtc/talk/app/webrtc/java/testcommon/src/org/webrtc/ |
| D | PeerConnectionTest.java | 435 public boolean await() { in await() method in PeerConnectionTest.SdpObserverLatch
437 assertTrue(latch.await(1000, TimeUnit.MILLISECONDS)); in await()
574 assertTrue(sdpLatch.await());
589 assertTrue(sdpLatch.await());
599 assertTrue(sdpLatch.await());
613 assertTrue(sdpLatch.await());
619 assertTrue(sdpLatch.await());
640 assertTrue(sdpLatch.await());
|
| /external/guice/extensions/service/test/com/google/inject/service/ |
| D | SingleServiceIntegrationTest.java | 44 assertTrue(startLatch.await(2, TimeUnit.SECONDS)); in testAsyncServiceLifecycle()
52 assertTrue(stopLatch.await(2, TimeUnit.SECONDS)); in testAsyncServiceLifecycle()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | CallTest.java | 560 callback.await(request.httpUrl()) in get_Async()
614 callback.await(server.url("/a")).assertBody("abc"); in connectionPooling_Async()
617 callback.await(server.url("/b")).assertBody("def"); in connectionPooling_Async()
620 callback.await(server.url("/c")).assertBody("ghi"); in connectionPooling_Async()
648 callback.await(server.url("/b")).assertCode(200).assertBody("def"); in connectionReuseWhenResponseBodyConsumed_Async()
793 callback.await(request.httpUrl()).assertHandshake(); in tls_Async()
882 callback.await(request.httpUrl()).assertBody("abc"); in recoverFromTlsHandshakeFailure_Async()
989 callback.await(request.httpUrl()) in post_Async()
1151 callback.await(request1.httpUrl()).assertCode(200).assertBody("A"); in conditionalCacheHit_Async()
1158 callback.await(request2.httpUrl()).assertCode(200).assertBody("A"); in conditionalCacheHit_Async()
[all …]
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ui/ |
| D | FullScreenTask.java | 155 p.mLatch.await(); in setViewProperty()
175 p.mLatch.await(); in setList()
314 p.mLatch.await(); in setLayout()
324 p.mLatch.await(); in setTitle()
|
| /external/webrtc/talk/app/webrtc/java/android/org/webrtc/ |
| D | ThreadUtils.java | 127 latch.await(); in awaitUninterruptibly()
139 result = barrier.await(timeRemainingMs, TimeUnit.MILLISECONDS); in awaitUninterruptibly()
|