Home
last modified time | relevance | path

Searched refs:wasInterrupted (Results 1 – 9 of 9) sorted by relevance

/external/webrtc/talk/app/webrtc/java/android/org/webrtc/
DThreadUtils.java74 boolean wasInterrupted = false; in executeUninterruptibly()
82 wasInterrupted = true; in executeUninterruptibly()
86 if (wasInterrupted) { in executeUninterruptibly()
94 boolean wasInterrupted = false; in joinUninterruptibly()
102 wasInterrupted = true; in joinUninterruptibly()
108 if (wasInterrupted) { in joinUninterruptibly()
135 boolean wasInterrupted = false; in awaitUninterruptibly()
144 wasInterrupted = true; in awaitUninterruptibly()
150 if (wasInterrupted) { in awaitUninterruptibly()
/external/lzma/C/
DMtDec.c200 static SRes MtDec_GetError_Spec(CMtDec *p, UInt64 interruptIndex, BoolInt *wasInterrupted) in MtDec_GetError_Spec() argument
204 *wasInterrupted = (p->needInterrupt && interruptIndex > p->interruptIndex); in MtDec_GetError_Spec()
210 …rror_Spec(CMtDec *p, UInt64 inSize, UInt64 outSize, UInt64 interruptIndex, BoolInt *wasInterrupted) in MtDec_Progress_GetError_Spec() argument
221 *wasInterrupted = (p->needInterrupt && interruptIndex > p->interruptIndex); in MtDec_Progress_GetError_Spec()
274 BoolInt wasInterrupted, isAllocError, overflow, finish; in ThreadFunc2() local
310 res = MtDec_Progress_GetError_Spec(p, 0, 0, blockIndex, &wasInterrupted); in ThreadFunc2()
322 if (res == SZ_OK && !wasInterrupted) in ThreadFunc2()
404 res = MtDec_Progress_GetError_Spec(p, 0, 0, blockIndex, &wasInterrupted); in ThreadFunc2()
405 if (res != SZ_OK || wasInterrupted) in ThreadFunc2()
555 res = MtDec_GetError_Spec(p, blockIndex, &wasInterrupted); in ThreadFunc2()
[all …]
DMtDec.h158 BoolInt wasInterrupted; member
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractFuture.java159 protected final boolean wasInterrupted() { in wasInterrupted() method in AbstractFuture
160 return sync.wasInterrupted(); in wasInterrupted()
333 boolean wasInterrupted() { in wasInterrupted() method in AbstractFuture.Sync
DAsyncSettableFuture.java95 value.cancel(wasInterrupted()); in setFuture()
DFutures.java473 running.cancel(wasInterrupted()); in FallbackFuture()
910 outputFuture.cancel(wasInterrupted());
1643 future.cancel(CombinedFuture.this.wasInterrupted());
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractFutureTest.java72 assertFalse(future.wasInterrupted()); in testCancel_notDoneNoInterrupt()
87 assertTrue(future.wasInterrupted()); in testCancel_notDoneInterrupt()
DFuturesTest.java240 assertFalse(input.wasInterrupted()); in testTransform_cancelPropagatesToInput()
252 assertTrue(input.wasInterrupted()); in testTransform_interruptPropagatesToInput()
265 assertFalse(secondary.wasInterrupted()); in testTransform_cancelPropagatesToAsyncOutput()
279 assertTrue(secondary.wasInterrupted()); in testTransform_interruptPropagatesToAsyncOutput()
617 assertTrue(primary.wasInterrupted());
630 assertFalse(primary.wasInterrupted());
646 assertFalse(secondary.wasInterrupted());
968 assertFalse(future1.wasInterrupted());
983 assertTrue(future1.wasInterrupted());
1585 assertFalse(future1.wasInterrupted());
[all …]
DAsyncSettableFutureTest.java190 return wasInterrupted(); in myWasInterrupted()