Searched refs:lev (Results 1 – 8 of 8) sorted by relevance
/unit/src/ |
H A D | nxt_conn_accept.c | 69 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 D | nxt_kqueue_engine.c | 916 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 D | nxt_epoll_engine.c | 1014 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 D | nxt_router.c | 3689 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 D | nxt_conn.h | 241 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 D | nxt_router.h | 250 void nxt_router_listen_event_release(nxt_task_t *task, nxt_listen_event_t *lev,
|
H A D | nxt_process.c | 1262 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 D | nxt_h1proto.c | 217 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()
|