Searched refs:nxt_queue_first (Results 1 – 11 of 11) sorted by relevance
21 middle = nxt_queue_first(queue); in nxt_queue_middle()59 link = nxt_queue_first(queue); in nxt_queue_sort()
72 #define nxt_queue_first(queue) \ macro207 for (_lnk = nxt_queue_first(queue); \
179 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
539 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()
1189 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()
479 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()
1268 for (link = nxt_queue_first(listen); in nxt_process_quit()
576 lnk = nxt_queue_first(&port->messages); in nxt_port_msg_first()
1772 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()
953 lnk = nxt_queue_first(&ws->pending_frames); in nxt_py_asgi_websocket_pop_frame()
1144 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()