11,12c11,12 < static void nxt_job_thread_trampoline(nxt_thread_t *thr, void *obj, void *data); < static void nxt_job_thread_return_handler(nxt_thread_t *thr, void *obj, --- > static void nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data); > static void nxt_job_thread_return_handler(nxt_task_t *task, void *obj, 46a47,48 > job->task.ident = nxt_task_next_ident(); > 58a61,62 > > job->task.ident = nxt_task_next_ident(); 106c110 < nxt_job_start(nxt_thread_t *thr, nxt_job_t *job, nxt_work_handler_t handler) --- > nxt_job_start(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) 108c112 < nxt_log_debug(thr->log, "%s start", job->name); --- > nxt_debug(task, "%s start", job->name); 115c119,120 < job->engine = thr->engine; --- > job->engine = task->thread->engine; > 117c122 < job, (void *) handler, job->log); --- > &job->task, job, (void *) handler); 127c132 < handler(thr, job, job->data); --- > handler(&job->task, job, job->data); 136c141 < nxt_job_thread_trampoline(nxt_thread_t *thr, void *obj, void *data) --- > nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) 144c149 < nxt_log_debug(thr->log, "%s thread", job->name); --- > job->task.log = job->log; 145a151,152 > nxt_debug(task, "%s thread", job->name); > 147c154 < nxt_job_return(thr, job, job->abort_handler); --- > nxt_job_return(task, job, job->abort_handler); 150c157 < handler(thr, job, job->data); --- > handler(&job->task, job, job->data); 158c165 < nxt_job_return(nxt_thread_t *thr, nxt_job_t *job, nxt_work_handler_t handler) --- > nxt_job_return(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) 160c167 < nxt_log_debug(thr->log, "%s return", job->name); --- > nxt_debug(task, "%s return", job->name); 167c174 < job, (void *) handler, job->log); --- > &job->task, job, (void *) handler, job->log); 174c181 < nxt_log_debug(thr->log, "%s cancellation", job->name); --- > nxt_debug(task, "%s cancellation", job->name); 178,179c185,186 < nxt_thread_work_queue_push(thr, &thr->work_queue.main, < handler, job, job->data, thr->log); --- > nxt_thread_work_queue_push(task->thread, &task->thread->work_queue.main, > handler, &job->task, job, job->data); 186c193 < nxt_job_thread_return_handler(nxt_thread_t *thr, void *obj, void *data) --- > nxt_job_thread_return_handler(nxt_task_t *task, void *obj, void *data) 193a201,202 > job->task.thread = task->thread; > 195c204 < nxt_log_debug(thr->log, "%s cancellation", job->name); --- > nxt_debug(task, "%s cancellation", job->name); 199c208 < handler(thr, job, job->data); --- > handler(&job->task, job, job->data);