Home
last modified time | relevance | path

Searched refs:lev (Results 1 – 8 of 8) sorted by relevance

/unit/src/
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()
206 lev->count++; in nxt_conn_accept()
229 lev->accept, task, lev, next); in nxt_conn_accept()
[all …]
H A Dnxt_kqueue_engine.c916 nxt_listen_event_t *lev; in nxt_kqueue_listen_handler() local
918 lev = obj; in nxt_kqueue_listen_handler()
921 lev->socket.fd, lev->socket.kq_available); in nxt_kqueue_listen_handler()
923 lev->ready = nxt_min(lev->batch, (uint32_t) lev->socket.kq_available); in nxt_kqueue_listen_handler()
936 nxt_listen_event_t *lev; in nxt_kqueue_conn_io_accept() local
938 lev = obj; in nxt_kqueue_conn_io_accept()
939 c = lev->next; in nxt_kqueue_conn_io_accept()
941 lev->ready--; in nxt_kqueue_conn_io_accept()
942 lev->socket.read_ready = (lev->ready != 0); in nxt_kqueue_conn_io_accept()
944 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_router.c3689 lev->socket.data = joint; in nxt_router_listen_socket_create()
3710 nxt_listen_event_t *lev; in nxt_router_listen_event() local
3721 return lev; in nxt_router_listen_event()
3747 old = lev->socket.data; in nxt_router_listen_socket_update()
3748 lev->socket.data = joint; in nxt_router_listen_socket_update()
3782 lev->socket.fd); in nxt_router_listen_socket_delete()
3784 joint = lev->socket.data; in nxt_router_listen_socket_delete()
3827 joint = lev->socket.data; in nxt_router_listen_socket_close()
3828 lev->socket.data = NULL; in nxt_router_listen_socket_close()
3917 if (--lev->count == 0) { in nxt_router_listen_event_release()
[all …]
H A Dnxt_conn.h241 NXT_EXPORT void nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev,
243 void nxt_conn_accept_error(nxt_task_t *task, nxt_listen_event_t *lev,
H A Dnxt_router.h250 void nxt_router_listen_event_release(nxt_task_t *task, nxt_listen_event_t *lev,
H A Dnxt_process.c1262 nxt_listen_event_t *lev; in nxt_process_quit() local
1273 lev = nxt_queue_link_data(link, nxt_listen_event_t, link); in nxt_process_quit()
1276 nxt_fd_event_close(task->thread->engine, &lev->socket); in nxt_process_quit()
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()
2118 nxt_listen_event_t *lev; in nxt_h1p_conn_free() local
2129 lev = c->listen; in nxt_h1p_conn_free()
2133 nxt_router_listen_event_release(&engine->task, lev, NULL); in nxt_h1p_conn_free()