Searched refs:job (Results 1 – 4 of 4) sorted by last modified time
| /unit/src/ |
| H A D | nxt_router.c | 1300 job = obj; in nxt_router_conf_wait()
3359 job->work.task = &job->task; in nxt_router_engine_joints_create()
3360 job->work.obj = job; in nxt_router_engine_joints_create()
3407 job->work.task = &job->task; in nxt_router_engine_quit()
3437 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3438 job->work.obj = job; in nxt_router_engine_joints_delete()
3679 job = obj; in nxt_router_listen_socket_create()
3704 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_create()
3741 job = obj; in nxt_router_listen_socket_update()
3758 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_update()
[all …]
|
| H A D | nxt_job.c | 46 return job; in nxt_job_create()
66 job = data; in nxt_job_destroy()
77 nxt_mp_free(job->mem_pool, job); in nxt_job_destroy()
119 job->task, job, (void *) handler); in nxt_job_start()
130 handler(job->task, job, job->data); in nxt_job_start()
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()
165 job->task, job, (void *) handler); in nxt_job_return()
167 nxt_event_engine_post(job->engine, &job->work); in nxt_job_return()
178 handler, job->task, job, job->data); in nxt_job_return()
[all …]
|
| H A D | nxt_job.h | 60 NXT_EXPORT void nxt_job_init(nxt_job_t *job, size_t size);
62 NXT_EXPORT nxt_int_t nxt_job_cleanup_add(nxt_mp_t *mp, nxt_job_t *job);
64 NXT_EXPORT void nxt_job_start(nxt_task_t *task, nxt_job_t *job,
66 NXT_EXPORT void nxt_job_return(nxt_task_t *task, nxt_job_t *job,
70 #define nxt_job_cancel(job) \ argument
71 (job)->cancel = 1
76 #define nxt_job_set_name(job, text) \ argument
77 (job)->name = text
81 #define nxt_job_set_name(job, text) argument
|
| H A D | nxt_event_conn_job_sendfile.c | 11 nxt_job_t job; member
61 jbs->job.data = c; in nxt_event_conn_job_sendfile_start()
62 nxt_job_set_name(&jbs->job, "job sendfile"); in nxt_event_conn_job_sendfile_start()
77 jbs->job.thread_pool = c->u.thread_pool; in nxt_event_conn_job_sendfile_start()
78 jbs->job.log = c->socket.log; in nxt_event_conn_job_sendfile_start()
86 nxt_job_start(task, &jbs->job, nxt_event_conn_job_sendfile_handler); in nxt_event_conn_job_sendfile_start()
150 nxt_job_return(task, &jbs->job, jbs->ready_handler); in nxt_event_conn_job_sendfile_handler()
155 nxt_work_set(&jbs->job.work, nxt_event_conn_job_sendfile_handler, in nxt_event_conn_job_sendfile_handler()
156 jbs->job.task, jbs, c); in nxt_event_conn_job_sendfile_handler()
158 nxt_thread_pool_post(task->thread->thread_pool, &jbs->job.work); in nxt_event_conn_job_sendfile_handler()
|