Home
last modified time | relevance | path

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

1234

/external/webrtc/rtc_base/java/src/org/webrtc/
DThreadUtils.java65 boolean wasInterrupted = false; in executeUninterruptibly()
73 wasInterrupted = true; in executeUninterruptibly()
77 if (wasInterrupted) { in executeUninterruptibly()
85 boolean wasInterrupted = false; in joinUninterruptibly()
93 wasInterrupted = true; in joinUninterruptibly()
99 if (wasInterrupted) { in joinUninterruptibly()
126 boolean wasInterrupted = false; in awaitUninterruptibly()
135 wasInterrupted = true; in awaitUninterruptibly()
141 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 …]
/external/llvm-project/mlir/lib/IR/
DVisitors.cpp54 if (callback(&region).wasInterrupted()) in walk()
68 if (callback(&block).wasInterrupted()) in walk()
84 if (walk(&nestedOp, callback).wasInterrupted()) in walk()
/external/tensorflow/tensorflow/compiler/mlir/tensorflow/utils/
Dvisitor_util.cc54 if (callback(op, stage).wasInterrupted()) in WalkOperations()
62 if (WalkOperations(&nestedOp, callback).wasInterrupted()) in WalkOperations()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DSettableFutureTest.java190 assertTrue(inner.wasInterrupted()); in testCancel_resultCancelsInner_interrupted()
205 assertFalse(inner.wasInterrupted()); in testCancel_resultCancelsInner()
227 assertFalse(inner.wasInterrupted()); in testCancel_multipleBeforeSetFuture_noInterruptFirst()
237 assertTrue(inner.wasInterrupted()); in testCancel_multipleBeforeSetFuture_interruptFirst()
DAbstractFutureBenchmarks.java198 protected final boolean wasInterrupted() { in wasInterrupted() method in AbstractFutureBenchmarks.OldAbstractFuture
199 return sync.wasInterrupted(); in wasInterrupted()
358 boolean wasInterrupted() { in wasInterrupted() method in AbstractFutureBenchmarks.OldAbstractFuture.Sync
DUninterruptibleFutureTest.java217 FutureTask<Boolean> wasInterrupted = untimedInterruptReporter(future, true); in testMakeUninterruptible_plainFutureSanityCheck() local
219 Thread waitingThread = new Thread(wasInterrupted); in testMakeUninterruptible_plainFutureSanityCheck()
223 wasInterrupted.get(); in testMakeUninterruptible_plainFutureSanityCheck()
DTrustedListenableFutureTaskTest.java56 assertFalse(task.wasInterrupted()); in testCancelled()
127 assertTrue(task.wasInterrupted()); in testCancel_interrupted()
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DSettableFutureTest.java190 assertTrue(inner.wasInterrupted()); in testCancel_resultCancelsInner_interrupted()
205 assertFalse(inner.wasInterrupted()); in testCancel_resultCancelsInner()
227 assertFalse(inner.wasInterrupted()); in testCancel_multipleBeforeSetFuture_noInterruptFirst()
237 assertTrue(inner.wasInterrupted()); in testCancel_multipleBeforeSetFuture_interruptFirst()
DAbstractFutureBenchmarks.java198 protected final boolean wasInterrupted() { in wasInterrupted() method in AbstractFutureBenchmarks.OldAbstractFuture
199 return sync.wasInterrupted(); in wasInterrupted()
358 boolean wasInterrupted() { in wasInterrupted() method in AbstractFutureBenchmarks.OldAbstractFuture.Sync
DUninterruptibleFutureTest.java217 FutureTask<Boolean> wasInterrupted = untimedInterruptReporter(future, true); in testMakeUninterruptible_plainFutureSanityCheck() local
219 Thread waitingThread = new Thread(wasInterrupted); in testMakeUninterruptible_plainFutureSanityCheck()
223 wasInterrupted.get(); in testMakeUninterruptible_plainFutureSanityCheck()
DTrustedListenableFutureTaskTest.java56 assertFalse(task.wasInterrupted()); in testCancelled()
127 assertTrue(task.wasInterrupted()); in testCancel_interrupted()
/external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/video/
DDummySurface.java145 boolean wasInterrupted = false; in init()
152 wasInterrupted = true; in init()
156 if (wasInterrupted) { in init()
/external/guava/android/guava/src/com/google/common/util/concurrent/
DAggregateFuture.java78 boolean wasInterrupted = wasInterrupted(); in afterDone()
80 future.cancel(wasInterrupted); in afterDone()
DAbstractFuture.java316 final boolean wasInterrupted; field in AbstractFuture.Cancellation
319 Cancellation(boolean wasInterrupted, @NullableDecl Throwable cause) { in Cancellation() argument
320 this.wasInterrupted = wasInterrupted; in Cancellation()
686 protected final boolean wasInterrupted() { in wasInterrupted() method in AbstractFuture
688 return (localValue instanceof Cancellation) && ((Cancellation) localValue).wasInterrupted; in wasInterrupted()
846 future.cancel(((Cancellation) localValue).wasInterrupted); in setFuture()
869 if (c.wasInterrupted) { in getFutureValue()
1044 related.cancel(wasInterrupted()); in maybePropagateCancellationTo()
/external/guava/guava/src/com/google/common/util/concurrent/
DAggregateFuture.java78 boolean wasInterrupted = wasInterrupted(); in afterDone()
80 future.cancel(wasInterrupted); in afterDone()
DAbstractFuture.java316 final boolean wasInterrupted; field in AbstractFuture.Cancellation
319 Cancellation(boolean wasInterrupted, @Nullable Throwable cause) { in Cancellation() argument
320 this.wasInterrupted = wasInterrupted; in Cancellation()
686 protected final boolean wasInterrupted() { in wasInterrupted() method in AbstractFuture
688 return (localValue instanceof Cancellation) && ((Cancellation) localValue).wasInterrupted; in wasInterrupted()
846 future.cancel(((Cancellation) localValue).wasInterrupted); in setFuture()
869 if (c.wasInterrupted) { in getFutureValue()
1043 related.cancel(wasInterrupted()); in maybePropagateCancellationTo()
/external/llvm-project/mlir/lib/Dialect/Async/Transforms/
DAsyncRefCounting.cpp292 if (refCountingWalk.wasInterrupted()) in runOnFunction()
305 if (blockWalk.wasInterrupted()) in runOnFunction()
318 if (opWalk.wasInterrupted()) in runOnFunction()
DAsyncRefCountingOptimization.cpp198 if (blockWalk.wasInterrupted()) in runOnFunction()
211 if (opWalk.wasInterrupted()) in runOnFunction()
/external/tensorflow/tensorflow/compiler/mlir/tensorflow/transforms/
Dtest_visitor_util.cc89 if (result.wasInterrupted()) in runOnFunction()
98 if (result.wasInterrupted()) in runOnFunction()
Dlaunch_to_device_attribute.cc97 return failure(result.wasInterrupted()); in AssignDevicesInRegion()
135 if (result.wasInterrupted()) return signalPassFailure(); in runOnFunction()
Dresource_op_lifting_cleanup.cc427 if (while_op.cond_function().walk(check_while_cond).wasInterrupted()) in CleanupAndCanonicalize()
434 if (while_region.cond().walk(check_while_cond).wasInterrupted()) in CleanupAndCanonicalize()
446 return failure(walk_result.wasInterrupted()); in CleanupAndCanonicalize()
462 return failure(walk_result.wasInterrupted()); in CleanupAndCanonicalizeForResourceOpLifting()
/external/llvm-project/mlir/lib/Target/LLVMIR/
DDebugTranslation.cpp32 if (!module->walk(interruptIfValidLocation).wasInterrupted()) in DebugTranslation()
82 if (!compileUnit || !func.walk(interruptIfValidLocation).wasInterrupted()) in translate()
93 .wasInterrupted(); in translate()
/external/llvm-project/mlir/lib/Dialect/SCF/Transforms/
DParallelLoopFusion.cpp29 return walkResult.wasInterrupted(); in hasNestedParallelOp()
86 return !walkResult.wasInterrupted(); in haveNoReadsAfterWriteExceptSameIndex()
/external/llvm-project/mlir/test/lib/Dialect/Affine/
DTestAffineLoopUnswitching.cpp50 if (func.walk(walkFn).wasInterrupted()) in runOnFunction()

1234