Lines Matching refs:task

21 static nxt_conn_t *nxt_conn_accept_alloc(nxt_task_t *task,
23 static void nxt_conn_listen_handler(nxt_task_t *task, void *obj,
25 static nxt_conn_t *nxt_conn_accept_next(nxt_task_t *task,
27 static void nxt_conn_accept_close_idle(nxt_task_t *task,
29 static void nxt_conn_accept_close_idle_handler(nxt_task_t *task, void *obj,
31 static void nxt_conn_listen_event_error(nxt_task_t *task, void *obj,
33 static void nxt_conn_listen_timer_handler(nxt_task_t *task, void *obj,
38 nxt_listen_event(nxt_task_t *task, nxt_listen_socket_t *ls) in nxt_listen_event() argument
48 engine = task->thread->engine; in nxt_listen_event()
66 lev->task.thread = task->thread; in nxt_listen_event()
67 lev->task.log = &nxt_main_log; in nxt_listen_event()
68 lev->task.ident = nxt_task_next_ident(); in nxt_listen_event()
69 lev->socket.task = &lev->task; in nxt_listen_event()
70 lev->timer.task = &lev->task; in nxt_listen_event()
72 if (nxt_conn_accept_alloc(task, lev) != NULL) { in nxt_listen_event()
86 nxt_conn_accept_alloc(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_alloc() argument
92 engine = task->thread->engine; in nxt_conn_accept_alloc()
99 c = nxt_conn_create(mp, lev->socket.task); in nxt_conn_accept_alloc()
115 nxt_conn_free(task, c); in nxt_conn_accept_alloc()
124 nxt_conn_listen_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_handler() argument
131 lev->accept(task, lev, data); in nxt_conn_listen_handler()
136 nxt_conn_io_accept(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_accept() argument
164 nxt_conn_accept_error(task, lev, "accept", nxt_socket_errno); in nxt_conn_io_accept()
175 if (nxt_slow_path(nxt_socket_nonblocking(task, s) != NXT_OK)) { in nxt_conn_io_accept()
176 nxt_socket_close(task, s); in nxt_conn_io_accept()
181 nxt_debug(task, "accept(%d): %d", lev->socket.fd, s); in nxt_conn_io_accept()
183 nxt_conn_accept(task, lev, c); in nxt_conn_io_accept()
188 nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev, nxt_conn_t *c) in nxt_conn_accept() argument
195 nxt_debug(task, "client: %*s", in nxt_conn_accept()
199 engine = task->thread->engine; in nxt_conn_accept()
218 &c->task, c, lev); in nxt_conn_accept()
222 &c->task, c, lev); in nxt_conn_accept()
225 next = nxt_conn_accept_next(task, lev); in nxt_conn_accept()
229 lev->accept, task, lev, next); in nxt_conn_accept()
235 nxt_conn_accept_next(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_next() argument
242 c = nxt_conn_accept_alloc(task, lev); in nxt_conn_accept_next()
245 nxt_conn_accept_close_idle(task, lev); in nxt_conn_accept_next()
254 nxt_conn_accept_close_idle(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_close_idle() argument
258 engine = task->thread->engine; in nxt_conn_accept_close_idle()
261 nxt_conn_accept_close_idle_handler, task, NULL, NULL); in nxt_conn_accept_close_idle()
267 nxt_alert(task, "new connections are not accepted within 100ms"); in nxt_conn_accept_close_idle()
272 nxt_conn_accept_close_idle_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_accept_close_idle_handler() argument
285 engine = task->thread->engine; in nxt_conn_accept_close_idle_handler()
296 nxt_debug(c->socket.task, "idle connection: %d rdy:%d", in nxt_conn_accept_close_idle_handler()
301 task->log, "no available connections, " in nxt_conn_accept_close_idle_handler()
304 c->read_state->close_handler(c->socket.task, c, c->socket.data); in nxt_conn_accept_close_idle_handler()
317 nxt_conn_accept_error(nxt_task_t *task, nxt_listen_event_t *lev, in nxt_conn_accept_error() argument
329 nxt_debug(task, "%s(%d) %E", accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error()
334 task->log, "%s(%d) failed %E", in nxt_conn_accept_error()
342 nxt_alert(task, "%s(%d) failed %E", in nxt_conn_accept_error()
345 nxt_conn_accept_close_idle(task, lev); in nxt_conn_accept_error()
349 nxt_alert(task, "%s(%d) failed %E", in nxt_conn_accept_error()
357 nxt_conn_listen_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_timer_handler() argument
367 c = nxt_conn_accept_next(task, lev); in nxt_conn_listen_timer_handler()
372 nxt_fd_event_enable_accept(task->thread->engine, &lev->socket); in nxt_conn_listen_timer_handler()
374 lev->accept(task, lev, c); in nxt_conn_listen_timer_handler()
379 nxt_conn_listen_event_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_event_error() argument
385 nxt_alert(task, "accept(%d) event error", ev->fd); in nxt_conn_listen_event_error()