Home
last modified time | relevance | path

Searched refs:currentTask (Results 1 – 6 of 6) sorted by relevance

/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/core/src/main/java/com/google/android/exoplayer2/upstream/
DLoader.java200 @Nullable private LoadTask<? extends Loadable> currentTask; field in Loader
263 return currentTask != null; in isLoading()
272 Assertions.checkStateNotNull(currentTask).cancel(false); in cancelLoading()
287 if (currentTask != null) { in release()
288 currentTask.cancel(true); in release()
307 } else if (currentTask != null) { in maybeThrowError()
308 currentTask.maybeThrowError( in maybeThrowError()
309 minRetryCount == Integer.MIN_VALUE ? currentTask.defaultMinRetryCount : minRetryCount); in maybeThrowError()
358 Assertions.checkState(currentTask == null); in start()
359 currentTask = this; in start()
[all …]
/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/core/src/main/java/com/google/android/exoplayer2/upstream/
DLoader.java197 @Nullable private LoadTask<? extends Loadable> currentTask; field in Loader
260 return currentTask != null; in isLoading()
269 Assertions.checkStateNotNull(currentTask).cancel(false); in cancelLoading()
284 if (currentTask != null) { in release()
285 currentTask.cancel(true); in release()
304 } else if (currentTask != null) { in maybeThrowError()
305 currentTask.maybeThrowError( in maybeThrowError()
306 minRetryCount == Integer.MIN_VALUE ? currentTask.defaultMinRetryCount : minRetryCount); in maybeThrowError()
355 Assertions.checkState(currentTask == null); in start()
356 currentTask = this; in start()
[all …]
/external/aws-sdk-java-v2/utils/src/main/java/software/amazon/awssdk/utils/cache/
DNonBlocking.java197 ScheduledFuture<?> currentTask; in updateTask() local
199 currentTask = refreshTask.get(); in updateTask()
200 if (currentTask != null && !currentTask.isDone()) { in updateTask()
201 currentTask.cancel(false); in updateTask()
203 } while (!refreshTask.compareAndSet(currentTask, newTask)); in updateTask()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/
DLimitedDispatcher.kt108 private inner class Worker(private var currentTask: Runnable) : Runnable { in <lambda>() variable in kotlinx.coroutines.internal.LimitedDispatcher.<lambda>.Worker
113 currentTask.run() in <lambda>()
117 currentTask = obtainTaskOrDeallocateWorker() ?: return in <lambda>()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DSequentialExecutorTest.java348 final Runnable[] currentTask = new Runnable[1]; in testToString() local
353 currentTask[0] = task; in testToString()
355 currentTask[0] = null; in testToString()
372 whileRunningToString[0] = "" + currentTask[0]; in testToString()
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DSequentialExecutorTest.java348 final Runnable[] currentTask = new Runnable[1]; in testToString() local
353 currentTask[0] = task; in testToString()
355 currentTask[0] = null; in testToString()
372 whileRunningToString[0] = "" + currentTask[0]; in testToString()