Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 667) sorted by relevance

12345678910>>...27

/third_party/gstreamer/gstreamer/gst/
Dgsttask.c200 static void gst_task_func (GstTask * task);
239 gst_task_init (GstTask * task) in gst_task_init() argument
243 klass = GST_TASK_GET_CLASS (task); in gst_task_init()
245 task->priv = gst_task_get_instance_private (task); in gst_task_init()
246 task->running = FALSE; in gst_task_init()
247 task->thread = NULL; in gst_task_init()
248 task->lock = NULL; in gst_task_init()
249 g_cond_init (&task->cond); in gst_task_init()
250 SET_TASK_STATE (task, GST_TASK_STOPPED); in gst_task_init()
256 task->priv->pool = gst_object_ref (klass->pool); in gst_task_init()
[all …]
Dgsttask.h42 #define GST_TASK(task) (G_TYPE_CHECK_INSTANCE_CAST ((task), GST_TYPE_TASK, GstTask… argument
43 #define GST_IS_TASK(task) (G_TYPE_CHECK_INSTANCE_TYPE ((task), GST_TYPE_TASK)) argument
46 #define GST_TASK_GET_CLASS(task) (G_TYPE_INSTANCE_GET_CLASS ((task), GST_TYPE_TASK, GstTaskC… argument
47 #define GST_TASK_CAST(task) ((GstTask*)(task)) argument
73 #define GST_TASK_STATE(task) (GST_TASK_CAST(task)->state) argument
81 #define GST_TASK_GET_COND(task) (&GST_TASK_CAST(task)->cond) argument
88 #define GST_TASK_WAIT(task) g_cond_wait(GST_TASK_GET_COND (task), GST_OBJECT_GET_LOCK (… argument
95 #define GST_TASK_SIGNAL(task) g_cond_signal(GST_TASK_GET_COND (task)) argument
102 #define GST_TASK_BROADCAST(task) g_cond_broadcast(GST_TASK_GET_COND (task)) argument
110 #define GST_TASK_GET_LOCK(task) (GST_TASK_CAST(task)->lock) argument
[all …]
/third_party/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() 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/
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->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 …]
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->color_tiles[i] = scene->cbufs[i].map + in lp_rast_tile_begin()
[all …]
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->x, in lp_rast_linear_tile()
[all …]
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
[all …]
Dlp_rast_priv.h55 #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 …]
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, inputs, ix0, iy0, in lp_rast_linear_rect_fallback()
[all …]
/third_party/libuv/test/
Drunner.c86 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/
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->dyn_map, task->dyn_map_len); in free_task()
[all …]
/third_party/gstreamer/gstplugins_bad/gst/rtmp2/rtmp/
Drtmpclient.c313 static void socket_connect (GTask * task);
318 static void send_connect (GTask * task);
321 static void send_secure_token_response (GTask * task,
364 GTask *task; in gst_rtmp_client_connect_async() local
375 task = g_task_new (NULL, cancellable, callback, user_data); in gst_rtmp_client_connect_async()
377 g_task_set_task_data (task, connect_task_data_new (location), in gst_rtmp_client_connect_async()
380 socket_connect (task); in gst_rtmp_client_connect_async()
384 socket_connect (GTask * task) in socket_connect() argument
386 ConnectTaskData *data = g_task_get_task_data (task); in socket_connect()
405 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED, in socket_connect()
[all …]
Drtmputils.c59 GTask *task; in gst_rtmp_input_stream_read_all_bytes_async() local
64 task = g_task_new (stream, cancellable, callback, user_data); in gst_rtmp_input_stream_read_all_bytes_async()
68 g_task_set_task_data (task, ba, (GDestroyNotify) g_byte_array_unref); in gst_rtmp_input_stream_read_all_bytes_async()
71 cancellable, read_all_bytes_done, task); in gst_rtmp_input_stream_read_all_bytes_async()
79 GTask *task = user_data; in read_all_bytes_done() local
80 GByteArray *ba = g_task_get_task_data (task); in read_all_bytes_done()
88 g_task_return_error (task, error); in read_all_bytes_done()
89 g_object_unref (task); in read_all_bytes_done()
96 g_task_return_pointer (task, bytes, (GDestroyNotify) g_bytes_unref); in read_all_bytes_done()
97 g_object_unref (task); in read_all_bytes_done()
[all …]
Drtmphandshake.c146 GTask *task; in gst_rtmp_client_handshake() local
154 task = g_task_new (stream, cancellable, callback, user_data); in gst_rtmp_client_handshake()
156 g_task_set_task_data (task, data, handshake_data_free); in gst_rtmp_client_handshake()
164 g_task_get_cancellable (task), client_handshake1_done, task); in gst_rtmp_client_handshake()
175 GTask *task = user_data; in client_handshake1_done() local
176 GIOStream *stream = g_task_get_source_object (task); in client_handshake1_done()
184 g_task_return_error (task, error); in client_handshake1_done()
185 g_object_unref (task); in client_handshake1_done()
191 G_PRIORITY_DEFAULT, g_task_get_cancellable (task), in client_handshake1_done()
192 client_handshake2_done, task); in client_handshake1_done()
[all …]
/third_party/musl/porting/linux/user/ldso/
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->dyn_map, task->dyn_map_len); in free_task()
[all …]
Ddynlink.c184 static bool map_library_header(struct loadtask *task);
185 static bool task_map_library(struct loadtask *task, struct reserved_address_params *reserved_params…
186 static bool resolve_fd_to_realpath(struct loadtask *task);
187 static bool load_library_header(struct loadtask *task);
188 static void task_load_library(struct loadtask *task, struct reserved_address_params *reserved_param…
195 static void open_library_by_path(const char *name, const char *s, struct loadtask *task, struct zip…
196 …_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/mesa3d/src/gallium/frontends/nine/
Dthreadpool.c49 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/
DCreatePipelineAsyncTests.cpp68 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/
DGrDDLTask.cpp23 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/ffmpeg/libavfilter/dnn/
Ddnn_backend_openvino.c133 TaskItem *task = request->tasks[0]; in fill_model_input_ov() local
135 status = ie_infer_request_get_blob(request->infer_request, task->input_name, &input_blob); in fill_model_input_ov()
137 av_log(ctx, AV_LOG_ERROR, "Failed to get input blob with name %s\n", task->input_name); in fill_model_input_ov()
167 task = request->tasks[i]; in fill_model_input_ov()
168 if (task->do_ioproc) { in fill_model_input_ov()
170 ov_model->model->pre_proc(task->in_frame, &input, ov_model->model->filter_ctx); in fill_model_input_ov()
172 ff_proc_from_frame_to_dnn(task->in_frame, &input, ov_model->model->func_type, ctx); in fill_model_input_ov()
189 TaskItem *task = request->tasks[0]; in infer_completion_callback() local
190 SafeQueue *requestq = task->ov_model->request_queue; in infer_completion_callback()
194 OVContext *ctx = &task->ov_model->ctx; in infer_completion_callback()
[all …]
/third_party/python/Lib/asyncio/
Dbase_tasks.py8 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/
Ddefault-foreground-task-runner.cc39 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/gstreamer/gstplugins_bad/ext/webrtc/
Dwebrtcsctptransport.c58 struct task struct
67 _execute_task (GstWebRTCBin * webrtc, struct task *task) in _execute_task() argument
69 if (task->func) in _execute_task()
70 task->func (task->sctp, task->user_data); in _execute_task()
75 _free_task (struct task *task) in _free_task() argument
77 gst_object_unref (task->sctp); in _free_task()
79 if (task->notify) in _free_task()
80 task->notify (task->user_data); in _free_task()
81 g_free (task); in _free_task()
88 struct task *task = g_new0 (struct task, 1); in _sctp_enqueue_task() local
[all …]
/third_party/typescript/
DGulpfile.mjs20 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/unity/test/
Drakefile25 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 …]

12345678910>>...27