/unit/src/ |
H A D | nxt_queue.c | 16 nxt_queue_link_t * 19 nxt_queue_link_t *middle, *next; in nxt_queue_middle() 54 nxt_int_t (*cmp)(const void *data, const nxt_queue_link_t *, in nxt_queue_sort() argument 55 const nxt_queue_link_t *), const void *data) in nxt_queue_sort() argument 57 nxt_queue_link_t *link, *prev, *next; in nxt_queue_sort()
|
H A D | nxt_queue.h | 11 typedef struct nxt_queue_link_s nxt_queue_link_t; typedef 14 nxt_queue_link_t *prev; 15 nxt_queue_link_t *next; 20 nxt_queue_link_t head; 197 NXT_EXPORT nxt_queue_link_t *nxt_queue_middle(nxt_queue_t *queue); 199 nxt_int_t (*cmp)(const void *, const nxt_queue_link_t *, 200 const nxt_queue_link_t *), const void *data); 205 nxt_queue_link_t *_lnk, *_nxt; \
|
H A D | nxt_router.h | 139 nxt_queue_link_t link; 163 nxt_queue_link_t link; 211 nxt_queue_link_t link;
|
H A D | nxt_port.h | 181 nxt_queue_link_t link; 225 nxt_queue_link_t link; /* for nxt_process_t.ports */ 228 nxt_queue_link_t app_link; /* for nxt_app_t.ports */ 232 nxt_queue_link_t idle_link; /* for nxt_app_t.idle_ports */
|
H A D | nxt_job.h | 44 nxt_queue_link_t link;
|
H A D | nxt_cache.h | 58 nxt_queue_link_t link;
|
H A D | nxt_port_rpc.c | 19 nxt_queue_link_t link; 192 nxt_queue_link_t *peer_link; in nxt_port_rpc_ex_set_peer() 373 nxt_queue_link_t *peer_link, *next_link; in nxt_port_rpc_remove_peer()
|
H A D | nxt_conn.h | 114 nxt_queue_link_t link; 171 nxt_queue_link_t link;
|
H A D | nxt_event_engine.h | 486 nxt_queue_link_t link; 488 nxt_queue_link_t link0;
|
H A D | nxt_mp.c | 32 nxt_queue_link_t link; 526 nxt_queue_link_t *link; in nxt_mp_alloc_small() 600 nxt_queue_link_t *link, *next; in nxt_mp_get_small() 649 nxt_queue_link_t *link; in nxt_mp_alloc_page()
|
H A D | nxt_process.h | 120 nxt_queue_link_t link; /* for nxt_process_t.children */
|
H A D | nxt_conn_accept.c | 272 nxt_queue_link_t *link, *next; in nxt_conn_accept_close_idle_handler()
|
H A D | nxt_router.c | 1080 nxt_queue_link_t *qlk; in nxt_router_conf_apply() 1235 nxt_queue_link_t *qlk; in nxt_router_conf_error() 2548 nxt_queue_link_t *qlk; in nxt_router_listen_socket_find() 2984 nxt_queue_link_t *qlk; in nxt_router_engines_create() 3127 nxt_queue_link_t *qlk; in nxt_router_engine_joints_create() 3207 nxt_queue_link_t *qlk; in nxt_router_engine_joints_delete() 3499 nxt_queue_link_t *qlk; in nxt_router_listen_event() 4367 nxt_queue_link_t *idle_lnk; in nxt_router_req_headers_ack_handler() 4668 nxt_queue_link_t *link; in nxt_router_app_port_error() 4922 nxt_queue_link_t *idle_lnk; in nxt_router_app_port_close() [all …]
|
H A D | nxt_http.h | 181 nxt_queue_link_t app_link; /* nxt_app_t.ack_waiting_req */
|
H A D | nxt_cache.c | 559 nxt_queue_link_t *link; in nxt_cache_node_alloc()
|
H A D | nxt_unit.c | 259 nxt_queue_link_t link; 261 nxt_queue_link_t port_wait_link; 272 nxt_queue_link_t link; 279 nxt_queue_link_t link; 297 nxt_queue_link_t link; 388 nxt_queue_link_t link; 1733 nxt_queue_link_t *lnk; in nxt_unit_request_info_get() 1846 nxt_queue_link_t *lnk; in nxt_unit_websocket_frame_get() 2791 nxt_queue_link_t *link; in nxt_unit_read_buf_get_impl()
|
H A D | nxt_runtime.c | 473 nxt_queue_link_t *link, *next; in nxt_runtime_close_idle_connections() 644 nxt_queue_link_t *link; in nxt_runtime_event_engine_free()
|
H A D | nxt_mem_zone.c | 53 nxt_queue_link_t link;
|
H A D | nxt_process.c | 1027 nxt_queue_link_t *link, *next; in nxt_process_quit()
|
H A D | nxt_port_socket.c | 571 nxt_queue_link_t *lnk; in nxt_port_msg_first()
|
/unit/src/python/ |
H A D | nxt_python_asgi.h | 14 nxt_queue_link_t *link); 59 int nxt_py_asgi_http_drain(nxt_queue_link_t *lnk);
|
H A D | nxt_python_asgi_http.c | 21 nxt_queue_link_t link; 558 nxt_py_asgi_http_drain(nxt_queue_link_t *lnk) in nxt_py_asgi_http_drain()
|
H A D | nxt_python_asgi_websocket.c | 30 nxt_queue_link_t link; 949 nxt_queue_link_t *lnk; in nxt_py_asgi_websocket_pop_frame()
|
H A D | nxt_python_asgi.c | 1028 nxt_queue_link_t *lnk; in nxt_py_asgi_shm_ack_handler() 1394 nxt_py_asgi_drain_wait(nxt_unit_request_info_t *req, nxt_queue_link_t *link) in nxt_py_asgi_drain_wait()
|
/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 27 nxt_queue_link_t link;
|