| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | JobHandlersUpgradeStressTest.kt | 46 repeat(rnd.nextInt(3000)) { sink.incrementAndGet() } in <lambda>()
50 inters.incrementAndGet() in <lambda>()
63 repeat(rnd.nextInt(1000)) { sink.incrementAndGet() } in <lambda>()
70 repeat(rnd.nextInt(1000)) { sink.incrementAndGet() } in <lambda>()
76 0 -> removed.incrementAndGet() in <lambda>()
77 1 -> fired.incrementAndGet() in <lambda>()
|
| D | RunInterruptibleStressTest.kt | 31 enterCount.incrementAndGet() in <lambda>()
36 interruptedCount.incrementAndGet() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/internal/ |
| D | LockFreeLinkedListShortStressTest.kt | 54 undone.incrementAndGet() in <lambda>()
58 missed.incrementAndGet() in <lambda>()
62 completedAdder.incrementAndGet() in <lambda>()
69 if (node != null) removed.incrementAndGet() in <lambda>()
72 completedRemover.incrementAndGet() in <lambda>()
|
| D | LockFreeLinkedListAtomicLFStressTest.kt | 46 val node = Node(index.incrementAndGet()) in <lambda>()
54 val node = Node(index.incrementAndGet()) in <lambda>()
62 val node = Node(index.incrementAndGet()) in <lambda>()
72 val node1 = Node(index.incrementAndGet()) in <lambda>()
73 val node2 = Node(index.incrementAndGet()) in <lambda>()
144 undone.incrementAndGet() in <lambda>()
146 missed.incrementAndGet() in <lambda>()
|
| D | LockFreeTaskQueueStressTest.kt | 71 consumed.incrementAndGet() in <lambda>()
90 if (batch.incrementAndGet() >= batchSize) break in <lambda>()
92 produced.incrementAndGet() in <lambda>()
94 doneProducers.incrementAndGet() in <lambda>()
|
| D | LockFreeLinkedListAddRemoveStressTest.kt | 28 if (node.remove()) removed.incrementAndGet() in testStressAddRemove()
32 if (node != null) removed.incrementAndGet() in testStressAddRemove()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ConflatedBroadcastChannelNotifyStressTest.kt | 33 sentTotal.incrementAndGet() in <lambda>()
37 sendersCompleted.incrementAndGet() in <lambda>()
46 receivedTotal.incrementAndGet() in <lambda>()
52 receiversCompleted.incrementAndGet() in <lambda>()
|
| D | ChannelSendReceiveStressTest.kt | 68 receiversCompleted.incrementAndGet() in <lambda>()
77 sendersCompleted.incrementAndGet() in <lambda>()
118 sentTotal.incrementAndGet() in <lambda>()
142 dupes.incrementAndGet() in <lambda>()
144 receivedTotal.incrementAndGet() in <lambda>()
|
| D | ConflatedChannelCloseStressTest.kt | 43 sent.incrementAndGet() in <lambda>()
58 closed.incrementAndGet() in <lambda>()
68 received.incrementAndGet() in <lambda>()
|
| D | InvokeOnCloseStressTest.kt | 52 channel.invokeOnClose { counter.incrementAndGet() } in runStressTest()
57 channel.invokeOnClose { counter.incrementAndGet() } in runStressTest()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | BlockingCoroutineDispatcherLivenessStressTest.kt | 35 val currentlyExecuting = concurrentWorkers.incrementAndGet() in <lambda>()
55 concurrentWorkers.incrementAndGet() in <lambda>()
57 completed.incrementAndGet() in <lambda>()
|
| D | BlockingCoroutineDispatcherThreadLimitStressTest.kt | 32 val currentlyExecuting = concurrentWorkers.incrementAndGet() in <lambda>()
56 val currentlyExecuting = concurrentWorkers.incrementAndGet() in <lambda>()
|
| /external/kotlinx.atomicfu/atomicfu/src/commonTest/kotlin/kotlinx/atomicfu/test/ |
| D | TopLevelTest.kt | 42 check(a.incrementAndGet() == 8) in <lambda>()
56 check(b.incrementAndGet() == 8924920024888888849) in <lambda>()
64 check(b.incrementAndGet() == -198452011965886958) in <lambda>()
128 check(longArr[4].incrementAndGet() == 8924920024888888849) in testLongArray()
139 check(longArr[1].incrementAndGet() == -198452011965886958) in testLongArray()
|
| D | MultiInitTest.kt | 25 fun incA() = a.incrementAndGet() in incA()
26 fun incB() = b.incrementAndGet() in incA()
|
| D | ArithmeticTest.kt | 30 check(a._x.incrementAndGet() == 8) in testInt()
45 check(a.z.incrementAndGet() == 8924920024888888849) in testLong()
53 check(a.z.incrementAndGet() == -198452011965886958) in testLong()
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | StreamsTest.java | 91 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated()
102 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated_Stream_concat()
114 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated_Stream_flatMap()
239 Stream<String> strings = source.onClose(stringsCloseCount::incrementAndGet); in testMapWithIndex_closeIsPropagated()
264 IntStream intStream = source.onClose(intStreamCloseCount::incrementAndGet); in testMapWithIndex_intStream_closeIsPropagated()
289 LongStream longStream = source.onClose(longStreamCloseCount::incrementAndGet); in testMapWithIndex_longStream_closeIsPropagated()
316 DoubleStream doubleStream = source.onClose(doubleStreamCloseCount::incrementAndGet); in testMapWithIndex_doubleStream_closeIsPropagated()
332 Stream<String> letters = Stream.of("a", "b", "c").onClose(lettersCloseCount::incrementAndGet); in testZip_closeIsPropagated()
334 Stream<Integer> numbers = Stream.of(1, 2, 3).onClose(numbersCloseCount::incrementAndGet); in testZip_closeIsPropagated()
415 count.incrementAndGet(); in testForEachPair_parallel()
|
| /external/guice/jdk8-tests/test/com/google/inject/jdk8/ |
| D | DefaultMethodInterceptionTest.java | 46 interceptedCallCount.incrementAndGet();
64 callCount.incrementAndGet(); in defaultMethod()
115 callCount.incrementAndGet(); in defaultMethod()
149 callCount.incrementAndGet(); in defaultMethod()
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/mediacodec/ |
| D | DedicatedThreadAsyncMediaCodecAdapterTest.java | 84 if (codecStartCalls.incrementAndGet() == 2) { in dequeueInputBufferIndex_withAfterFlushFailed_throwsException()
152 if (codecStartCalls.incrementAndGet() == 2) { in dequeueOutputBufferIndex_withInternalException_throwsException()
271 adapter.setCodecStartRunnable(() -> codecStartCalls.incrementAndGet()); in flush_multipleTimes_onlyLastFlushExecutes()
279 handler.post(() -> milestoneCount.incrementAndGet()); in flush_multipleTimes_onlyLastFlushExecutes()
300 adapter.setCodecStartRunnable(() -> onCodecStartCount.incrementAndGet()); in flush_andImmediatelyShutdown_flushIsNoOp()
324 INSTANCES_STARTED.incrementAndGet(); in start()
|
| D | MultiLockAsyncMediaCodecAdapterTest.java | 82 if (codecStartCalls.incrementAndGet() == 2) { in dequeueInputBufferIndex_withAfterFlushFailed_throwsException()
152 if (codecStartCalls.incrementAndGet() == 2) { in dequeueOutputBufferIndex_withInternalException_throwsException()
269 adapter.setCodecStartRunnable(() -> codecStartCalls.incrementAndGet()); in flush_multipleTimes_onlyLastFlushExecutes()
277 handler.post(() -> milestoneCount.incrementAndGet()); in flush_multipleTimes_onlyLastFlushExecutes()
297 adapter.setCodecStartRunnable(() -> codecStartCalls.incrementAndGet()); in flush_andImmediatelyShutdown_flushIsNoOp()
321 INSTANCES_STARTED.incrementAndGet(); in start()
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheLoaderTest.java | 60 loadCount.incrementAndGet(); in testAsyncReload()
66 reloadCount.incrementAndGet(); in testAsyncReload()
72 loadAllCount.incrementAndGet(); in testAsyncReload()
|
| D | TestingCacheLoaders.java | 105 count.incrementAndGet();
139 countLoad.incrementAndGet();
146 countReload.incrementAndGet();
|
| /external/desugar/test/java/com/google/devtools/build/android/desugar/ |
| D | DesugarObjectsRequireNonNullTest.java | 61 counterForSingleArgument.incrementAndGet(); in testClassCallingRequireNonNullHasNoReferenceToRequiresNonNull()
64 counterForString.incrementAndGet(); in testClassCallingRequireNonNullHasNoReferenceToRequiresNonNull()
67 counterForSupplier.incrementAndGet(); in testClassCallingRequireNonNullHasNoReferenceToRequiresNonNull()
|
| /external/guava/android/guava-tests/test/com/google/common/cache/ |
| D | CacheLoaderTest.java | 60 loadCount.incrementAndGet(); in testAsyncReload()
66 reloadCount.incrementAndGet(); in testAsyncReload()
72 loadAllCount.incrementAndGet(); in testAsyncReload()
|
| D | TestingCacheLoaders.java | 105 count.incrementAndGet();
139 countLoad.incrementAndGet();
146 countReload.incrementAndGet();
|
| /external/dagger2/javatests/dagger/functional/cycle/ |
| D | DoubleCheckCycleTest.java | 112 if (callCount.incrementAndGet() == 1) { in testReentrant()
140 if (callCount.incrementAndGet() == 1) { in testFailingReentrant()
174 callCount.incrementAndGet(); in testGetFromMultipleThreads()
195 requestCount.incrementAndGet(); in testGetFromMultipleThreads()
|