Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 587) sorted by relevance

12345678910>>...24

/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/common/src/test/java/com/google/android/exoplayer2/util/
DRunnableFutureTaskTest.java34 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifNotStarted_blocks() local
64 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifStarted_unblocks() local
83 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifCanceled_unblocks() local
100 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifNotFinished_blocks() local
133 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifFinished_unblocks() local
152 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifCanceled_unblocks() local
169 RunnableFutureTask<Void, Exception> task = in get_ifNotFinished_blocks() local
208 RunnableFutureTask<Object, Exception> task = in get_returnsResult() local
227 RunnableFutureTask<Object, IOException> task = in get_throwsExecutionException_containsIOException() local
247 RunnableFutureTask<Object, Exception> task = in get_throwsExecutionException_containsRuntimeException() local
[all …]
/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/common/src/test/java/com/google/android/exoplayer2/util/
DRunnableFutureTaskTest.java34 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifNotStarted_blocks() local
64 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifStarted_unblocks() local
83 RunnableFutureTask<Void, Exception> task = in blockUntilStarted_ifCanceled_unblocks() local
100 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifNotFinished_blocks() local
133 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifFinished_unblocks() local
152 RunnableFutureTask<Void, Exception> task = in blockUntilFinished_ifCanceled_unblocks() local
169 RunnableFutureTask<Void, Exception> task = in get_ifNotFinished_blocks() local
208 RunnableFutureTask<Object, Exception> task = in get_returnsResult() local
227 RunnableFutureTask<Object, IOException> task = in get_throwsExecutionException_containsIOException() local
247 RunnableFutureTask<Object, Exception> task = in get_throwsExecutionException_containsRuntimeException() local
[all …]
/external/skia/src/gpu/
DGrDDLTask.cpp23 for (auto& task : fDDL->priv().renderTasks()) { in GrDDLTask() local
38 for (auto& task : fDDL->priv().renderTasks()) { in endFlush() local
46 for (auto& task : fDDL->priv().renderTasks()) { in disown() local
58 for (auto& task : fDDL->priv().renderTasks()) { in onIsUsed() local
72 for (auto& task : fDDL->priv().renderTasks()) { in gatherProxyIntervals() local
84 for (auto& task : fDDL->priv().renderTasks()) { in gatherIDs() local
90 for (auto& task : fDDL->priv().renderTasks()) { in onPrepare() local
97 for (auto& task : fDDL->priv().renderTasks()) { in onExecute() local
126 for (auto& task : fDDL->priv().renderTasks()) { in dump() local
DGrDrawingManager.cpp120 bool used = std::any_of(fDAG.begin(), fDAG.end(), [&](auto& task) { in flush()
170 for (const auto& task : fDAG) { in flush() local
225 for (const auto& task : fDAG) { in flush() local
349 for (const auto& task : fDAG) { in removeRenderTasks() local
429 sk_sp<GrRenderTask>& task = fDAG[i]; in reorderTasks() local
448 for (auto& task : fDAG) { in closeAllTasks() local
455 GrRenderTask* GrDrawingManager::insertTaskBeforeLast(sk_sp<GrRenderTask> task) { in insertTaskBeforeLast()
470 GrRenderTask* GrDrawingManager::appendTask(sk_sp<GrRenderTask> task) { in appendTask()
559 void GrDrawingManager::setLastRenderTask(const GrSurfaceProxy* proxy, GrRenderTask* task) { in setLastRenderTask()
579 GrRenderTask* task = this->getLastRenderTask(proxy); in getLastOpsTask() local
[all …]
/external/libwebsockets/lib/misc/threadpool/
Dthreadpool.c75 struct lws_threadpool_task *task; member
125 __lws_threadpool_task_dump(struct lws_threadpool_task *task, char *buf, int len) in __lws_threadpool_task_dump()
237 state_transition(struct lws_threadpool_task *task, in state_transition()
245 task_to_wsi(struct lws_threadpool_task *task) in task_to_wsi()
255 lws_threadpool_task_cleanup_destroy(struct lws_threadpool_task *task) in lws_threadpool_task_cleanup_destroy()
269 __lws_threadpool_reap(struct lws_threadpool_task *task) in __lws_threadpool_reap()
319 struct lws_threadpool_task **c, *task = NULL; in lws_threadpool_tsi_context() local
393 struct lws_threadpool_task *task) in lws_threadpool_worker_sync()
493 struct lws_threadpool_task **c, **c2, *task; in lws_threadpool_worker() local
744 struct lws_threadpool_task **c, *task; in lws_threadpool_finish() local
[all …]
/external/ims/rcs/rcsservice/src/com/android/service/ims/
DTaskManager.java99 public void putTask(int taskId, Task task){ in putTask()
105 private synchronized void putTaskInternal(int taskId, Task task){ in putTaskInternal()
115 Task task = new PresenceCapabilityTask(context, taskId, TASK_TYPE_GET_CAPABILITY, in addCapabilityTask() local
128 Task task = new PresenceAvailabilityTask(taskId, TASK_TYPE_GET_AVAILABILITY, in addAvailabilityTask() local
141 Task task = new PresenceTask(taskId, TASK_TYPE_PUBLISH, null /*listener*/, contacts); in addPublishTask() local
157 Task task = mTaskMap.remove(String.valueOf(taskId)); in removeTask() local
174 Task task = mTaskMap.get(key); in getTaskForSingleContactQuery() local
225 Task task = mTaskMap.get(key); in onTerminated() local
256 Task task = getTaskByRequestId(requestId); in onTerminated() local
278 Task task = getTask(taskId); in onTimeout() local
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DTrustedListenableFutureTaskTest.java42 TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); in testSuccessful() local
51 TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); in testCancelled() local
67 TrustedListenableFutureTask<Integer> task = in testFailed() local
92 final TrustedListenableFutureTask<Integer> task = in testCancel_interrupted() local
144 final TrustedListenableFutureTask<Integer> task = in testRunIdempotency() local
178 final TrustedListenableFutureTask<Void> task = in testToString() local
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DTrustedListenableFutureTaskTest.java42 TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); in testSuccessful() local
51 TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); in testCancelled() local
67 TrustedListenableFutureTask<Integer> task = in testFailed() local
92 final TrustedListenableFutureTask<Integer> task = in testCancel_interrupted() local
144 final TrustedListenableFutureTask<Integer> task = in testRunIdempotency() local
178 final TrustedListenableFutureTask<Void> task = in testToString() local
/external/libchrome/base/task_scheduler/
Dpost_task.cc25 bool PostTask(const Location& from_here, OnceClosure task) override { in PostTask()
45 void PostTask(const Location& from_here, OnceClosure task) { in PostTask()
50 OnceClosure task, in PostDelayedTask()
56 OnceClosure task, in PostTaskAndReply()
64 OnceClosure task) { in PostTaskWithTraits()
70 OnceClosure task, in PostDelayedTaskWithTraits()
83 OnceClosure task, in PostTaskWithTraitsAndReply()
Dpost_task.h101 OnceCallback<TaskReturnType()> task, in PostTaskAndReplyWithResult()
114 Callback<TaskReturnType()> task, in PostTaskAndReplyWithResult()
153 OnceCallback<TaskReturnType()> task, in PostTaskWithTraitsAndReplyWithResult()
172 Callback<TaskReturnType()> task, in PostTaskWithTraitsAndReplyWithResult()
/external/mesa3d/src/gallium/drivers/llvmpipe/
Dlp_rast.c96 lp_rast_tile_begin(struct lp_rasterizer_task *task, in lp_rast_tile_begin()
137 lp_rast_clear_color(struct lp_rasterizer_task *task, in lp_rast_clear_color()
185 lp_rast_clear_zstencil(struct lp_rasterizer_task *task, in lp_rast_clear_zstencil()
306 lp_rast_shade_tile(struct lp_rasterizer_task *task, in lp_rast_shade_tile()
399 lp_rast_shade_tile_opaque(struct lp_rasterizer_task *task, in lp_rast_shade_tile_opaque()
420 lp_rast_shade_quads_mask_sample(struct lp_rasterizer_task *task, in lp_rast_shade_quads_mask_sample()
500 lp_rast_shade_quads_mask(struct lp_rasterizer_task *task, in lp_rast_shade_quads_mask()
517 lp_rast_begin_query(struct lp_rasterizer_task *task, in lp_rast_begin_query()
544 lp_rast_end_query(struct lp_rasterizer_task *task, in lp_rast_end_query()
573 lp_rast_set_state(struct lp_rasterizer_task *task, in lp_rast_set_state()
[all …]
/external/lottie/lottie/src/test/java/com/airbnb/lottie/
DLottieTaskTest.java28 LottieTask<Integer> task = new LottieTask<>(new Callable<LottieResult<Integer>>() { in testListener() local
42 LottieTask<Integer> task = new LottieTask<>(new Callable<LottieResult<Integer>>() { in testException() local
60 LottieTask<Integer> task = new LottieTask<>(new Callable<LottieResult<Integer>>() { in testRemoveListener() local
84 LottieTask<Integer> task = new LottieTask<>(new Callable<LottieResult<Integer>>() { in testAddListenerAfter() local
/external/libchrome/base/android/java/src/org/chromium/base/
DThreadUtils.java75 FutureTask<Void> task = new FutureTask<Void>(r, null); in runOnUiThreadBlocking() local
110 FutureTask<T> task = new FutureTask<T>(c); in runOnUiThreadBlocking() local
126 public static <T> FutureTask<T> runOnUiThread(FutureTask<T> task) { in runOnUiThread()
167 public static <T> FutureTask<T> postOnUiThread(FutureTask<T> task) { in postOnUiThread()
178 public static void postOnUiThread(Runnable task) { in postOnUiThread()
190 public static void postOnUiThreadDelayed(Runnable task, long delayMillis) { in postOnUiThreadDelayed()
/external/jacoco/org.jacoco.ant/src/org/jacoco/ant/
DCoverageTask.java57 public void addTask(final Task task) { in addTask()
119 public void enhanceTask(final Task task) { in enhanceTask()
141 public void enhanceTask(final Task task) { in enhanceTask()
157 public void addJvmArgs(final Task task) { in addJvmArgs()
198 void enhanceTask(Task task) throws BuildException; in enhanceTask()
/external/tensorflow/tensorflow/core/data/service/
Dworker_impl.cc150 for (auto& task : tasks) { in Stop() local
165 Task* task; in GetElementResult() local
214 const TaskDef& task = request->task(); in ProcessTask() local
221 std::shared_ptr<Task>& task = tasks_[task_def.task_id()]; in ProcessTaskInternal() local
235 DataServiceWorkerImpl::Task& task) { in EnsureTaskInitialized()
325 void DataServiceWorkerImpl::StopTask(Task& task) TF_LOCKS_EXCLUDED(mu_) { in StopTask()
358 Task* task = it.second.get(); in GetWorkerTasks() local
447 for (const auto& task : tasks_) { in Heartbeat() local
459 for (const auto& task : new_tasks) { in Heartbeat() local
476 for (const auto& task : tasks_to_delete) { in Heartbeat() local
/external/python/cpython3/Lib/asyncio/
Dbase_tasks.py8 def _task_repr_info(task): argument
25 def _task_get_stack(task, limit): argument
60 def _task_print_stack(task, limit, file): argument
/external/pthreadpool/src/
Dshim.c31 pthreadpool_task_1d_t task, in pthreadpool_parallelize_1d()
43 pthreadpool_task_1d_with_id_t task, in pthreadpool_parallelize_1d_with_uarch()
57 pthreadpool_task_1d_tile_1d_t task, in pthreadpool_parallelize_1d_tile_1d()
70 pthreadpool_task_2d_t task, in pthreadpool_parallelize_2d()
85 pthreadpool_task_2d_tile_1d_t task, in pthreadpool_parallelize_2d_tile_1d()
101 pthreadpool_task_2d_tile_2d_t task, in pthreadpool_parallelize_2d_tile_2d()
118 pthreadpool_task_2d_tile_2d_with_id_t task, in pthreadpool_parallelize_2d_tile_2d_with_uarch()
138 pthreadpool_task_3d_t task, in pthreadpool_parallelize_3d()
156 pthreadpool_task_3d_tile_1d_t task, in pthreadpool_parallelize_3d_tile_1d()
175 pthreadpool_task_3d_tile_2d_t task, in pthreadpool_parallelize_3d_tile_2d()
[all …]
/external/rust/crates/futures-util/src/stream/futures_unordered/
Dmod.rs27 mod task; module
163 let task = Arc::new(Task { in push() localVariable
218 let task = *self.head_all.get_mut(); in iter_pin_mut() localVariable
228 let task = self.head_all.load(Acquire); in atomic_load_head_and_len_all() localVariable
329 let task = Arc::from_raw(task); in unlink() localVariable
401 let task = match unsafe { self.ready_to_run_queue.dequeue() } { in poll_next() localVariable
442 let task = unsafe { Arc::from_raw(task) }; in poll_next() localVariable
455 let task = unsafe { self.unlink(task) }; in poll_next() localVariable
479 task: Option<Arc<Task<Fut>>>, in poll_next() field
504 let task = bomb.task.as_ref().unwrap(); in poll_next() localVariable
[all …]
/external/guava/android/guava/src/com/google/common/util/concurrent/
DForwardingListeningExecutorService.java43 public <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task) { in submit()
48 public ListenableFuture<?> submit(Runnable task) { in submit()
54 Runnable task, @ParametricNullness T result) { in submit()
DAbstractListeningExecutorService.java57 public ListenableFuture<?> submit(Runnable task) { in submit()
63 Runnable task, @ParametricNullness T result) { in submit()
68 public <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task) { in submit()
/external/libbrillo/brillo/message_loops/
Dmessage_loop.h57 TaskId PostDelayedTask(base::OnceClosure task, base::TimeDelta delay) { in PostDelayedTask()
63 TaskId PostTask(base::OnceClosure task) { in PostTask()
66 TaskId PostTask(const base::Location& from_here, base::OnceClosure task) { in PostTask()
/external/guava/guava/src/com/google/common/util/concurrent/
DForwardingListeningExecutorService.java43 public <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task) { in submit()
48 public ListenableFuture<?> submit(Runnable task) { in submit()
54 Runnable task, @ParametricNullness T result) { in submit()
DAbstractListeningExecutorService.java57 public ListenableFuture<?> submit(Runnable task) { in submit()
63 Runnable task, @ParametricNullness T result) { in submit()
68 public <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task) { in submit()
/external/swiftshader/src/Vulkan/
DVkQueue.cpp43 Task task; in ~Queue() local
57 Task task; in submit() local
71 void Queue::submitQueue(const Task &task) in submitQueue()
148 Task task = pending.take(); in taskLoop() local
171 Task task; in waitIdle() local
/external/webrtc/rtc_base/
Dtask_queue_for_test.h28 void SendTask(rtc::Location loc, TaskQueueBase* task_queue, Closure&& task) {
54 void SendTask(Closure* task) {
66 void SendTask(Closure&& task, rtc::Location loc) {

12345678910>>...24