Lines Matching refs:socket

46         lev->socket.fd = ls->socket;  in nxt_listen_event()
52 lev->socket.read_work_queue = &engine->accept_work_queue; in nxt_listen_event()
53 lev->socket.read_handler = nxt_conn_listen_handler; in nxt_listen_event()
54 lev->socket.error_handler = nxt_conn_listen_event_error; in nxt_listen_event()
55 lev->socket.log = &nxt_main_log; in nxt_listen_event()
69 lev->socket.task = &lev->task; in nxt_listen_event()
73 nxt_fd_event_enable_accept(engine, &lev->socket); in nxt_listen_event()
99 c = nxt_conn_create(mp, lev->socket.task); in nxt_conn_accept_alloc()
106 c->socket.read_work_queue = lev->socket.read_work_queue; in nxt_conn_accept_alloc()
107 c->socket.write_ready = 1; in nxt_conn_accept_alloc()
148 lev->socket.read_ready = (lev->ready != 0); in nxt_conn_io_accept()
161 s = accept(lev->socket.fd, sa, &socklen); in nxt_conn_io_accept()
168 c->socket.fd = s; in nxt_conn_io_accept()
181 nxt_debug(task, "accept(%d): %d", lev->socket.fd, s); in nxt_conn_io_accept()
203 c->socket.data = NULL; in nxt_conn_accept()
222 if (next != NULL && lev->socket.read_ready) { in nxt_conn_accept()
223 nxt_work_queue_add(lev->socket.read_work_queue, in nxt_conn_accept()
260 nxt_fd_event_disable_read(engine, &lev->socket); in nxt_conn_accept_close_idle()
291 nxt_debug(c->socket.task, "idle connection: %d rdy:%d", in nxt_conn_accept_close_idle_handler()
292 c->socket.fd, c->socket.read_ready); in nxt_conn_accept_close_idle_handler()
294 if (!c->socket.read_ready) { in nxt_conn_accept_close_idle_handler()
299 c->read_state->close_handler(c->socket.task, c, c->socket.data); in nxt_conn_accept_close_idle_handler()
319 lev->socket.read_ready = 0; in nxt_conn_accept_error()
324 nxt_debug(task, "%s(%d) %E", accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error()
330 accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error()
338 accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error()
345 accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error()
367 nxt_fd_event_enable_accept(task->thread->engine, &lev->socket); in nxt_conn_listen_timer_handler()