Home
last modified time | relevance | path

Searched refs:lev (Results 1 – 8 of 8) sorted by last modified time

/unit/src/
H A Dnxt_process.c1008 nxt_listen_event_t *lev; in nxt_process_quit() local
1022 lev = nxt_queue_link_data(link, nxt_listen_event_t, link); in nxt_process_quit()
1025 nxt_fd_event_close(task->thread->engine, &lev->socket); in nxt_process_quit()
H A Dnxt_router.c3435 lev->socket.data = joint; in nxt_router_listen_socket_create()
3456 nxt_listen_event_t *lev; in nxt_router_listen_event() local
3467 return lev; in nxt_router_listen_event()
3493 old = lev->socket.data; in nxt_router_listen_socket_update()
3494 lev->socket.data = joint; in nxt_router_listen_socket_update()
3528 lev->socket.fd); in nxt_router_listen_socket_delete()
3530 joint = lev->socket.data; in nxt_router_listen_socket_delete()
3573 joint = lev->socket.data; in nxt_router_listen_socket_close()
3574 lev->socket.data = NULL; in nxt_router_listen_socket_close()
3628 if (--lev->count == 0) { in nxt_router_listen_event_release()
[all …]
H A Dnxt_router.h240 void nxt_router_listen_event_release(nxt_task_t *task, nxt_listen_event_t *lev,
H A Dnxt_h1proto.c217 nxt_listen_event_t *lev; in nxt_http_conn_init() local
221 lev = data; in nxt_http_conn_init()
225 joint = lev->socket.data; in nxt_http_conn_init()
2107 nxt_listen_event_t *lev; in nxt_h1p_conn_free() local
2118 lev = c->listen; in nxt_h1p_conn_free()
2122 nxt_router_listen_event_release(&engine->task, lev, NULL); in nxt_h1p_conn_free()
H A Dnxt_kqueue_engine.c915 nxt_listen_event_t *lev; in nxt_kqueue_listen_handler() local
917 lev = obj; in nxt_kqueue_listen_handler()
920 lev->socket.fd, lev->socket.kq_available); in nxt_kqueue_listen_handler()
922 lev->ready = nxt_min(lev->batch, (uint32_t) lev->socket.kq_available); in nxt_kqueue_listen_handler()
935 nxt_listen_event_t *lev; in nxt_kqueue_conn_io_accept() local
937 lev = obj; in nxt_kqueue_conn_io_accept()
938 c = lev->next; in nxt_kqueue_conn_io_accept()
940 lev->ready--; in nxt_kqueue_conn_io_accept()
941 lev->socket.read_ready = (lev->ready != 0); in nxt_kqueue_conn_io_accept()
943 lev->socket.kq_available--; in nxt_kqueue_conn_io_accept()
[all …]
H A Dnxt_epoll_engine.c1014 nxt_listen_event_t *lev; in nxt_epoll_conn_io_accept4() local
1016 lev = obj; in nxt_epoll_conn_io_accept4()
1017 c = lev->next; in nxt_epoll_conn_io_accept4()
1019 lev->ready--; in nxt_epoll_conn_io_accept4()
1020 lev->socket.read_ready = (lev->ready != 0); in nxt_epoll_conn_io_accept4()
1028 s = accept4(lev->socket.fd, sa, &socklen, SOCK_NONBLOCK); in nxt_epoll_conn_io_accept4()
1033 nxt_debug(task, "accept4(%d): %d", lev->socket.fd, s); in nxt_epoll_conn_io_accept4()
1035 nxt_conn_accept(task, lev, c); in nxt_epoll_conn_io_accept4()
1039 nxt_conn_accept_error(task, lev, "accept4", nxt_errno); in nxt_epoll_conn_io_accept4()
H A Dnxt_conn.h240 NXT_EXPORT void nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev,
242 void nxt_conn_accept_error(nxt_task_t *task, nxt_listen_event_t *lev,
H A Dnxt_conn_accept.c69 lev->socket.task = &lev->task; in nxt_listen_event()
70 lev->timer.task = &lev->task; in nxt_listen_event()
128 lev = obj; in nxt_conn_listen_handler()
129 lev->ready = lev->batch; in nxt_conn_listen_handler()
131 lev->accept(task, lev, data); in nxt_conn_listen_handler()
144 lev = obj; in nxt_conn_io_accept()
147 lev->ready--; in nxt_conn_io_accept()
148 lev->socket.read_ready = (lev->ready != 0); in nxt_conn_io_accept()
201 lev->count++; in nxt_conn_accept()
224 lev->accept, task, lev, next); in nxt_conn_accept()
[all …]