| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | AbstractListenableFutureTest.java | 58 latch.countDown(); in tearDown()
86 successLatch.countDown(); in testGetBlocksUntilValueAvailable()
94 latch.countDown(); in testGetBlocksUntilValueAvailable()
120 latch.countDown(); in testTimeoutOnGetWorksCorrectly()
143 successLatch.countDown(); in testCanceledFutureThrowsCancellation()
160 latch.countDown(); in testCanceledFutureThrowsCancellation()
172 listenerLatch.countDown(); in testListenersNotifiedOnError()
182 successLatch.countDown(); in testListenersNotifiedOnError()
197 latch.countDown(); in testListenersNotifiedOnError()
226 latch.countDown(); in testAllListenersCompleteSuccessfully()
[all …]
|
| D | AbstractCheckedFutureTest.java | 109 startingGate.countDown(); in testCheckedGetThrowsApplicationExceptionOnInterruption()
118 successLatch.countDown(); in testCheckedGetThrowsApplicationExceptionOnInterruption()
143 latch.countDown(); in testCheckedGetThrowsApplicationExceptionOnError()
|
| /external/okhttp/okhttp-ws-tests/src/main/java/com/squareup/okhttp/ws/ |
| D | AutobahnTester.java | 110 latch.countDown(); in runTest()
115 latch.countDown(); in runTest()
148 latch.countDown(); in getTestCount()
153 latch.countDown(); in getTestCount()
183 latch.countDown(); in updateReports()
187 latch.countDown(); in updateReports()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | MoreInProcessTest.java | 118 finishLatch.countDown(); in asyncClientStreaming_serverResponsePriorToRequest()
123 finishLatch.countDown(); in asyncClientStreaming_serverResponsePriorToRequest()
177 finishLatch.countDown(); in asyncClientStreaming_serverErrorPriorToRequest()
182 finishLatch.countDown(); in asyncClientStreaming_serverErrorPriorToRequest()
236 finishLatch.countDown(); in asyncClientStreaming_erroneousServiceImpl()
241 finishLatch.countDown(); in asyncClientStreaming_erroneousServiceImpl()
|
| D | CascadingTest.java | 238 receivedCancellations.countDown(); in startChainingServer()
255 observedCancellations.countDown(); in startChainingServer()
315 observedCancellations.countDown(); in startCallTreeServer()
335 receivedCancellations.countDown(); in startCallTreeServer()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ListenableFutureTaskTest.java | 49 runLatch.countDown();
67 listenerLatch.countDown(); in setUp()
99 taskLatch.countDown(); in testListenerDoesNotRunUntilTaskCompletes()
112 taskLatch.countDown(); in testListenerCalledOnException()
|
| D | AbstractExecutionThreadServiceTest.java | 105 exitRun.countDown(); // the service will exit voluntarily in testServiceExitingOnItsOwn()
138 enterRun.countDown(); in run()
155 exitRun.countDown(); in triggerShutdown()
259 enterRun.countDown(); in testServiceThrowOnShutDown()
318 started.countDown(); in testStopWhileStarting_runNotCalled()
|
| D | JdkFutureAdaptersTest.java | 117 submitSuccessful.countDown(); in testListenInPoolThreadCustomExecutorInterrupted()
216 wasRun.countDown(); in run()
240 input.allowGetToComplete.countDown(); in testListenInPoolThreadRunsListenerAfterRuntimeException()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ChannelExecutorTest.java | 102 task1Running.countDown(); in multiThread()
124 task1Added.countDown(); in multiThread()
126 sideThreadDone.countDown(); in multiThread()
140 task1Proceed.countDown(); in multiThread()
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | MapMakerTest.java | 75 computationStarted.countDown(); in testRemovalNotification_clear()
77 computationComplete.countDown(); in testRemovalNotification_clear()
85 computingLatch.countDown(); in testRemovalNotification_clear()
146 tasksFinished.countDown(); in testRemovalNotification_clear_basher()
152 computationLatch.countDown(); in testRemovalNotification_clear_basher()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | Ping.java | 40 latch.countDown(); in receive()
46 latch.countDown(); in cancel()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | Ping.java | 42 latch.countDown(); in receive()
48 latch.countDown(); in cancel()
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ui/ |
| D | FullScreenTask.java | 87 mShowLatch.countDown(); in onCreate()
228 mLatch.countDown(); in run()
240 mLatch.countDown(); in SetList()
261 mLatch.countDown(); in run()
277 mLatch.countDown(); in run()
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheLoadingTest.java | 2106 gettersStartedSignal.countDown(); in doConcurrentGet()
2122 gettersComplete.countDown(); in doConcurrentGet()
2132 gettersStartedSignal.countDown(); in doConcurrentGet()
2153 getStartedSignal.countDown(); in testAsMapDuringLoading()
2171 getFinishedSignal.countDown(); in testAsMapDuringLoading()
2178 getFinishedSignal.countDown(); in testAsMapDuringLoading()
2190 letGetFinishSignal.countDown(); in testAsMapDuringLoading()
2212 computationStarted.countDown(); in testInvalidateDuringLoading()
2227 getFinishedSignal.countDown(); in testInvalidateDuringLoading()
2234 getFinishedSignal.countDown(); in testInvalidateDuringLoading()
[all …]
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideClient.java | 154 finishLatch.countDown(); in recordRoute()
160 finishLatch.countDown(); in recordRoute()
219 finishLatch.countDown(); in routeChat()
225 finishLatch.countDown(); in routeChat()
|
| /external/guice/core/test/com/google/inject/ |
| D | BindingOrderTest.java | 73 ready.countDown(); in testBindingWithExtraThreads()
76 done.countDown(); in testBindingWithExtraThreads()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | StreamRecorder.java | 67 latch.countDown(); in onError()
75 latch.countDown(); in onCompleted()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | StreamRecorder.java | 72 latch.countDown(); in onError()
80 latch.countDown(); in onCompleted()
|
| /external/guice/extensions/service/test/com/google/inject/service/ |
| D | SingleServiceIntegrationTest.java | 29 startLatch.countDown(); in testAsyncServiceLifecycle()
37 stopLatch.countDown(); in testAsyncServiceLifecycle()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/ |
| D | ManualFlowControlClient.java | 103 done.countDown(); in main()
109 done.countDown(); in main()
|
| /external/swiftshader/third_party/LLVM/tools/llvm-ar/ |
| D | llvm-ar.cpp | 355 unsigned countDown = Count; in doPrint() local
360 if (countDown == 1) { in doPrint()
374 countDown--; in doPrint()
490 unsigned countDown = Count; in doDelete() local
494 if (countDown == 1) { in doDelete()
499 countDown--; in doDelete()
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/ |
| D | RuntimeEnvironmentTest.java | 37 finished.countDown(); in isMainThread_forNewThread_withoutSwitch()
57 finished.countDown(); in isMainThread_forNewThread_withSwitch()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/ |
| D | ErrorHandlingClient.java | 131 latch.countDown(); in futureCallCallback()
158 latch.countDown(); in asyncCall()
191 latch.countDown(); in advancedAsyncCall()
|
| /external/webrtc/talk/app/webrtc/java/android/org/webrtc/ |
| D | ThreadUtils.java | 172 barrier.countDown(); in invokeUninterruptibly()
187 barrier.countDown(); in invokeUninterruptibly()
|
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| D | GcFinalization.java | 194 new Object() { @Override protected void finalize() { latch.countDown(); }}; in createUnreachableLatchFinalizer()
288 @Override protected void finalize() { finalizerRan.countDown(); } in awaitFullGc()
|