| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | FuturesTransformAsyncFunctionTest.java | 101 assertTrue(resultFuture.isCancelled()); in testFutureCancelBeforeInputCompletion()
102 assertTrue(inputFuture.isCancelled()); in testFutureCancelBeforeInputCompletion()
103 assertFalse(outputFuture.isCancelled()); in testFutureCancelBeforeInputCompletion()
114 assertTrue(resultFuture.isCancelled()); in testFutureCancellableBeforeOutputCompletion()
115 assertFalse(inputFuture.isCancelled()); in testFutureCancellableBeforeOutputCompletion()
116 assertTrue(outputFuture.isCancelled()); in testFutureCancellableBeforeOutputCompletion()
136 assertTrue(resultFuture.isCancelled()); in testFutureCancellableBeforeFunctionCompletion()
137 assertFalse(inputFuture.isCancelled()); in testFutureCancellableBeforeFunctionCompletion()
138 assertFalse(outputFuture.isCancelled()); in testFutureCancellableBeforeFunctionCompletion()
156 assertFalse(resultFuture.isCancelled()); in testFutureCancelAfterCompletion()
[all …]
|
| D | AsyncSettableFutureTest.java | 41 assertFalse(future.isCancelled()); in testCreate()
54 assertFalse(future.isCancelled()); in testSetValue()
69 assertFalse(future.isCancelled()); in testSetException()
89 assertFalse(future.isCancelled()); in testSetFuture()
96 assertFalse(future.isCancelled()); in testSetFuture()
111 assertFalse(future.isCancelled()); in testSetFuture_genericsHierarchy()
119 assertFalse(future.isCancelled()); in testSetFuture_genericsHierarchy()
128 assertTrue(async.isCancelled()); in testCancel_innerCancelsAsync()
140 assertTrue(inner.isCancelled()); in testCancel_resultCancelsInner_interrupted()
153 assertTrue(inner.isCancelled()); in testCancel_resultCancelsInner()
[all …]
|
| D | ListenableFutureTaskTest.java | 86 assertFalse(task.isCancelled()); in testListenerDoesNotRunUntilTaskCompletes()
95 assertFalse(task.isCancelled()); in testListenerDoesNotRunUntilTaskCompletes()
103 assertFalse(task.isCancelled()); in testListenerDoesNotRunUntilTaskCompletes()
123 assertFalse(task.isCancelled()); in testListenerCalledOnException()
129 assertTrue(task.isCancelled()); in testListenerCalledOnCancelFromNotRunning()
135 assertTrue(task.isCancelled()); in testListenerCalledOnCancelFromNotRunning()
148 assertTrue(task.isCancelled()); in testListenerCalledOnCancelFromRunning()
154 assertTrue(task.isCancelled()); in testListenerCalledOnCancelFromRunning()
|
| D | ListenableFutureTester.java | 60 assertFalse(future.isCancelled()); in setUp()
70 assertFalse(future.isCancelled()); in testCompletedFuture()
74 assertFalse(future.isCancelled()); in testCompletedFuture()
82 assertTrue(future.isCancelled()); in testCancelledFuture()
86 assertTrue(future.isCancelled()); in testCancelledFuture()
97 assertFalse(future.isCancelled()); in testFailedFuture()
101 assertFalse(future.isCancelled()); in testFailedFuture()
|
| D | FuturesTest.java | 150 assertFalse(future.isCancelled()); in testImmediateFailedFuture_cancellationException()
157 assertTrue(future.isCancelled()); in testImmediateCancelledFuture()
239 assertTrue(input.isCancelled()); in testTransform_cancelPropagatesToInput()
251 assertTrue(input.isCancelled()); in testTransform_interruptPropagatesToInput()
264 assertTrue(secondary.isCancelled()); in testTransform_cancelPropagatesToAsyncOutput()
278 assertTrue(secondary.isCancelled()); in testTransform_interruptPropagatesToAsyncOutput()
616 assertTrue(primary.isCancelled());
629 assertTrue(primary.isCancelled());
645 assertTrue(secondary.isCancelled());
760 assertTrue(outer.isCancelled());
[all …]
|
| D | AbstractFutureTest.java | 70 assertTrue(future.isCancelled()); in testCancel_notDoneNoInterrupt()
85 assertTrue(future.isCancelled()); in testCancel_notDoneInterrupt()
104 assertFalse(future.isCancelled()); in testCancel_done()
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| D | RequestFutureTarget.java | 50 private boolean isCancelled; field in RequestFutureTarget
75 if (isCancelled) { in cancel()
81 isCancelled = true; in cancel()
92 public synchronized boolean isCancelled() { in isCancelled() method in RequestFutureTarget
93 return isCancelled; in isCancelled()
101 return isCancelled || resultReceived; in isDone()
191 if (isCancelled) { in doGet()
209 } else if (isCancelled) { in doGet()
|
| D | ThumbnailRequestCoordinator.java | 120 public boolean isCancelled() { in isCancelled() method in ThumbnailRequestCoordinator
121 return full.isCancelled(); in isCancelled()
|
| /external/grpc-grpc-java/context/src/test/java/io/grpc/ |
| D | ContextTest.java | 143 assertFalse(Context.ROOT.isCancelled()); in rootIsNotCancelled()
267 assertTrue(base.isCancelled()); in cancelReturnsFalseIfAlreadyCancelled()
370 assertFalse(base.isCancelled()); in cascadingCancellationNotifiesChild()
371 assertFalse(child.isCancelled()); in cascadingCancellationNotifiesChild()
374 assertTrue(base.isCancelled()); in cascadingCancellationNotifiesChild()
377 assertTrue(child.isCancelled()); in cascadingCancellationNotifiesChild()
389 assertTrue(child.isCancelled()); in cascadingCancellationWithoutListener()
404 assertFalse(attached.isCancelled()); in cancellableContextIsAttached()
413 assertTrue(attached.isCancelled()); in cancellableContextIsAttached()
426 assertFalse(base.isCancelled()); in cancellableContextCascadesFromCancellableParent()
[all …]
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | AbstractCheckedFutureTest.java | 74 assertFalse(future.isCancelled()); in testCheckedGetThrowsApplicationExceptionOnCancellation()
91 assertTrue(future.isCancelled()); in testCheckedGetThrowsApplicationExceptionOnCancellation()
104 assertFalse(future.isCancelled()); in testCheckedGetThrowsApplicationExceptionOnInterruption()
130 assertFalse(future.isCancelled()); in testCheckedGetThrowsApplicationExceptionOnInterruption()
138 assertFalse(future.isCancelled()); in testCheckedGetThrowsApplicationExceptionOnError()
155 assertFalse(future.isCancelled()); in testCheckedGetThrowsApplicationExceptionOnError()
|
| D | AbstractListenableFutureTest.java | 75 assertFalse(future.isCancelled()); in testGetBlocksUntilValueAvailable()
103 assertFalse(future.isCancelled()); in testGetBlocksUntilValueAvailable()
132 assertFalse(future.isCancelled()); in testCanceledFutureThrowsCancellation()
151 assertFalse(future.isCancelled()); in testCanceledFutureThrowsCancellation()
156 assertTrue(future.isCancelled()); in testCanceledFutureThrowsCancellation()
191 assertTrue(future.isCancelled()); in testListenersNotifiedOnError()
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
| D | EngineJob.java | 36 private boolean isCancelled; field in EngineJob
116 if (hasException || hasResource || isCancelled) { in cancel()
124 isCancelled = true; in cancel()
129 boolean isCancelled() { in isCancelled() method in EngineJob
130 return isCancelled; in isCancelled()
140 if (isCancelled) { in handleResultOnMainThread()
171 if (isCancelled) { in handleExceptionOnMainThread()
|
| D | EngineRunnable.java | 35 private volatile boolean isCancelled; field in EngineRunnable
45 isCancelled = true; in cancel()
51 if (isCancelled) { in run()
66 if (isCancelled) { in run()
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/data/ |
| D | HttpUrlFetcher.java | 26 private volatile boolean isCancelled; field in HttpUrlFetcher
65 if (isCancelled) { in loadDataWithRedirects()
110 isCancelled = true; in cancel()
|
| /external/nist-sip/java/gov/nist/javax/sip/parser/ |
| D | Pipeline.java | 61 private boolean isCancelled; field in Pipeline.MyTimer
68 if (this.isCancelled) in runTask()
80 this.isCancelled = true; in cancel()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ServerCallsTest.java | 119 serverCall.isCancelled = false; in runtimeStreamObserverIsServerCallStreamObserver()
121 assertFalse(callObserver.get().isCancelled()); in runtimeStreamObserverIsServerCallStreamObserver()
129 serverCall.isCancelled = true; in runtimeStreamObserverIsServerCallStreamObserver()
131 assertTrue(callObserver.get().isCancelled()); in runtimeStreamObserverIsServerCallStreamObserver()
279 serverCall.isCancelled = false; in onReadyHandlerCalledForUnaryRequest()
469 private boolean isCancelled; field in ServerCallsTest.ServerCallRecorder
498 public boolean isCancelled() { in isCancelled() method in ServerCallsTest.ServerCallRecorder
499 return isCancelled; in isCancelled()
|
| /external/volley/src/test/java/com/android/volley/toolbox/ |
| D | AndroidAuthenticatorTest.java | 70 when(mFuture.isCancelled()).thenReturn(false); in resultContainsIntent()
81 when(mFuture.isCancelled()).thenReturn(false); in missingAuthToken()
99 when(mFuture.isCancelled()).thenReturn(false); in goodToken()
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/prefill/ |
| D | BitmapPreFillRunner.java | 64 private boolean isCancelled; field in BitmapPreFillRunner
81 isCancelled = true; in cancel()
109 return !isCancelled && !toPrefill.isEmpty(); in allocate()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Futures.java | 130 public boolean isCancelled() { in isCancelled() method in Futures.ImmediateFuture
203 public boolean isCancelled() { in isCancelled() method in Futures.ImmediateCancelledFuture
467 if (isCancelled()) { in FallbackFuture()
472 if (isCancelled()) { // in case cancel called in the meantime in FallbackFuture()
484 if (running.isCancelled()) { in FallbackFuture()
801 public boolean isCancelled() {
802 return input.isCancelled();
909 if (isCancelled()) {
1109 if (delegate.isCancelled()) {
1641 if (CombinedFuture.this.isCancelled()) {
[all …]
|
| D | AbstractFuture.java | 125 public boolean isCancelled() { in isCancelled() method in AbstractFuture
126 return sync.isCancelled(); in isCancelled()
326 boolean isCancelled() { in isCancelled() method in AbstractFuture.Sync
|
| D | ForwardingFuture.java | 52 public boolean isCancelled() { in isCancelled() method in ForwardingFuture
53 return delegate().isCancelled(); in isCancelled()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PartialForwardingServerCall.java | 52 public boolean isCancelled() { in isCancelled() method in PartialForwardingServerCall
53 return delegate().isCancelled(); in isCancelled()
|
| /external/glide/library/src/main/java/com/bumptech/glide/manager/ |
| D | RequestTracker.java | 69 if (!request.isComplete() && !request.isCancelled() && !request.isRunning()) { in resumeRequests()
89 if (!request.isComplete() && !request.isCancelled()) { in restartRequests()
|
| /external/grpc-grpc-java/context/src/main/java/io/grpc/ |
| D | Context.java | 422 public boolean isCancelled() { in isCancelled() method in Context
426 return cancellableAncestor.isCancelled(); in isCancelled()
468 if (isCancelled()) { in addListener()
818 public boolean isCancelled() {
826 if (super.isCancelled()) {
835 if (isCancelled()) {
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ContextsTest.java | 189 assertFalse(context.isCancelled()); in statusFromCancelled_returnNullIfCtxNotCancelled()
222 assertTrue(cancellableContext.isCancelled()); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()
235 assertTrue(cancellableContext.isCancelled()); in statusFromCancelled_returnCancelledIfCauseIsNull()
247 assertTrue(cancellableContext.isCancelled()); in statusFromCancelled_StatusUnknownShouldWork()
|