Searched refs:lnk (Results 1 – 8 of 8) sorted by last modified time
| /unit/src/ |
| H A D | nxt_unit.c | 1747 nxt_queue_link_t *lnk; in nxt_unit_request_info_get() local
1772 lnk = nxt_queue_first(&ctx_impl->free_req); in nxt_unit_request_info_get()
1773 nxt_queue_remove(lnk); in nxt_unit_request_info_get()
1775 req_impl = nxt_container_of(lnk, nxt_unit_request_info_impl_t, link); in nxt_unit_request_info_get()
1860 nxt_queue_link_t *lnk; in nxt_unit_websocket_frame_get() local
1877 lnk = nxt_queue_first(&ctx_impl->free_ws); in nxt_unit_websocket_frame_get()
1878 nxt_queue_remove(lnk); in nxt_unit_websocket_frame_get()
1882 ws_impl = nxt_container_of(lnk, nxt_unit_websocket_frame_impl_t, link); in nxt_unit_websocket_frame_get()
|
| H A D | nxt_router.c | 586 nxt_queue_chk_remove(nxt_queue_link_t *lnk) in nxt_queue_chk_remove() argument
588 if (lnk->next != NULL) { in nxt_queue_chk_remove()
589 nxt_queue_remove(lnk); in nxt_queue_chk_remove()
591 lnk->next = NULL; in nxt_queue_chk_remove()
4888 nxt_queue_link_t *lnk; in nxt_router_adjust_idle_timer() local
4918 lnk = nxt_queue_first(&app->idle_ports); in nxt_router_adjust_idle_timer()
4919 port = nxt_queue_link_data(lnk, nxt_port_t, idle_link); in nxt_router_adjust_idle_timer()
4931 nxt_queue_remove(lnk); in nxt_router_adjust_idle_timer()
4932 lnk->next = NULL; in nxt_router_adjust_idle_timer()
|
| H A D | nxt_port_socket.c | 571 nxt_queue_link_t *lnk; in nxt_port_msg_first() local
576 lnk = nxt_queue_first(&port->messages); in nxt_port_msg_first()
578 if (lnk == nxt_queue_tail(&port->messages)) { in nxt_port_msg_first()
582 msg = nxt_queue_link_data(lnk, nxt_port_send_msg_t, link); in nxt_port_msg_first()
|
| H A D | nxt_queue.h | 193 #define nxt_queue_link_data(lnk, type, link) \ argument
194 nxt_container_of(lnk, type, link)
|
| /unit/src/python/ |
| H A D | nxt_python_asgi.c | 1138 nxt_queue_link_t *lnk; in nxt_py_asgi_shm_ack_handler() local
1144 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()
1146 rc = nxt_py_asgi_http_drain(lnk); in nxt_py_asgi_shm_ack_handler()
1151 nxt_queue_remove(lnk); in nxt_py_asgi_shm_ack_handler()
|
| H A D | nxt_python_asgi_websocket.c | 949 nxt_queue_link_t *lnk; in nxt_py_asgi_websocket_pop_frame() local
953 lnk = nxt_queue_first(&ws->pending_frames); in nxt_py_asgi_websocket_pop_frame()
954 nxt_queue_remove(lnk); in nxt_py_asgi_websocket_pop_frame()
956 p = nxt_queue_link_data(lnk, nxt_py_asgi_penging_frame_t, link); in nxt_py_asgi_websocket_pop_frame()
|
| H A D | nxt_python_asgi.h | 59 int nxt_py_asgi_http_drain(nxt_queue_link_t *lnk);
|
| H A D | nxt_python_asgi_http.c | 558 nxt_py_asgi_http_drain(nxt_queue_link_t *lnk) in nxt_py_asgi_http_drain() argument
566 http = nxt_container_of(lnk, nxt_py_asgi_http_t, link); in nxt_py_asgi_http_drain()
|