Searched refs:nxt_queue_link_data (Results 1 – 12 of 12) sorted by relevance
/unit/src/ |
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); \
|
H A D | nxt_process.h | 173 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
|
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_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_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 | 289 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
|
H A D | nxt_router.c | 1097 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 D | nxt_cache.c | 568 node = nxt_queue_link_data(link, nxt_cache_node_t, link); in nxt_cache_node_alloc()
|
H A D | nxt_runtime.c | 484 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 D | nxt_process.c | 1042 lev = nxt_queue_link_data(link, nxt_listen_event_t, link); in nxt_process_quit()
|
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()
|
/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()
|