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,
60 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy() argument
107 nxt_job_start(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_start() argument
109 nxt_debug(task, "%s start", job->name); in nxt_job_start()
114 job->engine = task->thread->engine; in nxt_job_start()
117 job->task, job, (void *) handler); in nxt_job_start()
128 handler(job->task, job, job->data); in nxt_job_start()
135 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline() argument
143 nxt_debug(task, "%s thread", job->name); in nxt_job_thread_trampoline()
146 nxt_job_return(task, job, job->abort_handler); in nxt_job_thread_trampoline()
149 handler(job->task, job, job->data); in nxt_job_thread_trampoline()
155 nxt_job_return(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_return() argument
157 nxt_debug(task, "%s return", job->name); in nxt_job_return()
163 job->task, job, (void *) handler); in nxt_job_return()
171 nxt_debug(task, "%s cancellation", job->name); in nxt_job_return()
175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
176 handler, job->task, job, job->data); in nxt_job_return()
181 nxt_job_thread_return_handler(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_return_handler() argument
189 job->task->thread = task->thread; in nxt_job_thread_return_handler()
192 nxt_debug(task, "%s cancellation", job->name); in nxt_job_thread_return_handler()
196 handler(job->task, job, job->data); in nxt_job_thread_return_handler()