Home
last modified time | relevance | path

Searched refs:wasInterrupted (Results 1 – 25 of 99) 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.c201 static SRes MtDec_GetError_Spec(CMtDec *p, UInt64 interruptIndex, BoolInt *wasInterrupted) in MtDec_GetError_Spec() argument
205 *wasInterrupted = (p->needInterrupt && interruptIndex > p->interruptIndex); in MtDec_GetError_Spec()
211 …rror_Spec(CMtDec *p, UInt64 inSize, UInt64 outSize, UInt64 interruptIndex, BoolInt *wasInterrupted) in MtDec_Progress_GetError_Spec() argument
222 *wasInterrupted = (p->needInterrupt && interruptIndex > p->interruptIndex); in MtDec_Progress_GetError_Spec()
275 BoolInt wasInterrupted, isAllocError, overflow, finish; in ThreadFunc2() local
311 res = MtDec_Progress_GetError_Spec(p, 0, 0, blockIndex, &wasInterrupted); in ThreadFunc2()
323 if (res == SZ_OK && !wasInterrupted) in ThreadFunc2()
405 res = MtDec_Progress_GetError_Spec(p, 0, 0, blockIndex, &wasInterrupted); in ThreadFunc2()
406 if (res != SZ_OK || wasInterrupted) in ThreadFunc2()
556 res = MtDec_GetError_Spec(p, blockIndex, &wasInterrupted); in ThreadFunc2()
[all …]
/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/common/src/main/java/com/google/android/exoplayer2/util/
DConditionVariable.java120 boolean wasInterrupted = false; in blockUninterruptible()
125 wasInterrupted = true; in blockUninterruptible()
128 if (wasInterrupted) { in blockUninterruptible()
/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/common/src/main/java/com/google/android/exoplayer2/util/
DConditionVariable.java120 boolean wasInterrupted = false; in blockUninterruptible()
125 wasInterrupted = true; in blockUninterruptible()
128 if (wasInterrupted) { in blockUninterruptible()
/external/apache-commons-io/src/test/java/org/apache/commons/io/
DFileUtilsWaitForTest.java46 final AtomicBoolean wasInterrupted = new AtomicBoolean(); in testWaitForInterrupted() local
52 wasInterrupted.set(Thread.currentThread().isInterrupted()); in testWaitForInterrupted()
60 assertTrue(wasInterrupted.get()); in testWaitForInterrupted()
/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.java215 FutureTask<Boolean> wasInterrupted = untimedInterruptReporter(future, true); in testMakeUninterruptible_plainFutureSanityCheck() local
217 Thread waitingThread = new Thread(wasInterrupted); in testMakeUninterruptible_plainFutureSanityCheck()
221 wasInterrupted.get(); in testMakeUninterruptible_plainFutureSanityCheck()
/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.java215 FutureTask<Boolean> wasInterrupted = untimedInterruptReporter(future, true); in testMakeUninterruptible_plainFutureSanityCheck() local
217 Thread waitingThread = new Thread(wasInterrupted); in testMakeUninterruptible_plainFutureSanityCheck()
221 wasInterrupted.get(); in testMakeUninterruptible_plainFutureSanityCheck()
/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/core/src/main/java/com/google/android/exoplayer2/video/
DDummySurface.java142 boolean wasInterrupted = false; in init()
149 wasInterrupted = true; in init()
153 if (wasInterrupted) { in init()
/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/core/src/main/java/com/google/android/exoplayer2/video/
DPlaceholderSurface.java142 boolean wasInterrupted = false; in init()
149 wasInterrupted = true; in init()
153 if (wasInterrupted) { in init()
/external/tensorflow/tensorflow/dtensor/mlir/
Ddesignate_resource_handle_mesh.cc44 if (!result.wasInterrupted()) return mlir::success(); in SetMeshForResourceCreatingCluster()
80 if (walk_result.wasInterrupted()) return signalPassFailure(); in runOnOperation()
/external/guava/guava/src/com/google/common/util/concurrent/
DAggregateFuture.java82 boolean wasInterrupted = wasInterrupted(); in afterDone()
84 future.cancel(wasInterrupted); in afterDone()
DAbstractFuture.java333 final boolean wasInterrupted; field in AbstractFuture.Cancellation
336 Cancellation(boolean wasInterrupted, @CheckForNull Throwable cause) { in Cancellation() argument
337 this.wasInterrupted = wasInterrupted; in Cancellation()
723 protected final boolean wasInterrupted() { in wasInterrupted() method in AbstractFuture
725 return (localValue instanceof Cancellation) && ((Cancellation) localValue).wasInterrupted; in wasInterrupted()
883 future.cancel(((Cancellation) localValue).wasInterrupted); in setFuture()
906 if (c.wasInterrupted) { in getFutureValue()
1104 related.cancel(wasInterrupted()); in maybePropagateCancellationTo()
/external/guava/android/guava/src/com/google/common/util/concurrent/
DAggregateFuture.java82 boolean wasInterrupted = wasInterrupted(); in afterDone()
84 future.cancel(wasInterrupted); in afterDone()
DAbstractFuture.java333 final boolean wasInterrupted; field in AbstractFuture.Cancellation
336 Cancellation(boolean wasInterrupted, @CheckForNull Throwable cause) { in Cancellation() argument
337 this.wasInterrupted = wasInterrupted; in Cancellation()
723 protected final boolean wasInterrupted() { in wasInterrupted() method in AbstractFuture
725 return (localValue instanceof Cancellation) && ((Cancellation) localValue).wasInterrupted; in wasInterrupted()
883 future.cancel(((Cancellation) localValue).wasInterrupted); in setFuture()
906 if (c.wasInterrupted) { in getFutureValue()
1104 related.cancel(wasInterrupted()); in maybePropagateCancellationTo()
/external/tensorflow/tensorflow/compiler/mlir/tfrt/transforms/lmhlo_to_gpu/
Dkernel_ops_pattern.cc479 if (walk(mlir::lmhlo::FusionOp()).wasInterrupted() || in matchAndRewrite()
480 walk(mlir::lmhlo::RngGetAndUpdateStateOp()).wasInterrupted() || in matchAndRewrite()
481 walk(mlir::lmhlo::ScatterOp()).wasInterrupted() || in matchAndRewrite()
482 walk(mlir::lmhlo::SelectAndScatterOp()).wasInterrupted() || in matchAndRewrite()
483 walk(mlir::lmhlo::SortOp()).wasInterrupted() || in matchAndRewrite()
484 walk(mlir::lmhlo::CustomCallOp()).wasInterrupted() || in matchAndRewrite()
485 walk(mlir::gpu::LaunchFuncOp()).wasInterrupted()) in matchAndRewrite()
/external/tensorflow/tensorflow/compiler/mlir/tensorflow/transforms/
Dlaunch_to_device_attribute.cc70 return failure(result.wasInterrupted()); in AssignDevicesInRegion()
108 if (result.wasInterrupted()) return signalPassFailure(); in runOnOperation()
Ddecompose_resource_ops_pass.cc103 if (walk_result.wasInterrupted()) return failure(); in ApplyPatternsLocallyUntilConverged()
147 if (walk_result.wasInterrupted()) return failure(); in ApplyPatternsInClusterAndReachableFunctions()
Dresource_op_lifting_cleanup.cc432 if (while_op.cond_function().walk(check_while_cond).wasInterrupted()) in CleanupAndCanonicalize()
439 if (while_region.cond().walk(check_while_cond).wasInterrupted()) in CleanupAndCanonicalize()
451 return failure(walk_result.wasInterrupted()); in CleanupAndCanonicalize()
467 return failure(walk_result.wasInterrupted()); in CleanupAndCanonicalizeForResourceOpLifting()
/external/tensorflow/tensorflow/compiler/mlir/lite/transforms/
Dpin_ops_with_side_effects.cc110 }).wasInterrupted()) { in runOnOperation()
129 }).wasInterrupted()) { in runOnOperation()
/external/tensorflow/tensorflow/compiler/mlir/tensorflow/utils/
Dtpu_cluster_util.cc66 if (result.wasInterrupted()) return failure(); in WalkReachableFromTpuCluster()
89 if (result.wasInterrupted()) return failure(); in WalkReachableFromTpuCluster()
/external/tensorflow/tensorflow/dtensor/mlir/utils/
Dupdate_tpu_metadata.cc142 return mlir::failure(result.wasInterrupted()); in UpdateTPUCompileMetadata()
179 if (result.wasInterrupted()) return signalPassFailure(); in runOnOperation()

1234