Lines Matching refs:task
10 static void nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data);
11 static void nxt_job_thread_return_handler(nxt_task_t *task, void *obj,
62 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy() argument
109 nxt_job_start(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_start() argument
111 nxt_debug(task, "%s start", job->name); in nxt_job_start()
116 job->engine = task->thread->engine; in nxt_job_start()
119 job->task, job, (void *) handler); in nxt_job_start()
130 handler(job->task, job, job->data); in nxt_job_start()
137 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline() argument
145 nxt_debug(task, "%s thread", job->name); in nxt_job_thread_trampoline()
148 nxt_job_return(task, job, job->abort_handler); in nxt_job_thread_trampoline()
151 handler(job->task, job, job->data); in nxt_job_thread_trampoline()
157 nxt_job_return(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_return() argument
159 nxt_debug(task, "%s return", job->name); in nxt_job_return()
165 job->task, job, (void *) handler); in nxt_job_return()
173 nxt_debug(task, "%s cancellation", job->name); in nxt_job_return()
177 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
178 handler, job->task, job, job->data); in nxt_job_return()
183 nxt_job_thread_return_handler(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_return_handler() argument
191 job->task->thread = task->thread; in nxt_job_thread_return_handler()
194 nxt_debug(task, "%s cancellation", job->name); in nxt_job_thread_return_handler()
198 handler(job->task, job, job->data); in nxt_job_thread_return_handler()