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);