Home
last modified time | relevance | path

Searched refs:setFuture (Results 1 – 25 of 40) sorted by relevance

12

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractAbstractFutureTest.java81 assertThat(future.setFuture(delegate)).isTrue(); in testSetFuturePending()
86 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureThenCancel()
93 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureThenInterrupt()
101 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateAlreadySuccessful()
106 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateLaterSuccessful()
116 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateAlreadyCancelled()
121 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateLaterCancelled()
134 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateAlreadyInterrupted()
139 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateLaterInterrupted()
193 future.setFuture(delegate); in testListenLaterSetAsynchronously()
[all …]
DSettableFutureTest.java93 assertFalse(future.setFuture(SettableFuture.<Integer>create())); in testSetValue_simpleThreaded()
107 assertFalse(future.setFuture(SettableFuture.create())); in testSetException()
122 assertTrue(future.setFuture(nested)); in testSetFuture()
126 assertFalse(future.setFuture(SettableFuture.<String>create())); in testSetFuture()
149 assertTrue(future.setFuture(nested)); in testSetFuture_genericsHierarchy()
153 assertFalse(future.setFuture(SettableFuture.<Foo>create())); in testSetFuture_genericsHierarchy()
173 async.setFuture(inner); in testCancel_innerCancelsAsync()
187 async.setFuture(inner); in testCancel_resultCancelsInner_interrupted()
202 async.setFuture(inner); in testCancel_resultCancelsInner()
225 assertFalse(async.setFuture(inner)); in testCancel_multipleBeforeSetFuture_noInterruptFirst()
[all …]
DAbstractFutureTest.java154 normalFuture.setFuture(evilFuture); in testEvilFuture_setFuture()
344 testFuture3.setFuture(testFuture2); in testToString_completed()
479 if (currentFuture.get().setFuture(future)) { in testFutureBash()
493 if (currentFuture.get().setFuture(future)) { in testFutureBash()
506 if (currentFuture.get().setFuture(future)) { in testFutureBash()
636 setFutureSetSuccess.set(currentFuture.get().setFuture(future)); in testSetFutureCancelBash()
703 final AbstractFuture<String> setFuture = new AbstractFuture<String>() {}; in testSetFutureCancelBash() local
705 setFutureFuture.set(setFuture); in testSetFutureCancelBash()
724 assertTrue(setFuture.isCancelled()); in testSetFutureCancelBash()
725 assertTrue(setFuture.wasInterrupted()); // we only call cancel(true) in testSetFutureCancelBash()
[all …]
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAbstractAbstractFutureTest.java81 assertThat(future.setFuture(delegate)).isTrue(); in testSetFuturePending()
86 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureThenCancel()
93 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureThenInterrupt()
101 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateAlreadySuccessful()
106 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateLaterSuccessful()
116 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateAlreadyCancelled()
121 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateLaterCancelled()
134 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateAlreadyInterrupted()
139 assertThat(future.setFuture(delegate)).isTrue(); in testSetFutureDelegateLaterInterrupted()
193 future.setFuture(delegate); in testListenLaterSetAsynchronously()
[all …]
DSettableFutureTest.java93 assertFalse(future.setFuture(SettableFuture.<Integer>create())); in testSetValue_simpleThreaded()
107 assertFalse(future.setFuture(SettableFuture.create())); in testSetException()
122 assertTrue(future.setFuture(nested)); in testSetFuture()
126 assertFalse(future.setFuture(SettableFuture.<String>create())); in testSetFuture()
149 assertTrue(future.setFuture(nested)); in testSetFuture_genericsHierarchy()
153 assertFalse(future.setFuture(SettableFuture.<Foo>create())); in testSetFuture_genericsHierarchy()
173 async.setFuture(inner); in testCancel_innerCancelsAsync()
187 async.setFuture(inner); in testCancel_resultCancelsInner_interrupted()
202 async.setFuture(inner); in testCancel_resultCancelsInner()
225 assertFalse(async.setFuture(inner)); in testCancel_multipleBeforeSetFuture_noInterruptFirst()
[all …]
DAbstractFutureTest.java154 normalFuture.setFuture(evilFuture); in testEvilFuture_setFuture()
344 testFuture3.setFuture(testFuture2); in testToString_completed()
479 if (currentFuture.get().setFuture(future)) { in testFutureBash()
493 if (currentFuture.get().setFuture(future)) { in testFutureBash()
506 if (currentFuture.get().setFuture(future)) { in testFutureBash()
636 setFutureSetSuccess.set(currentFuture.get().setFuture(future)); in testSetFutureCancelBash()
703 final AbstractFuture<String> setFuture = new AbstractFuture<String>() {}; in testSetFutureCancelBash() local
705 setFutureFuture.set(setFuture); in testSetFutureCancelBash()
724 assertTrue(setFuture.isCancelled()); in testSetFutureCancelBash()
725 assertTrue(setFuture.wasInterrupted()); // we only call cancel(true) in testSetFutureCancelBash()
[all …]
/external/dagger2/javatests/dagger/producers/internal/
DProducersTest.java88 ListenableFuture<Set<String>> setFuture = Producers.createFutureSingletonSet(future); in createFutureSingletonSet_success() local
89 assertThat(setFuture.isDone()).isTrue(); in createFutureSingletonSet_success()
90 assertThat(setFuture.get()).containsExactly("monkey"); in createFutureSingletonSet_success()
95 ListenableFuture<Set<String>> setFuture = Producers.createFutureSingletonSet(future); in createFutureSingletonSet_failure() local
96 assertThat(setFuture.isDone()).isTrue(); in createFutureSingletonSet_failure()
98 setFuture.get(); in createFutureSingletonSet_failure()
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/duration/
DPeriod.java129 return setFuture(true); in inFuture()
138 return setFuture(false); in inPast()
149 return setFuture(future); in inFuture()
160 return setFuture(!past); in inPast()
347 private Period setFuture(boolean future) { in setFuture() method in Period
/external/icu/android_icu4j/src/main/java/android/icu/impl/duration/
DPeriod.java131 return setFuture(true); in inFuture()
140 return setFuture(false); in inPast()
151 return setFuture(future); in inFuture()
162 return setFuture(!past); in inPast()
349 private Period setFuture(boolean future) { in setFuture() method in Period
/external/dagger2/java/dagger/producers/internal/
DAbstractProducer.java39 future.setFuture(compute()); in get()
101 public boolean setFuture(ListenableFuture<? extends T> future) { in setFuture() method in AbstractProducer.NonExternallyCancellableFuture
102 return super.setFuture(future); in setFuture()
145 setFuture(localDelegate); in run()
/external/jimfs/jimfs/src/test/java/com/google/common/jimfs/
DJimfsAsynchronousFileChannelTest.java131 channel.write(ByteBuffer.allocate(10), 0, null, setFuture(completionHandlerFuture)); in testAsyncClose_write()
165 channel.read(ByteBuffer.allocate(10), 0, null, setFuture(completionHandlerFuture)); in testAsyncClose_read()
191 channel.read(buf, 0, null, setFuture(future)); in checkAsyncRead()
202 asyncChannel.write(buf, 0, null, setFuture(future)); in checkAsyncWrite()
212 channel.lock(0, 10, true, null, setFuture(future)); in checkAsyncLock()
221 private static <T> CompletionHandler<T, Object> setFuture(final SettableFuture<T> future) { in setFuture() method in JimfsAsynchronousFileChannelTest
/external/guava/guava/src/com/google/common/util/concurrent/
DSettableFuture.java58 public boolean setFuture(ListenableFuture<? extends V> future) { in setFuture() method in SettableFuture
59 return super.setFuture(future); in setFuture()
DAbstractTransformFuture.java75 setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting in run()
224 setFuture(result); in setResult()
DAbstractCatchingFuture.java115 setFuture(localInputFuture); in run()
203 setFuture(result); in setResult()
DAbstractFuture.java807 protected boolean setFuture(ListenableFuture<? extends V> future) { in setFuture() method in AbstractFuture
968 SetFuture<?> setFuture = (SetFuture<?>) task; in complete() local
974 future = setFuture.owner; in complete()
975 if (future.value == setFuture) { in complete()
976 Object valueToSet = getFutureValue(setFuture.future); in complete()
977 if (ATOMIC_HELPER.casValue(future, setFuture, valueToSet)) { in complete()
DTrustedListenableFutureTask.java169 setFuture(result); in afterRanInterruptibly()
DTimeoutFuture.java116 timeoutFuture.setFuture(delegate); in run()
/external/guava/android/guava/src/com/google/common/util/concurrent/
DSettableFuture.java58 public boolean setFuture(ListenableFuture<? extends V> future) { in setFuture() method in SettableFuture
59 return super.setFuture(future); in setFuture()
DAbstractTransformFuture.java75 setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting in run()
225 setFuture(result); in setResult()
DAbstractCatchingFuture.java115 setFuture(localInputFuture); in run()
204 setFuture(result); in setResult()
DAbstractFuture.java807 protected boolean setFuture(ListenableFuture<? extends V> future) { in setFuture() method in AbstractFuture
968 SetFuture<?> setFuture = (SetFuture<?>) task; in complete() local
974 future = setFuture.owner; in complete()
975 if (future.value == setFuture) { in complete()
976 Object valueToSet = getFutureValue(setFuture.future); in complete()
977 if (ATOMIC_HELPER.casValue(future, setFuture, valueToSet)) { in complete()
DTimeoutFuture.java116 timeoutFuture.setFuture(delegate); in run()
DTrustedListenableFutureTask.java169 setFuture(result); in afterRanInterruptibly()
DCombinedFuture.java163 CombinedFuture.this.setFuture(value); in setValue()
/external/angle/src/libANGLE/
DWorkerThread.cpp91 void setFuture(std::future<void> &&future);
103 void AsyncWaitableEvent::setFuture(std::future<void> &&future) in setFuture() function in angle::AsyncWaitableEvent
209 waitable->setFuture(std::move(future)); in checkToRunPendingTasks()

12