| /external/sdk-platform-java/gax-java/gax-httpjson/src/test/java/com/google/api/gax/httpjson/ |
| D | HttpJsonDirectServerStreamingCallableTest.java | 180 CountDownLatch latch = new CountDownLatch(1); in testBadContext() local
196 CountDownLatch latch = new CountDownLatch(1); in testServerStreamingStart() local
212 CountDownLatch latch = new CountDownLatch(3); in testServerStreaming() local
226 CountDownLatch latch = new CountDownLatch(2); in testManualFlowControl() local
246 CountDownLatch latch = new CountDownLatch(1); in testCancelClientCall() local
263 CountDownLatch latch = new CountDownLatch(1); in testOnResponseError() local
341 CountDownLatch latch = new CountDownLatch(1); in testDeadlineExceededServerStreaming() local
357 private final CountDownLatch latch; field in HttpJsonDirectServerStreamingCallableTest.MoneyObserver
364 MoneyObserver(boolean autoFlowControl, CountDownLatch latch) { in MoneyObserver()
|
| /external/sdk-platform-java/gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/ |
| D | GrpcDirectServerStreamingCallableTest.java | 119 CountDownLatch latch = new CountDownLatch(1); in testBadContext() local
133 CountDownLatch latch = new CountDownLatch(1); in testServerStreamingStart() local
143 CountDownLatch latch = new CountDownLatch(2); in testServerStreaming() local
155 CountDownLatch latch = new CountDownLatch(2); in testManualFlowControl() local
174 CountDownLatch latch = new CountDownLatch(1); in testCancelClientCall() local
189 CountDownLatch latch = new CountDownLatch(1); in testOnResponseError() local
254 private final CountDownLatch latch; field in GrpcDirectServerStreamingCallableTest.MoneyObserver
261 MoneyObserver(boolean autoFlowControl, CountDownLatch latch) { in MoneyObserver()
|
| D | GrpcDirectStreamingCallableTest.java | 95 CountDownLatch latch = new CountDownLatch(1); in testBidiStreaming() local
117 CountDownLatch latch = new CountDownLatch(1); in testBidiStreamingServerError() local
140 CountDownLatch latch = new CountDownLatch(1); in testBidiStreamingClientError() local
167 CountDownLatch latch = new CountDownLatch(1); in testClientStreaming() local
186 CountDownLatch latch; field in GrpcDirectStreamingCallableTest.MoneyObserver
188 MoneyObserver(CountDownLatch latch) { in MoneyObserver()
|
| /external/desugar/test/java/com/google/devtools/build/android/desugar/runtime/ |
| D | ConcurrentWeakIdentityHashMapTest.java | 51 testConcurrentWeakIdentityHashMapSingleThreadedHelper(CountDownLatch latch) in testConcurrentWeakIdentityHashMapSingleThreadedHelper()
86 CountDownLatch latch = new CountDownLatch(5); in testSingleThreadedUse() local
99 int numMainExceptions, int numSuppressedPerMain, CountDownLatch latch) { in createExceptionWithSuppressed()
115 int numMainExceptions, int numSuppressedPerMain, CountDownLatch latch) in testFunctionalCorrectnessForMultiThreadedUse()
162 CountDownLatch latch = new CountDownLatch(numMainExceptions * numSuppressedPerMain); in testMultiThreadedUse() local
201 private final CountDownLatch latch; field in ConcurrentWeakIdentityHashMapTest.ExceptionWithLatch
203 private ExceptionWithLatch(String message, CountDownLatch latch) { in ExceptionWithLatch()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | CoroutineSchedulerTest.kt | 21 val latch = CountDownLatch(1) in <lambda>() constant
34 val latch = CountDownLatch(taskModes.size) in <lambda>() constant
125 val latch = CountDownLatch(1) in <lambda>() constant
136 var latch = CountDownLatch(1) in <lambda>() variable
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/flow/ |
| D | FlowCancellationTest.kt | 16 val latch = Channel<Unit>(1) in <lambda>() constant
33 val latch = Channel<Unit>(1) in <lambda>() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | FlatMapMergeBaseTest.kt | 37 val latch = Channel<Unit>() in testConcurrentFailure() constant
67 val latch = Channel<Unit>() in <lambda>() constant
|
| D | FilterTest.kt | 29 val latch = Channel<Unit>() in <lambda>() constant
64 val latch = Channel<Unit>() in <lambda>() constant
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/ |
| D | ErrorHandlingClient.java | 117 final CountDownLatch latch = new CountDownLatch(1); in futureCallCallback() local
146 final CountDownLatch latch = new CountDownLatch(1); in asyncCall() local
184 final CountDownLatch latch = new CountDownLatch(1); in advancedAsyncCall() local
|
| D | DetailErrorSample.java | 144 final CountDownLatch latch = new CountDownLatch(1); in futureCallCallback() local
170 final CountDownLatch latch = new CountDownLatch(1); in asyncCall() local
205 final CountDownLatch latch = new CountDownLatch(1); in advancedAsyncCall() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/terminal/ |
| D | FirstTest.kt | 37 val latch = Channel<Unit>() in <lambda>() constant
66 val latch = Channel<Unit>() in <lambda>() constant
104 val latch = Channel<Unit>() in <lambda>() constant
139 val latch = Channel<Unit>() in <lambda>() constant
|
| /external/okhttp/okhttp-ws-tests/src/main/java/com/squareup/okhttp/ws/ |
| D | AutobahnTester.java | 71 final CountDownLatch latch = new CountDownLatch(1); in runTest() local
132 final CountDownLatch latch = new CountDownLatch(1); in getTestCount() local
171 final CountDownLatch latch = new CountDownLatch(1); in updateReports() local
|
| /external/apache-commons-lang/src/test/java/org/apache/commons/lang3/concurrent/ |
| D | TimedSemaphoreTest.java | 215 final CountDownLatch latch = new CountDownLatch(count - 1); in testAcquireLimit() local
289 final CountDownLatch latch = new CountDownLatch(count); in testAcquireNoLimit() local
320 final CountDownLatch latch = new CountDownLatch(count); in testAcquireMultiplePeriods() local
384 final CountDownLatch latch = new CountDownLatch(1); in testTryAcquire() local
420 volatile CountDownLatch latch; field in TimedSemaphoreTest.TimedSemaphoreTestImpl
487 private final CountDownLatch latch; field in TimedSemaphoreTest.SemaphoreThread
532 private final CountDownLatch latch; field in TimedSemaphoreTest.TryAcquireThread
|
| /external/grpc-grpc/test/core/promise/ |
| D | latch_test.cc | 35 Latch<int> latch; in TEST() local
55 Latch<std::string> latch; in TEST() local
82 Latch<void> latch; in TEST() local
99 ExternallyObservableLatch<void> latch; in TEST() local
|
| /external/dagger2/javatests/artifacts/hilt-android/simple/app/src/androidTest-agp-4.2.0/java/dagger/hilt/android/simple/ |
| D | BroadcastReceiverTest.java | 116 final CountDownLatch latch = new CountDownLatch(1); field in BroadcastReceiverTest.TestReceiverOne
131 final CountDownLatch latch = new CountDownLatch(1); field in BroadcastReceiverTest.TestReceiverTwo
146 final CountDownLatch latch = new CountDownLatch(1); field in BroadcastReceiverTest.TestReceiverThree
162 final CountDownLatch latch = new CountDownLatch(1); field in BroadcastReceiverTest.TestReceiverFour
|
| /external/aws-sdk-java-v2/core/aws-core/src/test/java/software/amazon/awssdk/awscore/eventstream/ |
| D | EventStreamAsyncResponseTransformerTest.java | 53 CountDownLatch latch = new CountDownLatch(1); in multipleEventsInChunk_OnlyDeliversOneEvent() local
105 CountDownLatch latch = new CountDownLatch(1); in devilSubscriber_requestDataAfterComplete() local
189 CountDownLatch latch = new CountDownLatch(2); in prepareResetsSubscriberRef() local
261 CountDownLatch latch = new CountDownLatch(1); in erroneousExceptionOccurredAfterCompleteDoesNotSurfaceException() local
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | IterableFlowTckTest.kt | 48 val latch = CountDownLatch(1) in testStackOverflowTrampoline() constant
83 val latch = CountDownLatch(1) in testConcurrentRequest() constant
|
| /external/dagger2/javatests/dagger/internal/ |
| D | DoubleCheckTest.java | 79 final CountDownLatch latch = new CountDownLatch(numThreads); in get() local
104 final CountDownLatch latch; field in DoubleCheckTest.LatchedProvider
106 LatchedProvider(CountDownLatch latch) { in LatchedProvider()
|
| /external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowPausedSystemClockTest.java | 53 CountDownLatch latch = new CountDownLatch(2); in sleep_concurrentAccess() local
99 CountDownLatch latch = new CountDownLatch(numToExecute); in deepSleep_concurrentAccess_doesNotCorruptData() local
143 CountDownLatch latch = new CountDownLatch(2); in setCurrentTimeMillis_concurrentAccess() local
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/http/timers/ |
| D | SyncTimeoutTaskTest.java | 41 CountDownLatch latch = new CountDownLatch(1); in taskInProgress_hasExecutedReturnsTrue() local
64 CountDownLatch latch = new CountDownLatch(1); in taskInProgress_cancelCalled_abortableIsNotInterrupted() local
|
| /external/tensorflow/tensorflow/core/tfrt/runtime/ |
| D | tf_threadpool_concurrent_work_queue_test.cc | 68 tfrt::latch latch(10); in TEST_F() local
86 tfrt::latch latch(10); in TEST_F() local
103 tfrt::latch latch(20); in TEST_F() local
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableSourceAsFlowStressTest.kt | 26 val latch = Channel<Unit>(1) in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableSourceAsFlowStressTest.kt | 27 val latch = Channel<Unit>(1) in <lambda>() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ReusableCancellableContinuationInvariantStressTest.kt | 29 val latch = CountDownLatch(1) in doTest() constant
|
| /external/guava/android/guava-testlib/src/com/google/common/testing/ |
| D | GcFinalization.java | 198 public static void await(CountDownLatch latch) { in await()
226 private static void createUnreachableLatchFinalizer(CountDownLatch latch) { in createUnreachableLatchFinalizer()
|