| /third_party/libwebsockets/lib/misc/threadpool/ |
| D | threadpool.c | 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()
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->acc_syncing) in __lws_threadpool_task_dump()
143 syncms = (int)task->acc_syncing; in __lws_threadpool_task_dump()
145 if (!task->done) { in __lws_threadpool_task_dump()
149 "run: %d%%, sync: %d%%)", task->name, task->status, in __lws_threadpool_task_dump()
[all …]
|
| /third_party/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_rast.c | 95 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->color_tiles[i] = scene->cbufs[i].map + in lp_rast_tile_begin()
[all …]
|
| D | lp_cs_tpool.c | 45 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->iter_start += iter_per_thread; in lp_cs_tpool_worker()
69 if (task->iter_start == task->iter_total) in lp_cs_tpool_worker()
70 list_del(&task->list); in lp_cs_tpool_worker()
[all …]
|
| D | lp_rast_linear.c | 46 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->x, in lp_rast_linear_tile()
[all …]
|
| D | lp_rast_rect.c | 88 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
[all …]
|
| D | lp_rast_priv.h | 55 #define BEGIN_JIT_CALL(state, task) \ argument
59 jit_task = task; \
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->color_tiles[buf]); in lp_rast_get_color_block_pointer()
174 unsigned pixel_offset = px * task->scene->cbufs[buf].format_bytes + in lp_rast_get_color_block_pointer()
[all …]
|
| D | lp_rast_linear_fallback.c | 91 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, inputs, ix0, iy0, in lp_rast_linear_rect_fallback()
[all …]
|
| /third_party/libuv/test/ |
| D | runner.c | 86 task_entry_t* task; in run_tests() local
91 for (task = TASKS; task->main; task++, actual++) { in run_tests()
92 if (!task->is_helper) { in run_tests()
109 for (task = TASKS; task->main; task++) { in run_tests()
110 if (task->is_helper) { in run_tests()
114 test_result = run_test(task->task_name, benchmark_output, current); in run_tests()
170 task_entry_t* task; in run_test() local
189 for (task = TASKS; task->main; task++) { in run_test()
190 if (task->is_helper && strcmp(test, task->process_name) == 0) { in run_test()
191 return task->main(); in run_test()
[all …]
|
| /third_party/musl/libc-test/src/functionalext/unittest/ |
| D | unit_test_mock_dynlink.c | 24 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->dyn_map, task->dyn_map_len); in free_task()
[all …]
|
| /third_party/musl/ldso/linux/ |
| D | dynlink_rand.c | 154 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->dyn_map, task->dyn_map_len); in free_task()
[all …]
|
| D | dynlink.c | 185 static bool map_library_header(struct loadtask *task);
186 static bool task_map_library(struct loadtask *task, struct reserved_address_params *reserved_params…
187 static bool resolve_fd_to_realpath(struct loadtask *task);
188 static bool load_library_header(struct loadtask *task);
189 static void task_load_library(struct loadtask *task, struct reserved_address_params *reserved_param…
196 static void open_library_by_path(const char *name, const char *s, struct loadtask *task, struct zip…
197 …_open_by_task(int fd, const char *name, ns_t *namespace, struct loadtask *task, struct zip_info *z…
3321 struct loadtask *task = NULL; in dlopen_impl() local
3424 task = create_loadtask(file, head, ns, true); in dlopen_impl()
3425 if (!task) { in dlopen_impl()
[all …]
|
| /third_party/musl/porting/linux/user/ldso/ |
| D | dynlink_rand.c | 154 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->dyn_map, task->dyn_map_len); in free_task()
[all …]
|
| D | dynlink.c | 185 static bool map_library_header(struct loadtask *task);
186 static bool task_map_library(struct loadtask *task, struct reserved_address_params *reserved_params…
187 static bool resolve_fd_to_realpath(struct loadtask *task);
188 static bool load_library_header(struct loadtask *task);
189 static void task_load_library(struct loadtask *task, struct reserved_address_params *reserved_param…
196 static void open_library_by_path(const char *name, const char *s, struct loadtask *task, struct zip…
197 …_open_by_task(int fd, const char *name, ns_t *namespace, struct loadtask *task, struct zip_info *z…
3325 struct loadtask *task = NULL; in dlopen_impl() local
3428 task = create_loadtask(file, head, ns, true); in dlopen_impl()
3429 if (!task) { in dlopen_impl()
[all …]
|
| /third_party/mesa3d/src/gallium/frontends/nine/ |
| D | threadpool.c | 49 struct threadpool_task *task; in threadpool_worker() local
62 task = pool->workqueue; in threadpool_worker()
63 pool->workqueue = task->next; 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, *previous; in _mesa_threadpool_queue_task() local
152 task = calloc(1, sizeof(*task)); in _mesa_threadpool_queue_task()
153 if (!task) { in _mesa_threadpool_queue_task()
158 task->work = work; in _mesa_threadpool_queue_task()
[all …]
|
| /third_party/skia/third_party/externals/dawn/src/tests/end2end/ |
| D | CreatePipelineAsyncTests.cpp | 68 ValidateCreateComputePipelineAsync(&task); in ValidateCreateComputePipelineAsync()
109 ValidateCreateRenderPipelineAsync(&task); in ValidateCreateRenderPipelineAsync()
121 CreatePipelineAsyncTask* task = static_cast<CreatePipelineAsyncTask*>(userdata); in DoCreateRenderPipelineAsync() local
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() local
153 task->computePipeline = wgpu::ComputePipeline::Acquire(returnPipeline); in TEST_P()
[all …]
|
| /third_party/skia/src/gpu/ |
| D | GrDDLTask.cpp | 23 for (auto& task : fDDL->priv().renderTasks()) { in GrDDLTask() local
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()
38 for (auto& task : fDDL->priv().renderTasks()) { in endFlush() local
39 task->endFlush(drawingManager); in endFlush()
46 for (auto& task : fDDL->priv().renderTasks()) { in disown() local
47 task->disown(drawingManager); in disown()
58 for (auto& task : fDDL->priv().renderTasks()) { in onIsUsed() local
59 if (task->isUsed(proxy)) { in onIsUsed()
[all …]
|
| /third_party/python/Lib/asyncio/ |
| D | base_tasks.py | 8 def _task_repr_info(task): argument
9 info = base_futures._future_repr_info(task)
11 if task._must_cancel:
15 info.insert(1, 'name=%r' % task.get_name())
17 coro = coroutines._format_coroutine(task._coro)
20 if task._fut_waiter is not None:
25 def _task_get_stack(task, limit): argument
27 if hasattr(task._coro, 'cr_frame'):
29 f = task._coro.cr_frame
30 elif hasattr(task._coro, 'gi_frame'):
[all …]
|
| /third_party/node/deps/v8/src/libplatform/ |
| D | default-foreground-task-runner.cc | 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() argument
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_seconds, kNestable, guard); in PostDelayedTask()
73 std::unique_ptr<Task> task, double delay_in_seconds) { in PostNonNestableDelayedTask() argument
75 PostDelayedTaskLocked(std::move(task), delay_in_seconds, kNonNestable, guard); in PostNonNestableDelayedTask()
[all …]
|
| /third_party/ffmpeg/libavfilter/dnn/ |
| D | dnn_backend_common.c | 56 int ff_dnn_fill_task(TaskItem *task, DNNExecBaseParams *exec_params, void *backend_model, int async… 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->output_names = exec_params->output_names; in ff_dnn_fill_task()
[all …]
|
| D | dnn_backend_native.c | 51 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,… in get_output_native()
119 ret = extract_lltask_from_task(&task, native_model->lltask_queue); in get_output_native()
126 *output_width = task.out_frame->width; in get_output_native()
127 *output_height = task.out_frame->height; in get_output_native()
[all …]
|
| D | dnn_backend_openvino.c | 125 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_frame, &input, ctx); in fill_model_input_ov()
180 ff_frame_to_dnn_detect(task->in_frame, &input, ctx); in fill_model_input_ov()
183 ff_frame_to_dnn_classify(task->in_frame, &input, lltask->bbox_index, ctx); in fill_model_input_ov()
[all …]
|
| /third_party/typescript/ |
| D | Gulpfile.mjs | 20 const { src, dest, task, parallel, series, watch } = gulp;
26 task("scripts", buildScripts);
27 task("scripts").description = "Builds files in the 'scripts' folder.";
46 task("lib", generateLibs);
47 task("lib").description = "Builds the library targets";
62 task("generate-diagnostics", generateDiagnostics);
63 task("generate-diagnostics").description = "Generates a diagnostic file in TypeScript based on an i…
68 const watchDiagnostics = () => watch(["src/compiler/diagnosticMessages.json"], task("generate-diagn…
107 task("tsc", series(lkgPreBuild, buildTsc));
108 task("tsc").description = "Builds the command-line compiler";
[all …]
|
| /third_party/typescript/tests/baselines/reference/user/ |
| D | grunt.log | 4 lib/grunt.js(91,13): error TS2551: Property 'task' does not exist on type 'typeof import("/grunt/gr…
5 lib/grunt.js(96,34): error TS2551: Property 'task' does not exist on type 'typeof import("/grunt/gr…
48 lib/grunt/help.js(81,9): error TS2551: Property 'task' does not exist on type 'typeof import("/grun…
49 lib/grunt/help.js(85,21): error TS2551: Property 'task' does not exist on type 'typeof import("/gru…
50 lib/grunt/help.js(87,22): error TS2551: Property 'task' does not exist on type 'typeof import("/gru…
51 lib/grunt/task.js(26,23): error TS2345: Argument of type 'any' is not assignable to parameter of ty…
52 lib/grunt/task.js(39,24): error TS2339: Property 'fail' does not exist on type 'typeof import("/gru…
53 lib/grunt/task.js(44,22): error TS2339: Property 'fail' does not exist on type 'typeof import("/gru…
54 lib/grunt/task.js(50,33): error TS2339: Property 'config' does not exist on type 'typeof import("/g…
55 lib/grunt/task.js(55,15): error TS2339: Property 'config' does not exist on type 'typeof import("/g…
[all …]
|
| /third_party/glib/patch/ |
| D | backport-gdbusconnection-Fix-double-unref-on-timeout-cancel-sending-a-message.patch | 54 @@ -1822,7 +1822,7 @@ send_message_data_deliver_reply_unlocked (GTask *task,
59 +/* Called from a user thread, lock is not held; @task is (transfer full) */
61 send_message_data_deliver_error (GTask *task,
63 @@ -1849,13 +1849,14 @@ send_message_data_deliver_error (GTask *task,
67 -/* Called from a user thread, lock is not held; @task is (transfer full) */
68 +/* Called from a user thread, lock is not held; @task is (transfer none) */
72 GTask *task = user_data;
74 - send_message_data_deliver_error (task, G_IO_ERROR, G_IO_ERROR_CANCELLED,
75 + g_object_ref (task);
76 + send_message_data_deliver_error (g_steal_pointer (&task), G_IO_ERROR, G_IO_ERROR_CANCELLED,
[all …]
|
| /third_party/unity/test/ |
| D | rakefile | 25 task :prepare_for_tests => TEMP_DIRS
36 …task :all => [:clean, :prepare_for_tests, 'test:scripts', 'test:unit', :style, 'test:fixture', 'te…
37 …task :ci => [:clean, :prepare_for_tests, 'test:scripts', 'test:unit', :style, 'test:make', 'test:f…
40 task :unit => [:prepare_for_tests] do
47 task File.basename(f,'.c').sub('test_unity_','') => [:prepare_for_tests] do
54 task :scripts => [:prepare_for_tests] do
61 task :make => [:prepare_for_tests] do
66 task :fixture => [:prepare_for_tests] do
71 task :memory => [:prepare_for_tests] do
76 task :examples => [:prepare_for_tests] do
[all …]
|