Home
last modified time | relevance | path

Searched refs:nxt_queue_link_data (Results 1 – 11 of 11) sorted by last modified time

/unit/src/
H A Dnxt_router.c1195 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_conf_apply()
1208 tls = nxt_queue_link_data(qlk, nxt_router_tlssock_t, link); in nxt_router_conf_apply()
1222 js_module = nxt_queue_link_data(qlk, nxt_router_js_module_t, link); in nxt_router_conf_apply()
1362 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_conf_error()
2767 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_listen_socket_find()
3216 recf->engine = nxt_queue_link_data(qlk, nxt_event_engine_t, link0); in nxt_router_engines_create()
3376 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_create()
3435 job->work.data = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_delete()
3718 lev = nxt_queue_link_data(qlk, nxt_listen_event_t, link); in nxt_router_listen_event()
4295 idle_port = nxt_queue_link_data(idle_lnk, nxt_port_t, idle_link); in nxt_router_req_headers_ack_handler()
[all …]
H A Dnxt_runtime.c484 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_runtime_close_idle_connections()
667 engine = nxt_queue_link_data(link, nxt_event_engine_t, link); in nxt_runtime_event_engine_free()
H A Dnxt_process.h179 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
H A Dnxt_process.c1273 lev = nxt_queue_link_data(link, nxt_listen_event_t, link); in nxt_process_quit()
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.c294 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
H A Dnxt_port_socket.c582 msg = nxt_queue_link_data(lnk, nxt_port_send_msg_t, link); in nxt_port_msg_first()
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_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_queue.h193 #define nxt_queue_link_data(lnk, type, link) \ macro
212 elt = nxt_queue_link_data(_lnk, type, link); \
/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()