Lines Matching refs:task

19 static void nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj,
21 static void nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj,
23 static void nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj,
25 static nxt_buf_t *nxt_event_conn_job_sendfile_completion(nxt_task_t *task,
30 nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_conn_t *c) in nxt_event_conn_job_sendfile() argument
32 nxt_fd_event_disable(task->thread->engine, &c->socket); in nxt_event_conn_job_sendfile()
35 nxt_event_conn_job_sendfile_start(task, c, NULL); in nxt_event_conn_job_sendfile()
40 nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_start() argument
49 nxt_debug(task, "event conn sendfile fd:%d", c->socket.fd); in nxt_event_conn_job_sendfile_start()
54 c->write_state->error_handler(task, c, NULL); in nxt_event_conn_job_sendfile_start()
75 if (nxt_sendbuf_mem_coalesce(c->socket.task, &sb) != 0 || !sb.sync) { 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()
91 nxt_event_conn_job_sendfile_return(task, jbs, c); in nxt_event_conn_job_sendfile_start()
96 nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_handler() argument
107 nxt_debug(task, "event conn job sendfile fd:%d", c->socket.fd); in nxt_event_conn_job_sendfile_handler()
144 if (first && task->thread->thread_pool->work_queue.head != NULL) { in nxt_event_conn_job_sendfile_handler()
150 nxt_job_return(task, &jbs->job, jbs->ready_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()
163 nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_return() argument
180 nxt_debug(task, "event conn sendfile sent:%z", sent); in nxt_event_conn_job_sendfile_return()
185 nxt_job_destroy(task, jbs); in nxt_event_conn_job_sendfile_return()
188 b = nxt_event_conn_job_sendfile_completion(task, c, b); in nxt_event_conn_job_sendfile_return()
201 nxt_event_conn_job_sendfile_start(task, c, NULL); in nxt_event_conn_job_sendfile_return()
209 nxt_timer_disable(task->thread->engine, &c->write_timer); in nxt_event_conn_job_sendfile_return()
213 && !nxt_event_conn_write_delayed(task->thread->engine, c, sent)) in nxt_event_conn_job_sendfile_return()
215 nxt_conn_timer(task->thread->engine, c, c->write_state, in nxt_event_conn_job_sendfile_return()
218 nxt_fd_event_oneshot_write(task->thread->engine, &c->socket); in nxt_event_conn_job_sendfile_return()
223 task, c, c->socket.data); in nxt_event_conn_job_sendfile_return()
232 task, c, c->socket.data); in nxt_event_conn_job_sendfile_return()
238 nxt_event_conn_job_sendfile_completion(nxt_task_t *task, nxt_conn_t *c, in nxt_event_conn_job_sendfile_completion() argument
253 b->completion_handler, task, b, b->parent); in nxt_event_conn_job_sendfile_completion()