Home
last modified time | relevance | path

Searched refs:task (Results 1 - 25 of 290) sorted by relevance

12345678910>>...12

/third_party/libwebsockets/lib/misc/threadpool/
H A Dthreadpool.c74 pthread_mutex_t lock; /* part of task wake_idle */
75 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() argument
131 if (!task->acquired) { in __lws_threadpool_task_dump()
133 "task: %s, QUEUED queued: %dms", in __lws_threadpool_task_dump()
134 task->name, ms_delta(now, task->created)); in __lws_threadpool_task_dump()
139 if (task->acc_running) in __lws_threadpool_task_dump()
140 runms = (int)task->acc_running; in __lws_threadpool_task_dump()
142 if (task in __lws_threadpool_task_dump()
237 state_transition(struct lws_threadpool_task *task, enum lws_threadpool_task_status status) state_transition() argument
245 task_to_wsi(struct lws_threadpool_task *task) task_to_wsi() argument
255 lws_threadpool_task_cleanup_destroy(struct lws_threadpool_task *task) lws_threadpool_task_cleanup_destroy() argument
269 __lws_threadpool_reap(struct lws_threadpool_task *task) __lws_threadpool_reap() argument
319 struct lws_threadpool_task **c, *task = NULL; lws_threadpool_tsi_context() local
392 lws_threadpool_worker_sync(struct lws_pool *pool, struct lws_threadpool_task *task) lws_threadpool_worker_sync() argument
493 struct lws_threadpool_task **c, **c2, *task; lws_threadpool_worker() local
744 struct lws_threadpool_task **c, *task; lws_threadpool_finish() local
775 struct lws_threadpool_task *task, *next; lws_threadpool_destroy() local
841 lws_threadpool_dequeue_task(struct lws_threadpool_task *task) lws_threadpool_dequeue_task() argument
957 struct lws_threadpool_task *task; lws_threadpool_dequeue() local
974 struct lws_threadpool_task *task = NULL; lws_threadpool_enqueue() local
1055 lws_threadpool_task_status(struct lws_threadpool_task *task, void **user) lws_threadpool_task_status() argument
1083 lws_threadpool_task_status_noreap(struct lws_threadpool_task *task) lws_threadpool_task_status_noreap() argument
1092 struct lws_threadpool_task *task; lws_threadpool_task_status_wsi() local
1110 lws_threadpool_task_sync(struct lws_threadpool_task *task, int stop) lws_threadpool_task_sync() argument
1125 lws_threadpool_foreach_task_wsi(struct lws *wsi, void *user, int (*cb)(struct lws_threadpool_task *task, void *user)) lws_threadpool_foreach_task_wsi() argument
1141 struct lws_threadpool_task *task = lws_container_of(d, lws_threadpool_foreach_task_wsi() local
1158 lws_threadpool_foreach_task_ss(struct lws_ss_handle *ss, void *user, int (*cb)(struct lws_threadpool_task *task, void *user)) lws_threadpool_foreach_task_ss() argument
1170 disassociate_wsi(struct lws_threadpool_task *task, void *user) disassociate_wsi() argument
[all...]
/third_party/mesa3d/src/gallium/drivers/llvmpipe/
H A Dlp_cs_tpool.c45 struct lp_cs_tpool_task *task; in lp_cs_tpool_worker() local
54 task = list_first_entry(&pool->workqueue, struct lp_cs_tpool_task, in lp_cs_tpool_worker()
57 unsigned this_iter = task->iter_start; in lp_cs_tpool_worker()
59 iter_per_thread = task->iter_per_thread; in lp_cs_tpool_worker()
61 if (task->iter_remainder && in lp_cs_tpool_worker()
62 task->iter_start + task->iter_remainder == task->iter_total) { in lp_cs_tpool_worker()
63 task->iter_remainder--; in lp_cs_tpool_worker()
67 task in lp_cs_tpool_worker()
133 struct lp_cs_tpool_task *task; lp_cs_tpool_queue_task() local
172 struct lp_cs_tpool_task *task = *task_handle; lp_cs_tpool_wait_for_task() local
[all...]
H A Dlp_rast.c95 lp_rast_tile_begin(struct lp_rasterizer_task *task, in lp_rast_tile_begin() argument
99 struct lp_scene *scene = task->scene; in lp_rast_tile_begin()
103 task->bin = bin; in lp_rast_tile_begin()
104 task->x = x * TILE_SIZE; in lp_rast_tile_begin()
105 task->y = y * TILE_SIZE; in lp_rast_tile_begin()
106 task->width = TILE_SIZE + x * TILE_SIZE > scene->fb.width ? in lp_rast_tile_begin()
108 task->height = TILE_SIZE + y * TILE_SIZE > scene->fb.height ? in lp_rast_tile_begin()
111 task->thread_data.vis_counter = 0; in lp_rast_tile_begin()
112 task->thread_data.ps_invocations = 0; in lp_rast_tile_begin()
116 task in lp_rast_tile_begin()
135 lp_rast_clear_color(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_clear_color() argument
183 lp_rast_clear_zstencil(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_clear_zstencil() argument
298 lp_rast_shade_tile(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_shade_tile() argument
390 lp_rast_shade_tile_opaque(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_shade_tile_opaque() argument
411 lp_rast_shade_quads_mask_sample(struct lp_rasterizer_task *task, const struct lp_rast_shader_inputs *inputs, unsigned x, unsigned y, uint64_t mask) lp_rast_shade_quads_mask_sample() argument
492 lp_rast_shade_quads_mask(struct lp_rasterizer_task *task, const struct lp_rast_shader_inputs *inputs, unsigned x, unsigned y, unsigned mask) lp_rast_shade_quads_mask() argument
509 lp_rast_blit_tile_to_dest(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_blit_tile_to_dest() argument
609 lp_rast_blit_tile(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_blit_tile() argument
624 lp_rast_begin_query(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_begin_query() argument
654 lp_rast_end_query(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_end_query() argument
684 lp_rast_set_state(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_set_state() argument
695 lp_rast_tile_end(struct lp_rasterizer_task *task) lp_rast_tile_end() argument
937 blit_rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin) blit_rasterize_bin() argument
952 tri_rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin, int x, int y) tri_rasterize_bin() argument
967 debug_rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin) debug_rasterize_bin() argument
987 rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin, int x, int y) rasterize_bin() argument
1042 rasterize_scene(struct lp_rasterizer_task *task, struct lp_scene *scene) rasterize_scene() argument
1170 struct lp_rasterizer_task *task = (struct lp_rasterizer_task *) init_data; thread_function() local
1277 struct lp_rasterizer_task *task = &rast->tasks[i]; lp_rast_create() local
[all...]
H A Dlp_rast_rect.c88 full(struct lp_rasterizer_task *task, in full() argument
93 lp_rast_shade_quads_all(task, in full()
95 task->x + ix * STAMP_SIZE, in full()
96 task->y + iy * STAMP_SIZE); in full()
100 partial(struct lp_rasterizer_task *task, in partial() argument
109 full(task, rect, ix, iy); in partial()
113 lp_rast_shade_quads_mask(task, in partial()
115 task->x + ix * STAMP_SIZE, in partial()
116 task->y + iy * STAMP_SIZE, in partial()
123 intersect_rect_and_tile(struct lp_rasterizer_task *task, in intersect_rect_and_tile() argument
148 lp_rast_rectangle(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_rectangle() argument
[all...]
H A Dlp_rast_linear.c46 lp_rast_linear_clear(struct lp_rasterizer_task *task, in lp_rast_linear_clear() argument
53 const struct lp_scene *scene = task->scene; in lp_rast_linear_clear()
57 task->x, in lp_rast_linear_clear()
58 task->y, in lp_rast_linear_clear()
59 task->width, in lp_rast_linear_clear()
60 task->height, in lp_rast_linear_clear()
68 lp_rast_linear_tile(struct lp_rasterizer_task *task, in lp_rast_linear_tile() argument
75 const struct lp_rast_state *state = task->state; in lp_rast_linear_tile()
82 const struct lp_scene *scene = task->scene; in lp_rast_linear_tile()
86 task in lp_rast_linear_tile()
127 lp_rast_linear_rect(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) lp_rast_linear_rect() argument
240 lp_linear_rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin) lp_linear_rasterize_bin() argument
[all...]
H A Dlp_rast_priv.h55 #define BEGIN_JIT_CALL(state, task) \
59 jit_task = task; \
124 /** A task object for each rasterization thread */
138 lp_rast_shade_quads_mask_sample(struct lp_rasterizer_task *task,
144 lp_rast_shade_quads_mask(struct lp_rasterizer_task *task,
155 lp_rast_get_color_block_pointer(struct lp_rasterizer_task *task, in lp_rast_get_color_block_pointer() argument
159 assert(x < task->scene->tiles_x * TILE_SIZE); in lp_rast_get_color_block_pointer()
160 assert(y < task->scene->tiles_y * TILE_SIZE); in lp_rast_get_color_block_pointer()
163 assert(buf < task->scene->fb.nr_cbufs); in lp_rast_get_color_block_pointer()
164 assert(task in lp_rast_get_color_block_pointer()
193 lp_rast_get_depth_block_pointer(struct lp_rasterizer_task *task, unsigned x, unsigned y, unsigned layer) lp_rast_get_depth_block_pointer() argument
225 lp_rast_shade_quads_all( struct lp_rasterizer_task *task, const struct lp_rast_shader_inputs *inputs, unsigned x, unsigned y ) lp_rast_shade_quads_all() argument
[all...]
H A Dlp_rast_linear_fallback.c91 shade_quads(struct lp_rasterizer_task *task, in shade_quads() argument
96 const struct lp_rast_state *state = task->state; in shade_quads()
98 const struct lp_scene *scene = task->scene; in shade_quads()
106 task->thread_data.raster_state.viewport_index = inputs->viewport_index; in shade_quads()
109 BEGIN_JIT_CALL(state, task); in shade_quads()
120 &task->thread_data, in shade_quads()
130 partial(struct lp_rasterizer_task *task, in partial() argument
139 shade_quads(task, inputs, ix * STAMP_SIZE, iy * STAMP_SIZE, mask); in partial()
147 lp_rast_linear_rect_fallback(struct lp_rasterizer_task *task, in lp_rast_linear_rect_fallback() argument
180 partial(task, input in lp_rast_linear_rect_fallback()
[all...]
/third_party/libuv/test/
H A Drunner.c27 #include "task.h"
70 task_entry_t* task; in run_tests() local
75 for (task = TASKS; task->main; task++, actual++) { in run_tests()
76 if (!task->is_helper) { in run_tests()
91 for (task = TASKS; task->main; task++) { in run_tests()
92 if (task in run_tests()
152 task_entry_t* task; run_test() local
352 task_entry_t* task; run_test_part() local
370 find_helpers(const task_entry_t* task, const task_entry_t** helpers) find_helpers() argument
388 const task_entry_t* task; print_tests() local
[all...]
/third_party/musl/ldso/linux/
H A Ddynlink_rand.c154 void free_task(struct loadtask *task) in free_task() argument
156 if (task == NULL) { in free_task()
159 if (task->name) { in free_task()
160 __libc_free(task->name); in free_task()
161 task->name = NULL; in free_task()
163 if (task->allocated_buf) { in free_task()
164 __libc_free(task->allocated_buf); in free_task()
165 task->allocated_buf = NULL; in free_task()
167 if (task->shdr_allocated_buf != MAP_FAILED) { in free_task()
168 munmap(task in free_task()
218 struct loadtask *task = NULL; shuffle_loadtasks() local
239 struct loadtask *task = __libc_calloc(1, sizeof(struct loadtask)); create_loadtask() local
[all...]
H A Ddynlink.c218 static bool task_check_xpm(struct loadtask *task);
219 static bool map_library_header(struct loadtask *task);
220 static bool task_map_library(struct loadtask *task, struct reserved_address_params *reserved_params);
221 static bool resolve_fd_to_realpath(struct loadtask *task);
222 static bool load_library_header(struct loadtask *task);
223 static void task_load_library(struct loadtask *task, struct reserved_address_params *reserved_params);
230 static void open_library_by_path(const char *name, const char *s, struct loadtask *task, struct zip_info *z_info);
231 static void handle_asan_path_open_by_task(int fd, const char *name, ns_t *namespace, struct loadtask *task, struct zip_info *z_info);
3573 struct loadtask *task = NULL; in dlopen_impl() local
3692 task in dlopen_impl()
4869 open_library_by_path(const char *name, const char *s, struct loadtask *task, struct zip_info *z_info) open_library_by_path() argument
4898 handle_asan_path_open_by_task(int fd, const char *name, ns_t *namespace, struct loadtask *task, struct zip_info *z_info) handle_asan_path_open_by_task() argument
5057 task_check_xpm(struct loadtask *task) task_check_xpm() argument
5069 map_library_header(struct loadtask *task) map_library_header() argument
5212 task_map_library(struct loadtask *task, struct reserved_address_params *reserved_params) task_map_library() argument
5500 resolve_fd_to_realpath(struct loadtask *task) resolve_fd_to_realpath() argument
5519 load_library_header(struct loadtask *task) load_library_header() argument
5767 task_load_library(struct loadtask *task, struct reserved_address_params *reserved_params) task_load_library() argument
5872 struct loadtask *task = create_loadtask(dtneed_name, p, namespace, true); preload_direct_deps() local
5912 struct loadtask *task = NULL; unmap_preloaded_sections() local
5949 struct loadtask *task = NULL; run_loadtasks() local
5994 struct loadtask *task = NULL; load_preload() local
[all...]
/third_party/musl/libc-test/src/functionalext/unittest/
H A Dunit_test_mock_dynlink.c24 void free_task(struct loadtask *task) in free_task() argument
26 if (task == NULL) { in free_task()
29 if (task->name) { in free_task()
30 free((void *)task->name); in free_task()
31 task->name = NULL; in free_task()
33 if (task->allocated_buf) { in free_task()
34 free(task->allocated_buf); in free_task()
35 task->allocated_buf = NULL; in free_task()
37 if (task->dyn_map_len) { in free_task()
38 munmap(task in free_task()
[all...]
/third_party/musl/porting/linux/user/ldso/
H A Ddynlink_rand.c154 void free_task(struct loadtask *task) in free_task() argument
156 if (task == NULL) { in free_task()
159 if (task->name) { in free_task()
160 __libc_free(task->name); in free_task()
161 task->name = NULL; in free_task()
163 if (task->allocated_buf) { in free_task()
164 __libc_free(task->allocated_buf); in free_task()
165 task->allocated_buf = NULL; in free_task()
167 if (task->dyn_map_len) { in free_task()
168 munmap(task in free_task()
214 struct loadtask *task = NULL; shuffle_loadtasks() local
234 struct loadtask *task = __libc_calloc(1, sizeof(struct loadtask)); create_loadtask() local
[all...]
/third_party/mesa3d/src/gallium/frontends/nine/
H A Dthreadpool.c49 struct threadpool_task *task; in threadpool_worker() local
58 /* Pull the first task from the list. We don't free it -- it now lacks in threadpool_worker()
62 task = pool->workqueue; in threadpool_worker()
63 pool->workqueue = task->next; in threadpool_worker()
65 /* Call the task's work func. */ in threadpool_worker()
67 task->work(task->data); in threadpool_worker()
69 task->finished = TRUE; in threadpool_worker()
70 pthread_cond_broadcast(&task->finish); in threadpool_worker()
145 struct threadpool_task *task, *previou in _mesa_threadpool_queue_task() local
187 struct threadpool_task *task = *task_handle; _mesa_threadpool_wait_for_task() local
[all...]
/third_party/python/Lib/asyncio/
H A Dbase_tasks.py9 def _task_repr_info(task):
10 info = base_futures._future_repr_info(task)
12 if task.cancelling() and not task.done():
16 info.insert(1, 'name=%r' % task.get_name())
18 coro = coroutines._format_coroutine(task._coro)
21 if task._fut_waiter is not None:
22 info.insert(3, f'wait_for={task._fut_waiter!r}')
27 def _task_repr(task):
28 info = ' '.join(_task_repr_info(task))
[all...]
/third_party/skia/src/gpu/
H A DGrDDLTask.cpp23 for (auto& task : fDDL->priv().renderTasks()) { in GrDDLTask()
24 SkASSERT(task->isClosed()); in GrDDLTask()
26 for (int i = 0; i < task->numTargets(); ++i) { in GrDDLTask()
27 drawingMgr->setLastRenderTask(task->target(i), task.get()); in GrDDLTask()
31 // The DDL task never accepts additional tasks in GrDDLTask()
38 for (auto& task : fDDL->priv().renderTasks()) { in endFlush()
39 task->endFlush(drawingManager); in endFlush()
46 for (auto& task : fDDL->priv().renderTasks()) { in disown()
47 task in disown()
[all...]
H A DGrDrawingManager.cpp120 bool used = std::any_of(fDAG.begin(), fDAG.end(), [&](auto& task) { in flush()
121 return task && task->isUsed(proxy); in flush()
170 for (const auto& task : fDAG) { in flush()
171 if (task) { in flush()
172 task->gatherIDs(&fFlushingRenderTaskIDs); in flush()
218 for (const auto& task : fDAG) { in flush()
219 SkDEBUGCODE(task->dump(/* printDependencies */ true);) in flush()
225 for (const auto& task : fDAG) { in flush()
226 SkASSERT(task); in flush()
429 sk_sp<GrRenderTask>& task = fDAG[i]; reorderTasks() local
455 insertTaskBeforeLast(sk_sp<GrRenderTask> task) insertTaskBeforeLast() argument
470 appendTask(sk_sp<GrRenderTask> task) appendTask() argument
579 GrRenderTask* task = this->getLastRenderTask(proxy); getLastOpsTask() local
766 GrRenderTask* task = this->insertTaskBeforeLast(sk_make_sp<GrTextureResolveRenderTask>()); newTextureResolveRenderTask() local
828 GrRenderTask* task = this->appendTask(sk_make_sp<GrTransferFromRenderTask>( newTransferFromRenderTask() local
866 sk_sp<GrRenderTask> task = GrCopyRenderTask::Make(this, newCopyRenderTask() local
912 GrRenderTask* task = this->appendTask(GrWritePixelsTask::Make(this, newWritePixelsTask() local
[all...]
/third_party/node/deps/v8/src/libplatform/
H A Ddefault-foreground-task-runner.cc5 #include "src/libplatform/default-foreground-task-runner.h"
33 // Drain the task queues. in Terminate()
39 void DefaultForegroundTaskRunner::PostTaskLocked(std::unique_ptr<Task> task, in PostTaskLocked() argument
43 task_queue_.push_back(std::make_pair(nestability, std::move(task))); in PostTaskLocked()
47 void DefaultForegroundTaskRunner::PostTask(std::unique_ptr<Task> task) { in PostTask() argument
49 PostTaskLocked(std::move(task), kNestable, guard); in PostTask()
57 std::unique_ptr<Task> task, double delay_in_seconds, in PostDelayedTaskLocked()
62 delayed_task_queue_.push({deadline, nestability, std::move(task)}); in PostDelayedTaskLocked()
66 void DefaultForegroundTaskRunner::PostDelayedTask(std::unique_ptr<Task> task, in PostDelayedTask() argument
69 PostDelayedTaskLocked(std::move(task), delay_in_second in PostDelayedTask()
56 PostDelayedTaskLocked( std::unique_ptr<Task> task, double delay_in_seconds, Nestability nestability, const base::MutexGuard&) PostDelayedTaskLocked() argument
72 PostNonNestableDelayedTask( std::unique_ptr<Task> task, double delay_in_seconds) PostNonNestableDelayedTask() argument
78 PostIdleTask(std::unique_ptr<IdleTask> task) PostIdleTask() argument
89 PostNonNestableTask( std::unique_ptr<Task> task) PostNonNestableTask() argument
110 std::unique_ptr<Task> task = MoveExpiredDelayedTasks() local
136 std::unique_ptr<Task> task = std::move(it->second); PopTaskFromQueue() local
[all...]
/third_party/skia/third_party/externals/dawn/src/tests/end2end/
H A DCreatePipelineAsyncTests.cpp68 ValidateCreateComputePipelineAsync(&task); in ValidateCreateComputePipelineAsync()
109 ValidateCreateRenderPipelineAsync(&task); in ValidateCreateRenderPipelineAsync()
121 CreatePipelineAsyncTask* task = static_cast<CreatePipelineAsyncTask*>(userdata); in DoCreateRenderPipelineAsync()
122 task->renderPipeline = wgpu::RenderPipeline::Acquire(returnPipeline); in DoCreateRenderPipelineAsync()
123 task->isCompleted = true; in DoCreateRenderPipelineAsync()
124 task->message = message; in DoCreateRenderPipelineAsync()
126 &task); in DoCreateRenderPipelineAsync()
129 CreatePipelineAsyncTask task; member in CreatePipelineAsyncTest
152 CreatePipelineAsyncTask* task = static_cast<CreatePipelineAsyncTask*>(userdata); in TEST_P()
153 task in TEST_P()
[all...]
/third_party/ffmpeg/libavfilter/dnn/
H A Ddnn_backend_common.c56 int ff_dnn_fill_task(TaskItem *task, DNNExecBaseParams *exec_params, void *backend_model, int async, int do_ioproc) { in ff_dnn_fill_task() argument
57 if (task == NULL || exec_params == NULL || backend_model == NULL) in ff_dnn_fill_task()
64 task->do_ioproc = do_ioproc; in ff_dnn_fill_task()
65 task->async = async; in ff_dnn_fill_task()
66 task->input_name = exec_params->input_name; in ff_dnn_fill_task()
67 task->in_frame = exec_params->in_frame; in ff_dnn_fill_task()
68 task->out_frame = exec_params->out_frame; in ff_dnn_fill_task()
69 task->model = backend_model; in ff_dnn_fill_task()
70 task->nb_output = exec_params->nb_output; in ff_dnn_fill_task()
71 task in ff_dnn_fill_task()
144 TaskItem *task = ff_queue_peek_front(task_queue); ff_dnn_get_result_common() local
162 ff_dnn_fill_gettingoutput_task(TaskItem *task, DNNExecBaseParams *exec_params, void *backend_model, int input_height, int input_width, void *ctx) ff_dnn_fill_gettingoutput_task() argument
[all...]
H A Ddnn_backend_openvino.c125 TaskItem *task; in fill_model_input_ov() local
129 task = lltask->task; in fill_model_input_ov()
131 status = ie_infer_request_get_blob(request->infer_request, task->input_name, &input_blob); in fill_model_input_ov()
133 av_log(ctx, AV_LOG_ERROR, "Failed to get input blob with name %s\n", task->input_name); in fill_model_input_ov()
168 task = lltask->task; in fill_model_input_ov()
171 if (task->do_ioproc) { in fill_model_input_ov()
173 ov_model->model->frame_pre_proc(task->in_frame, &input, ov_model->model->filter_ctx); in fill_model_input_ov()
175 ff_proc_from_frame_to_dnn(task in fill_model_input_ov()
204 TaskItem *task = lltask->task; infer_completion_callback() local
448 TaskItem *task; execute_model_ov() local
590 extract_lltask_from_task(DNNFunctionType func_type, TaskItem *task, Queue *lltask_queue, DNNExecBaseParams *exec_params) extract_lltask_from_task() argument
662 TaskItem task; get_output_ov() local
788 TaskItem *task; ff_dnn_execute_model_ov() local
[all...]
H A Ddnn_backend_native.c51 static int extract_lltask_from_task(TaskItem *task, Queue *lltask_queue) in extract_lltask_from_task() argument
53 NativeModel *native_model = task->model; in extract_lltask_from_task()
61 task->inference_todo = 1; in extract_lltask_from_task()
62 task->inference_done = 0; in extract_lltask_from_task()
63 lltask->task = task; in extract_lltask_from_task()
105 TaskItem task; in get_output_native() local
114 ret = ff_dnn_fill_gettingoutput_task(&task, &exec_params, native_model, input_height, input_width, ctx); in get_output_native()
119 ret = extract_lltask_from_task(&task, native_model->lltask_queue); in get_output_native()
121 av_log(ctx, AV_LOG_ERROR, "unable to extract last level task fro in get_output_native()
308 TaskItem *task = NULL; execute_model_native() local
439 TaskItem *task; ff_dnn_execute_model_native() local
[all...]
/third_party/python/Modules/
H A D_asynciomodule.c88 FutureObj_HEAD(task)
1879 TaskStepMethWrapper_new(TaskObj *task, PyObject *arg) in TaskStepMethWrapper_new() argument
1887 Py_INCREF(task); in TaskStepMethWrapper_new()
1888 o->sw_task = task; in TaskStepMethWrapper_new()
1909 register_task(PyObject *task) in register_task() argument
1914 &PyId_add, task); in register_task()
1924 unregister_task(PyObject *task) in unregister_task() argument
1929 &PyId_discard, task); in unregister_task()
1939 enter_task(PyObject *loop, PyObject *task) in enter_task() argument
1952 "Cannot enter into task in enter_task()
1966 leave_task(PyObject *loop, PyObject *task) leave_task() argument
2061 TaskObj_clear(TaskObj *task) TaskObj_clear() argument
2072 TaskObj_traverse(TaskObj *task, visitproc visit, void *arg) TaskObj_traverse() argument
2083 TaskObj_get_log_destroy_pending(TaskObj *task, void *Py_UNUSED(ignored)) TaskObj_get_log_destroy_pending() argument
2094 TaskObj_set_log_destroy_pending(TaskObj *task, PyObject *val, void *Py_UNUSED(ignored)) TaskObj_set_log_destroy_pending() argument
2109 TaskObj_get_must_cancel(TaskObj *task, void *Py_UNUSED(ignored)) TaskObj_get_must_cancel() argument
2120 TaskObj_get_coro(TaskObj *task, void *Py_UNUSED(ignored)) TaskObj_get_coro() argument
2131 TaskObj_get_fut_waiter(TaskObj *task, void *Py_UNUSED(ignored)) TaskObj_get_fut_waiter() argument
2142 TaskObj_repr(TaskObj *task) TaskObj_repr() argument
2423 TaskObj_finalize(TaskObj *task) TaskObj_finalize() argument
2548 TaskObj *task = (TaskObj *)self; TaskObj_dealloc() local
2571 task_call_step_soon(TaskObj *task, PyObject *arg) task_call_step_soon() argument
2584 task_set_error_soon(TaskObj *task, PyObject *et, const char *format, ...) task_set_error_soon() argument
2631 task_step_impl(TaskObj *task, PyObject *exc) task_step_impl() argument
2982 task_step(TaskObj *task, PyObject *exc) task_step() argument
3011 task_wakeup(TaskObj *task, PyObject *o) task_wakeup() argument
3182 _asyncio__register_task_impl(PyObject *module, PyObject *task) _asyncio__register_task_impl() argument
3203 _asyncio__unregister_task_impl(PyObject *module, PyObject *task) _asyncio__unregister_task_impl() argument
3227 _asyncio__enter_task_impl(PyObject *module, PyObject *loop, PyObject *task) _asyncio__enter_task_impl() argument
3251 _asyncio__leave_task_impl(PyObject *module, PyObject *loop, PyObject *task) _asyncio__leave_task_impl() argument
[all...]
/third_party/protobuf/js/
H A Dgulpfile.js56 gulp.task('genproto_well_known_types_closure', function (cb) {
65 gulp.task('genproto_group1_closure', function (cb) {
74 gulp.task('genproto_group2_closure', function (cb) {
83 gulp.task('genproto_well_known_types_commonjs', function (cb) {
92 gulp.task('genproto_group1_commonjs', function (cb) {
101 gulp.task('genproto_group2_commonjs', function (cb) {
110 gulp.task('genproto_commonjs_wellknowntypes', function (cb) {
119 gulp.task('genproto_wellknowntypes', function (cb) {
127 gulp.task('genproto_group3_commonjs_strict', function (cb) {
148 gulp.task('dis
[all...]
/third_party/node/deps/v8/src/d8/
H A Dd8-platforms.cc55 void CallOnWorkerThread(std::unique_ptr<Task> task) override {
56 // We post worker tasks on the foreground task runner of the
57 // {kProcessGlobalPredictablePlatformWorkerTaskQueue} isolate. The task
66 ->PostTask(std::move(task));
69 void CallDelayedOnWorkerThread(std::unique_ptr<Task> task,
132 // When the platform shuts down, all task runners must be freed.
174 void CallOnWorkerThread(std::unique_ptr<Task> task) override {
175 platform_->CallOnWorkerThread(MakeDelayedTask(std::move(task)));
178 void CallDelayedOnWorkerThread(std::unique_ptr<Task> task,
180 platform_->CallDelayedOnWorkerThread(MakeDelayedTask(std::move(task)),
258 DelayedTask(std::unique_ptr<Task> task, int32_t delay_ms) DelayedTask() argument
273 DelayedIdleTask(std::unique_ptr<IdleTask> task, int32_t delay_ms) DelayedIdleTask() argument
327 MakeDelayedTask(std::unique_ptr<Task> task) MakeDelayedTask() argument
332 MakeDelayedIdleTask( std::unique_ptr<IdleTask> task) MakeDelayedIdleTask() argument
338 MakeDelayedJob(std::unique_ptr<JobTask> task) MakeDelayedJob() argument
[all...]
/third_party/node/src/
H A Dnode_platform.cc42 while (std::unique_ptr<Task> task = pending_worker_tasks->BlockingPop()) { in PlatformWorkerThread()
43 task->Run(); in PlatformWorkerThread()
74 void PostDelayedTask(std::unique_ptr<Task> task, double delay_in_seconds) { in PostDelayedTask() argument
75 tasks_.Push(std::make_unique<ScheduleTask>(this, std::move(task), in PostDelayedTask()
102 while (std::unique_ptr<Task> task = scheduler->tasks_.Pop()) in FlushTasks()
103 task->Run(); in FlushTasks()
127 std::unique_ptr<Task> task, in ScheduleTask()
130 task_(std::move(task)), in ScheduleTask()
155 std::unique_ptr<Task> task(static_cast<Task*>(timer->data)); in TakeTimerTask()
161 return task; in TakeTimerTask()
126 ScheduleTask(DelayedTaskScheduler* scheduler, std::unique_ptr<Task> task, double delay_in_seconds) ScheduleTask() argument
204 PostTask(std::unique_ptr<Task> task) PostTask() argument
208 PostDelayedTask(std::unique_ptr<Task> task, double delay_in_seconds) PostDelayedTask() argument
248 PostIdleTask(std::unique_ptr<v8::IdleTask> task) PostIdleTask() argument
252 PostTask(std::unique_ptr<Task> task) PostTask() argument
262 PostDelayedTask( std::unique_ptr<Task> task, double delay_in_seconds) PostDelayedTask() argument
277 PostNonNestableTask(std::unique_ptr<Task> task) PostNonNestableTask() argument
281 PostNonNestableDelayedTask( std::unique_ptr<Task> task, double delay_in_seconds) PostNonNestableDelayedTask() argument
417 RunForegroundTask(std::unique_ptr<Task> task) RunForegroundTask() argument
434 DeleteFromScheduledTasks(DelayedTask* task) DeleteFromScheduledTasks() argument
491 std::unique_ptr<Task> task = std::move(tasks.front()); FlushForegroundTasksInternal() local
499 CallOnWorkerThread(std::unique_ptr<Task> task) CallOnWorkerThread() argument
503 CallDelayedOnWorkerThread(std::unique_ptr<Task> task, double delay_in_seconds) CallDelayedOnWorkerThread() argument
578 Push(std::unique_ptr<T> task) Push() argument
[all...]

Completed in 19 milliseconds

12345678910>>...12