Home
last modified time | relevance | path

Searched refs:nxt_queue_link_data (Results 1 – 12 of 12) sorted by relevance

/unit/src/
H A Dnxt_queue.h193 #define nxt_queue_link_data(lnk, type, link) \ macro
212 elt = nxt_queue_link_data(_lnk, type, link); \
H A Dnxt_process.h173 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
H A Dnxt_port_rpc.c283 r = nxt_queue_link_data(reg->link.next, nxt_port_rpc_reg_t, link); in nxt_port_rpc_remove_from_peers()
405 reg = nxt_queue_link_data(peer_link, nxt_port_rpc_reg_t, link); in nxt_port_rpc_remove_peer()
H A Dnxt_mp.c540 page = nxt_queue_link_data(link, nxt_mp_page_t, link); in nxt_mp_alloc_small()
609 page = nxt_queue_link_data(link, nxt_mp_page_t, link); in nxt_mp_get_small()
661 page = nxt_queue_link_data(link, nxt_mp_page_t, link); in nxt_mp_alloc_page()
H A Dnxt_mem_zone.c913 next_page = nxt_queue_link_data(page->link.next, nxt_mem_zone_page_t, link); in nxt_mem_zone_free_pages()
927 prev_page = nxt_queue_link_data(page->link.prev, nxt_mem_zone_page_t, link); in nxt_mem_zone_free_pages()
H A Dnxt_conn_accept.c289 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
H A Dnxt_router.c1097 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_conf_apply()
1110 tls = nxt_queue_link_data(qlk, nxt_router_tlssock_t, link); in nxt_router_conf_apply()
1245 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_conf_error()
2557 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_listen_socket_find()
3006 recf->engine = nxt_queue_link_data(qlk, nxt_event_engine_t, link0); in nxt_router_engines_create()
3166 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_create()
3225 job->work.data = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_delete()
3508 lev = nxt_queue_link_data(qlk, nxt_listen_event_t, link); in nxt_router_listen_event()
4426 idle_port = nxt_queue_link_data(idle_lnk, nxt_port_t, idle_link); in nxt_router_req_headers_ack_handler()
4971 idle_port = nxt_queue_link_data(idle_lnk, nxt_port_t, idle_link); in nxt_router_app_port_close()
[all …]
H A Dnxt_cache.c568 node = nxt_queue_link_data(link, nxt_cache_node_t, link); in nxt_cache_node_alloc()
H A Dnxt_runtime.c484 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_runtime_close_idle_connections()
650 engine = nxt_queue_link_data(link, nxt_event_engine_t, link); in nxt_runtime_event_engine_free()
H A Dnxt_process.c1042 lev = nxt_queue_link_data(link, nxt_listen_event_t, link); in nxt_process_quit()
H A Dnxt_port_socket.c582 msg = nxt_queue_link_data(lnk, nxt_port_send_msg_t, link); in nxt_port_msg_first()
/unit/src/python/
H A Dnxt_python_asgi_websocket.c956 p = nxt_queue_link_data(lnk, nxt_py_asgi_penging_frame_t, link); in nxt_py_asgi_websocket_pop_frame()