Searched refs:job (Results 1 – 8 of 8) sorted by relevance
| /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_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_router.c | 1249 job = obj; in nxt_router_conf_wait()
3192 job->work.task = &job->task; in nxt_router_engine_joints_create()
3193 job->work.obj = job; in nxt_router_engine_joints_create()
3240 job->work.task = &job->task; in nxt_router_engine_quit()
3270 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3271 job->work.obj = job; in nxt_router_engine_joints_delete()
3512 job = obj; in nxt_router_listen_socket_create()
3537 nxt_event_engine_post(job->tmcf->engine, &job->work); in nxt_router_listen_socket_create()
3574 job = obj; in nxt_router_listen_socket_update()
3591 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()
|