/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()
|