Lines Matching refs:job

19     nxt_job_t  *job;  in nxt_job_create()  local
27 job = nxt_mp_zget(mp, size); in nxt_job_create()
31 job = nxt_mp_zalloc(mp, size); in nxt_job_create()
35 if (nxt_slow_path(job == NULL)) { in nxt_job_create()
39 job->cache_size = (uint16_t) cache_size; in nxt_job_create()
40 job->mem_pool = mp; in nxt_job_create()
41 nxt_job_set_name(job, "job"); in nxt_job_create()
44 nxt_queue_self(&job->link); in nxt_job_create()
46 return job; in nxt_job_create()
51 nxt_job_init(nxt_job_t *job, size_t size) in nxt_job_init() argument
53 nxt_memzero(job, size); in nxt_job_init()
55 nxt_job_set_name(job, "job"); in nxt_job_init()
57 nxt_queue_self(&job->link); in nxt_job_init()
64 nxt_job_t *job; in nxt_job_destroy() local
66 job = data; in nxt_job_destroy()
68 nxt_queue_remove(&job->link); in nxt_job_destroy()
70 if (job->cache_size == 0) { in nxt_job_destroy()
72 if (job->mem_pool != NULL) { in nxt_job_destroy()
73 nxt_mp_destroy(job->mem_pool); in nxt_job_destroy()
77 nxt_mp_free(job->mem_pool, job); in nxt_job_destroy()
85 nxt_job_cleanup_add(nxt_mp_t *mp, nxt_job_t *job)
93 mpcl->data = job;
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()
113 if (job->thread_pool != NULL) { in nxt_job_start()
116 job->engine = task->thread->engine; in nxt_job_start()
118 nxt_work_set(&job->work, nxt_job_thread_trampoline, in nxt_job_start()
119 job->task, job, (void *) handler); in nxt_job_start()
121 ret = nxt_thread_pool_post(job->thread_pool, &job->work); in nxt_job_start()
127 handler = job->abort_handler; in nxt_job_start()
130 handler(job->task, job, job->data); in nxt_job_start()
139 nxt_job_t *job; in nxt_job_thread_trampoline() local
142 job = obj; in nxt_job_thread_trampoline()
145 nxt_debug(task, "%s thread", job->name); in nxt_job_thread_trampoline()
147 if (nxt_slow_path(job->cancel)) { 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()
161 if (job->engine != NULL) { in nxt_job_return()
164 nxt_work_set(&job->work, nxt_job_thread_return_handler, in nxt_job_return()
165 job->task, job, (void *) handler); in nxt_job_return()
167 nxt_event_engine_post(job->engine, &job->work); in nxt_job_return()
172 if (nxt_slow_path(job->cancel)) { in nxt_job_return()
173 nxt_debug(task, "%s cancellation", job->name); in nxt_job_return()
174 handler = job->abort_handler; in nxt_job_return()
178 handler, job->task, job, job->data); in nxt_job_return()
185 nxt_job_t *job; in nxt_job_thread_return_handler() local
188 job = obj; in nxt_job_thread_return_handler()
191 job->task->thread = task->thread; in nxt_job_thread_return_handler()
193 if (nxt_slow_path(job->cancel)) { in nxt_job_thread_return_handler()
194 nxt_debug(task, "%s cancellation", job->name); in nxt_job_thread_return_handler()
195 handler = job->abort_handler; in nxt_job_thread_return_handler()
198 handler(job->task, job, job->data); in nxt_job_thread_return_handler()