Lines Matching refs:lev

3416     nxt_listen_event_t       *lev;  in nxt_router_listen_socket_create()  local
3429 lev = nxt_listen_event(task, ls); in nxt_router_listen_socket_create()
3430 if (nxt_slow_path(lev == NULL)) { in nxt_router_listen_socket_create()
3435 lev->socket.data = joint; in nxt_router_listen_socket_create()
3456 nxt_listen_event_t *lev; in nxt_router_listen_event() local
3464 lev = nxt_queue_link_data(qlk, nxt_listen_event_t, link); in nxt_router_listen_event()
3466 if (fd == lev->socket.fd) { in nxt_router_listen_event()
3467 return lev; in nxt_router_listen_event()
3480 nxt_listen_event_t *lev; in nxt_router_listen_socket_update() local
3490 lev = nxt_router_listen_event(&engine->listen_connections, in nxt_router_listen_socket_update()
3493 old = lev->socket.data; in nxt_router_listen_socket_update()
3494 lev->socket.data = joint; in nxt_router_listen_socket_update()
3495 lev->listen = joint->socket_conf->listen; in nxt_router_listen_socket_update()
3515 nxt_listen_event_t *lev; in nxt_router_listen_socket_delete() local
3523 lev = nxt_router_listen_event(&engine->listen_connections, skcf); in nxt_router_listen_socket_delete()
3525 nxt_fd_event_delete(engine, &lev->socket); in nxt_router_listen_socket_delete()
3528 lev->socket.fd); in nxt_router_listen_socket_delete()
3530 joint = lev->socket.data; in nxt_router_listen_socket_delete()
3533 lev->timer.handler = nxt_router_listen_socket_close; in nxt_router_listen_socket_delete()
3534 lev->timer.work_queue = &engine->fast_work_queue; in nxt_router_listen_socket_delete()
3536 nxt_timer_add(engine, &lev->timer, 0); in nxt_router_listen_socket_delete()
3562 nxt_listen_event_t *lev; in nxt_router_listen_socket_close() local
3566 lev = nxt_timer_data(timer, nxt_listen_event_t, timer); in nxt_router_listen_socket_close()
3569 lev->socket.fd); in nxt_router_listen_socket_close()
3571 nxt_queue_remove(&lev->link); in nxt_router_listen_socket_close()
3573 joint = lev->socket.data; in nxt_router_listen_socket_close()
3574 lev->socket.data = NULL; in nxt_router_listen_socket_close()
3587 nxt_router_listen_event_release(task, lev, joint); in nxt_router_listen_socket_close()
3619 nxt_router_listen_event_release(nxt_task_t *task, nxt_listen_event_t *lev, in nxt_router_listen_event_release() argument
3624 nxt_debug(task, "listen event count: %D", lev->count); in nxt_router_listen_event_release()
3628 if (--lev->count == 0) { in nxt_router_listen_event_release()
3629 if (lev->next != NULL) { in nxt_router_listen_event_release()
3630 nxt_sockaddr_cache_free(engine, lev->next); in nxt_router_listen_event_release()
3632 nxt_conn_free(task, lev->next); in nxt_router_listen_event_release()
3635 nxt_free(lev); in nxt_router_listen_event_release()