Searched refs:nxt_queue_link_data (Results 1 – 11 of 11) sorted by last modified time
/unit/src/ |
H A D | nxt_router.c | 1195 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 D | nxt_runtime.c | 484 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 D | nxt_process.h | 179 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
|
H A D | nxt_process.c | 1273 lev = nxt_queue_link_data(link, nxt_listen_event_t, link); in nxt_process_quit()
|
H A D | nxt_mem_zone.c | 913 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 D | nxt_conn_accept.c | 294 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
|
H A D | nxt_port_socket.c | 582 msg = nxt_queue_link_data(lnk, nxt_port_send_msg_t, link); in nxt_port_msg_first()
|
H A D | nxt_mp.c | 540 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 D | nxt_port_rpc.c | 283 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 D | nxt_queue.h | 193 #define nxt_queue_link_data(lnk, type, link) \ macro 212 elt = nxt_queue_link_data(_lnk, type, link); \
|
/unit/src/python/ |
H A D | nxt_python_asgi_websocket.c | 956 p = nxt_queue_link_data(lnk, nxt_py_asgi_penging_frame_t, link); in nxt_py_asgi_websocket_pop_frame()
|