| /external/pigweed/pw_transfer/java/test/dev/pigweed/pw_transfer/ |
| D | TransferClientTest.java | 79 ListenableFuture<byte[]> future = transferClient.read(1); in legacy_read_singleChunk_successful() local
93 ListenableFuture<byte[]> future = transferClient.read(1, TRANSFER_PARAMETERS); in legacy_read_failedPreconditionError_retriesInitialPacket() local
113 ListenableFuture<byte[]> future = transferClient.read(1, params); in legacy_read_failedPreconditionError_abortsAfterInitialPacket() local
137 ListenableFuture<byte[]> future = transferClient.read(1, TRANSFER_PARAMETERS); in legacy_read_failedPreconditionErrorMaxRetriesTimes_aborts() local
159 ListenableFuture<byte[]> future = transferClient.read(1); in legacy_read_singleChunk_ignoresUnknownIdOrWriteChunks() local
194 ListenableFuture<byte[]> future = transferClient.read(2); in legacy_read_empty() local
208 ListenableFuture<byte[]> future = transferClient.read(99, params); in legacy_read_sendsTransferParametersFirst() local
217 ListenableFuture<byte[]> future = transferClient.read(123, TRANSFER_PARAMETERS); in legacy_read_severalChunks() local
258 ListenableFuture<byte[]> future = in legacy_read_progressCallbackIsCalled() local
292 ListenableFuture<byte[]> future = transferClient.read(123, TRANSFER_PARAMETERS); in legacy_read_rewindWhenPacketsSkipped() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/jdk8/future/ |
| D | AsFutureTest.kt | 23 val future = deferred.asCompletableFuture() in <lambda>() constant
31 val future = job.asCompletableFuture() in <lambda>() constant
43 val future = deferred.asCompletableFuture() in <lambda>() constant
51 val future = job.asCompletableFuture() in testWaitForJobAsCompletableFuture() constant
61 val future = deferred.asCompletableFuture() in testAsCompletableFutureThrowable() constant
77 val future = job.asCompletableFuture() in testJobAsCompletableFutureThrowable() constant
92 val future = job.asCompletableFuture() in testJobAsCompletableFutureCancellation() constant
107 val future = job.asCompletableFuture() in testJobCancellation() constant
117 val future = deferred.asCompletableFuture() in testDeferredCancellation() constant
|
| D | FutureTest.kt | 28 val future = GlobalScope.future { in testSimpleAwait() constant
40 val future = GlobalScope.future { in testCompletedFuture() constant
51 val future = GlobalScope.future { in testCompletedCompletionStage() constant
60 val future = GlobalScope.future { in testWaitForFuture() constant
72 val future = GlobalScope.future { in testWaitForCompletionStage() constant
84 val future = GlobalScope.future { in testCompletedFutureExceptionally() constant
100 val future = GlobalScope.future { in testCompletedCompletionStageExceptionally() constant
115 val future = future(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
136 val future = GlobalScope.future { in testWaitForCompletionStageWithException() constant
150 val future = GlobalScope.future { in testExceptionInsideCoroutine() constant
[all …]
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/test/ |
| D | ListenableFutureTest.kt | 26 val future = GlobalScope.future { in testSimpleAwait() constant
36 val future = SettableFuture.create<Int>() in <lambda>() constant
49 val future = SettableFuture.create<Int>() constant
65 val future = GlobalScope.future { in testCompletedFuture() constant
74 val future = GlobalScope.future { in testWaitForFuture() constant
86 val future = GlobalScope.future { in testCompletedFutureExceptionally() constant
100 val future = GlobalScope.future { in testWaitForFutureWithException() constant
116 val future = GlobalScope.future { in testExceptionInsideCoroutine() constant
150 val future = deferred.asListenableFuture() in <lambda>() constant
163 val future = deferred.asListenableFuture() in <lambda>() constant
[all …]
|
| /external/cronet/base/test/ |
| D | repeating_test_future_unittest.cc | 50 RepeatingTestFuture<std::string> future; in TEST_F() local
56 RepeatingTestFuture<std::string> future; in TEST_F() local
64 RepeatingTestFuture<std::string> future; in TEST_F() local
74 RepeatingTestFuture<std::string> future; in TEST_F() local
84 RepeatingTestFuture<std::string> future; in TEST_F() local
94 RepeatingTestFuture<std::string> future; in TEST_F() local
105 RepeatingTestFuture<std::string> future; in TEST_F() local
116 RepeatingTestFuture<std::string> future; in TEST_F() local
130 static RepeatingTestFuture<std::string> future; in TEST_F() local
138 RepeatingTestFuture<std::string> future; in TEST_F() local
[all …]
|
| D | test_future_unittest.cc | 68 TestFuture<int> future; in TEST_F() local
79 TestFuture<int> future; in TEST_F() local
95 static TestFuture<AnyType> future; in TEST_F() local
104 TestFuture<int> future; in TEST_F() local
117 TestFuture<AnyType> future; in TEST_F() local
124 TestFuture<MoveOnlyValue> future; in TEST_F() local
136 TestFuture<AnyType> future; in TEST_F() local
142 TestFuture<AnyType> future; in TEST_F() local
152 TestFuture<AnyType> future; in TEST_F() local
162 TestFuture<int> future; in TEST_F() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jdk8/src/future/ |
| D | Future.kt | 34 public fun <T> CoroutineScope.future( in <lambda>() method
41 val future = CompletableFuture<T>() in <lambda>() constant
50 private val future: CompletableFuture<T> constant
75 val future = CompletableFuture<T>() in asCompletableFuture() constant
92 val future = CompletableFuture<Unit>() in asCompletableFuture() constant
117 val future = toCompletableFuture() // retrieve the future in asDeferred() constant
161 val future = toCompletableFuture() // retrieve the future in await() constant
|
| /external/dagger2/javatests/dagger/producers/internal/ |
| D | ProducersTest.java | 42 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureProduced_success() local
49 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureProduced_failure() local
59 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelPropagatesBackwards() local
67 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelDoesNotPropagateForwards() local
87 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureSingletonSet_success() local
94 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureSingletonSet_failure() local
107 ListenableFuture<Set<String>> future = in allAsSet_success() local
117 ListenableFuture<Set<String>> future = in allAsSet_failure() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractFutureTest.java | 69 AbstractFuture<String> future = in testException() local
90 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local
106 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local
122 AbstractFuture<String> future = in testCancel_done() local
134 AbstractFuture<String> future = in testGetWithTimeoutDoneFuture() local
164 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_interruption() local
188 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_polling() local
217 SettableFuture<Object> future = SettableFuture.create(); in testToString_oom() local
380 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local
579 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testFutureBash() local
[all …]
|
| D | UninterruptibleFutureTest.java | 182 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest() local
190 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest() local
197 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest()
214 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck() local
231 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted() local
243 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted() local
254 final Future<?> future, final boolean allowInterruption) { in untimedInterruptReporter()
|
| D | TestPlatform.java | 38 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture()
49 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture()
71 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload()
72 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
| D | FuturesTest.java | 136 ListenableFuture<String> future = immediateFuture(DATA1); in testImmediateFuture() local
153 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture() local
173 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture_cancellationException() local
193 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureBasic() local
199 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureStack() local
|
| D | SettableFutureTest.java | 34 private SettableFuture<String> future; field in SettableFutureTest
82 SettableFuture<Integer> future = SettableFuture.create(); in testCreate() local
88 SettableFuture<Integer> future = SettableFuture.create(); in testSetValue_simpleThreaded() local
101 SettableFuture<Object> future = SettableFuture.create(); in testSetException() local
120 SettableFuture<String> future = SettableFuture.create(); in testSetFuture() local
147 SettableFuture<Foo> future = SettableFuture.create(); in testSetFuture_genericsHierarchy() local
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractFutureTest.java | 69 AbstractFuture<String> future = in testException() local
90 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local
106 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local
122 AbstractFuture<String> future = in testCancel_done() local
134 AbstractFuture<String> future = in testGetWithTimeoutDoneFuture() local
164 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_interruption() local
188 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_polling() local
217 SettableFuture<Object> future = SettableFuture.create(); in testToString_oom() local
380 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local
579 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testFutureBash() local
[all …]
|
| D | UninterruptibleFutureTest.java | 182 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest() local
190 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest() local
197 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest()
214 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck() local
231 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted() local
243 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted() local
254 final Future<?> future, final boolean allowInterruption) { in untimedInterruptReporter()
|
| D | TestPlatform.java | 38 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture()
49 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture()
71 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload()
72 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
| D | FuturesTest.java | 136 ListenableFuture<String> future = immediateFuture(DATA1); in testImmediateFuture() local
153 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture() local
173 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture_cancellationException() local
193 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureBasic() local
199 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureStack() local
|
| D | SettableFutureTest.java | 34 private SettableFuture<String> future; field in SettableFutureTest
82 SettableFuture<Integer> future = SettableFuture.create(); in testCreate() local
88 SettableFuture<Integer> future = SettableFuture.create(); in testSetValue_simpleThreaded() local
101 SettableFuture<Object> future = SettableFuture.create(); in testSetException() local
120 SettableFuture<String> future = SettableFuture.create(); in testSetFuture() local
147 SettableFuture<Foo> future = SettableFuture.create(); in testSetFuture_genericsHierarchy() local
|
| /external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/robotests/ |
| D | BothProfilesListenableFutureTest.java | 108 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_blockingMethod_blocks() local
120 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_nonblockingMethod_doesNotBlock() local
132 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_nonblockingMethod_doesCallback() local
184 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_isBound_becomesUnbound_callbackFires() local
197 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_profilesWithExceptionsAreNotIncludedInResults() local
209 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_connectionDropsDuringCall_resultContainsOnlyCurrentProfilesResult() local
227 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_doesNotTimeout() local
|
| D | BothProfilesManualListenableFutureTest.java | 110 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_blockingMethod_blocks() local
123 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_nonblockingMethod_doesNotBlock() local
136 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_nonblockingMethod_doesCallback() local
193 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_becomesUnbound_callbackFires() local
207 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_profilesWithExceptionsAreNotIncludedInResults() local
220 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_manualConnection_connectionDropsDuringCall_resultContainsOnlyCurrentProfilesResult() local
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientHandlerTest.java | 261 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceShouldSucceed() local
274 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceDifferentReasons() local
283 ChannelFuture future in sendFrameShouldSucceed() local
295 ChannelFuture future in sendForUnknownStreamShouldFail() local
331 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldCancelBufferedStream() local
342 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldRefuseLaterStreamId() local
350 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldNotAffectEarlyStreamId() local
361 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithRefuseCode() local
369 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithCanceCode() local
392 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldFailUnknownBufferedStreams() local
[all …]
|
| /external/guava/guava-gwt/test-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ |
| D | TestPlatform.java | 30 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture()
40 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture()
58 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload()
59 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 345 final ListenableFuture<? extends V> future; field in AbstractFuture.SetFuture
347 SetFuture(AbstractFuture<V> owner, ListenableFuture<? extends V> future) { in SetFuture()
844 protected boolean setFuture(ListenableFuture<? extends V> future) { in setFuture()
894 private static Object getFutureValue(ListenableFuture<?> future) { in getFutureValue()
974 private static <V extends @Nullable Object> V getUninterruptibly(Future<V> future) in getUninterruptibly()
995 AbstractFuture<?> future = param; in complete() local
1291 AbstractFuture<?> future, @CheckForNull Waiter expect, @CheckForNull Waiter update); in casWaiters()
1295 AbstractFuture<?> future, @CheckForNull Listener expect, Listener update); in casListeners()
1298 abstract Waiter gasWaiters(AbstractFuture<?> future, Waiter update); in gasWaiters()
1301 abstract Listener gasListeners(AbstractFuture<?> future, Listener update); in gasListeners()
[all …]
|
| /external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | JimfsAsynchronousFileChannelTest.java | 127 Future<Integer> future = channel.write(ByteBuffer.allocate(10), 0); in testAsyncClose_write() local
161 Future<Integer> future = channel.read(ByteBuffer.allocate(10), 0); in testAsyncClose_read() local
190 SettableFuture<Integer> future = SettableFuture.create(); in checkAsyncRead() local
201 SettableFuture<Integer> future = SettableFuture.create(); in checkAsyncWrite() local
211 SettableFuture<FileLock> future = SettableFuture.create(); in checkAsyncLock() local
221 private static <T> CompletionHandler<T, Object> setFuture(final SettableFuture<T> future) { in setFuture()
|
| /external/perfetto/src/base/threading/ |
| D | future_unittest.cc | 50 base::Future<int> future(std::move(int_pollable)); in TEST_F() local
62 base::Future<int> future(std::move(int_pollable)); in TEST_F() local
68 base::Future<int> future(100); in TEST_F() local
73 auto future = base::Future<int>(100).ContinueWith( in TEST_F() local
79 auto future = base::Future<int>(100).ContinueWith([](int res) { in TEST_F() local
95 auto future = in TEST_F() local
|