Home
last modified time | relevance | path

Searched refs:nxt_queue_first (Results 1 – 13 of 13) 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.h173 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_file_cache.c312 qn = nxt_queue_first(&cache->free_nodes); in nxt_cache_node_alloc()
H A Dnxt_router.c1091 qlk = nxt_queue_first(&pending_sockets); in nxt_router_conf_apply()
1241 for (qlk = nxt_queue_first(&creating_sockets); in nxt_router_conf_error()
2553 for (qlk = nxt_queue_first(&router->sockets); in nxt_router_listen_socket_find()
2997 for (qlk = nxt_queue_first(&router->engines); in nxt_router_engines_create()
3131 for (qlk = nxt_queue_first(sockets); in nxt_router_engine_joints_create()
3209 for (qlk = nxt_queue_first(sockets); in nxt_router_engine_joints_delete()
3504 for (qlk = nxt_queue_first(listen_connections); in nxt_router_listen_event()
4700 link = nxt_queue_first(&app->ack_waiting_req); in nxt_router_app_port_error()
4720 link = nxt_queue_first(&app->ack_waiting_req); in nxt_router_app_port_error()
5045 lnk = nxt_queue_first(&app->idle_ports); in nxt_router_adjust_idle_timer()
H A Dnxt_cache.c562 link = nxt_queue_first(&cache->free_nodes); in nxt_cache_node_alloc()
H A Dnxt_runtime.c479 for (link = nxt_queue_first(idle); in nxt_runtime_close_idle_connections()
647 link = nxt_queue_first(&rt->engines); in nxt_runtime_event_engine_free()
H A Dnxt_process.c1037 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.c1758 lnk = nxt_queue_first(&ctx_impl->free_req); in nxt_unit_request_info_get()
1863 lnk = nxt_queue_first(&ctx_impl->free_ws); in nxt_unit_websocket_frame_get()
2795 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.c1034 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()