| /unit/src/ |
| H A D | nxt_job.c | 44 return job; in nxt_job_create()
64 job = data; in nxt_job_destroy()
75 nxt_mp_free(job->mem_pool, job); in nxt_job_destroy()
117 job->task, job, (void *) handler); in nxt_job_start()
128 handler(job->task, job, job->data); in nxt_job_start()
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()
163 job->task, job, (void *) handler); in nxt_job_return()
165 nxt_event_engine_post(job->engine, &job->work); in nxt_job_return()
176 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_job_file_cache.c | 27 nxt_job_return(&jbf->job, jbf->ready_handler); in nxt_job_file_cache_read()
32 nxt_job_return(&jbf->job, jbf->error_handler); in nxt_job_file_cache_read()
37 jbf->job.thread_pool = NULL; in nxt_job_file_cache_read()
|
| 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()
|
| H A D | nxt_job_resolve.c | 34 host = nxt_mp_alloc(jbr->job.mem_pool, length); in nxt_job_resolve()
71 mp = jbr->job.mem_pool; in nxt_job_resolve()
128 nxt_mp_free(jbr->job.mem_pool, host); in nxt_job_resolve()
131 nxt_job_return(jbr->job.task, &jbr->job, handler); in nxt_job_resolve()
|
| H A D | nxt_job_file.h | 47 nxt_job_t job; member
71 NXT_EXPORT void nxt_job_file_read(nxt_task_t *task, nxt_job_t *job);
|
| H A D | nxt_job_file.c | 39 nxt_job_init(&jbf->job, sizeof(nxt_job_file_t)); in nxt_job_file_init()
53 nxt_job_file_read(nxt_task_t *task, nxt_job_t *job) in nxt_job_file_read() argument
55 nxt_job_start(task, job, nxt_job_file_open_and_read); in nxt_job_file_read()
137 nxt_job_return(task, &jbf->job, jbf->ready_handler); in nxt_job_file_open_and_read()
147 nxt_job_return(task, &jbf->job, handler); in nxt_job_file_open_and_read()
|
| H A D | nxt_job_resolve.h | 12 nxt_job_t job; member
|
| H A D | nxt_router.c | 1184 job = obj; in nxt_router_conf_wait()
3145 job->work.task = &job->task; in nxt_router_engine_joints_create()
3146 job->work.obj = job; in nxt_router_engine_joints_create()
3193 job->work.task = &job->task; in nxt_router_engine_quit()
3223 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3224 job->work.obj = job; in nxt_router_engine_joints_delete()
3465 job = obj; in nxt_router_listen_socket_create()
3490 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_create()
3527 job = obj; in nxt_router_listen_socket_update()
3544 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_update()
[all …]
|
| H A D | nxt_buf_filter.c | 246 nxt_job_set_name(&jbf->job, "buf filter job file"); in nxt_buf_filter_file_read_start()
300 nxt_job_file_read(task, &ff->job_file.job); in nxt_buf_filter_file_read()
429 nxt_job_destroy(&f->filter_file->job_file.job); in nxt_buf_filter_buf_completion()
|
| H A D | nxt_sockaddr.c | 860 nxt_job_set_name(&jbs->resolve.job, "job sockaddr parse"); in nxt_job_sockaddr_parse()
889 nxt_job_return(jbs->resolve.job.task, &jbs->resolve.job, handler); in nxt_job_sockaddr_parse()
944 mp = jbs->resolve.job.mem_pool; in nxt_job_sockaddr_unix_parse()
995 mp = jbs->resolve.job.mem_pool; in nxt_job_sockaddr_inet6_parse()
1150 mp = jbs->resolve.job.mem_pool; in nxt_job_sockaddr_inet_parse()
|