Home
last modified time | relevance | path

Searched refs:nxt_queue_first (Results 1 – 11 of 11) sorted by relevance

/unit/src/
H A Dnxt_queue.c21 middle = nxt_queue_first(queue); in nxt_queue_middle()
59 link = nxt_queue_first(queue); in nxt_queue_sort()
H A Dnxt_queue.h72 #define nxt_queue_first(queue) \ macro
207 for (_lnk = nxt_queue_first(queue); \
H A Dnxt_process.h179 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
H A Dnxt_mp.c539 link = nxt_queue_first(chunk_pages); in nxt_mp_alloc_small()
604 for (link = nxt_queue_first(pages); in nxt_mp_get_small()
658 link = nxt_queue_first(&mp->free_pages); in nxt_mp_alloc_page()
H A Dnxt_router.c1189 qlk = nxt_queue_first(&pending_sockets); in nxt_router_conf_apply()
1358 for (qlk = nxt_queue_first(&creating_sockets); in nxt_router_conf_error()
2763 for (qlk = nxt_queue_first(&router->sockets); in nxt_router_listen_socket_find()
3207 for (qlk = nxt_queue_first(&router->engines); in nxt_router_engines_create()
3341 for (qlk = nxt_queue_first(sockets); in nxt_router_engine_joints_create()
3419 for (qlk = nxt_queue_first(sockets); in nxt_router_engine_joints_delete()
3714 for (qlk = nxt_queue_first(listen_connections); in nxt_router_listen_event()
4569 link = nxt_queue_first(&app->ack_waiting_req); in nxt_router_app_port_error()
4589 link = nxt_queue_first(&app->ack_waiting_req); in nxt_router_app_port_error()
4914 lnk = nxt_queue_first(&app->idle_ports); in nxt_router_adjust_idle_timer()
H A Dnxt_runtime.c479 for (link = nxt_queue_first(idle); in nxt_runtime_close_idle_connections()
664 link = nxt_queue_first(&rt->engines); in nxt_runtime_event_engine_free()
H A Dnxt_process.c1268 for (link = nxt_queue_first(listen); in nxt_process_quit()
H A Dnxt_port_socket.c576 lnk = nxt_queue_first(&port->messages); in nxt_port_msg_first()
H A Dnxt_unit.c1772 lnk = nxt_queue_first(&ctx_impl->free_req); in nxt_unit_request_info_get()
1877 lnk = nxt_queue_first(&ctx_impl->free_ws); in nxt_unit_websocket_frame_get()
2810 link = nxt_queue_first(&ctx_impl->free_rbuf); in nxt_unit_read_buf_get_impl()
/unit/src/python/
H A Dnxt_python_asgi_websocket.c953 lnk = nxt_queue_first(&ws->pending_frames); in nxt_py_asgi_websocket_pop_frame()
H A Dnxt_python_asgi.c1144 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()