Searched refs:nxt_queue_link_t (Results 1 – 24 of 24) sorted by last modified time
/unit/src/python/ |
H A D | nxt_python_asgi_http.c | 21 nxt_queue_link_t link; 565 nxt_py_asgi_http_drain(nxt_queue_link_t *lnk) in nxt_py_asgi_http_drain()
|
H A D | nxt_python_asgi.c | 1138 nxt_queue_link_t *lnk; in nxt_py_asgi_shm_ack_handler() 1504 nxt_py_asgi_drain_wait(nxt_unit_request_info_t *req, nxt_queue_link_t *link) in nxt_py_asgi_drain_wait()
|
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.h | 14 nxt_queue_link_t *link); 59 int nxt_py_asgi_http_drain(nxt_queue_link_t *lnk);
|
/unit/src/ |
H A D | nxt_router.c | 66 nxt_queue_link_t link; 1352 nxt_queue_link_t *qlk; in nxt_router_conf_error() 2758 nxt_queue_link_t *qlk; in nxt_router_listen_socket_find() 3194 nxt_queue_link_t *qlk; in nxt_router_engines_create() 3337 nxt_queue_link_t *qlk; in nxt_router_engine_joints_create() 3417 nxt_queue_link_t *qlk; in nxt_router_engine_joints_delete() 3709 nxt_queue_link_t *qlk; in nxt_router_listen_event() 4236 nxt_queue_link_t *idle_lnk; in nxt_router_req_headers_ack_handler() 4537 nxt_queue_link_t *link; in nxt_router_app_port_error() 4791 nxt_queue_link_t *idle_lnk; in nxt_router_app_port_close() [all …]
|
H A D | nxt_runtime.c | 473 nxt_queue_link_t *link, *next; in nxt_runtime_close_idle_connections() 661 nxt_queue_link_t *link; in nxt_runtime_event_engine_free()
|
H A D | nxt_router.h | 147 nxt_queue_link_t link; 171 nxt_queue_link_t link; 223 nxt_queue_link_t link;
|
H A D | nxt_controller.c | 28 nxt_queue_link_t link;
|
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; 1747 nxt_queue_link_t *lnk; in nxt_unit_request_info_get() 1860 nxt_queue_link_t *lnk; in nxt_unit_websocket_frame_get() 2806 nxt_queue_link_t *link; in nxt_unit_read_buf_get_impl()
|
H A D | nxt_http.h | 186 nxt_queue_link_t app_link; /* nxt_app_t.ack_waiting_req */
|
H A D | nxt_port.h | 195 nxt_queue_link_t link; 239 nxt_queue_link_t link; /* for nxt_process_t.ports */ 242 nxt_queue_link_t app_link; /* for nxt_app_t.ports */ 246 nxt_queue_link_t idle_link; /* for nxt_app_t.idle_ports */
|
H A D | nxt_process.h | 124 nxt_queue_link_t link; /* for nxt_process_t.children */
|
H A D | nxt_process.c | 1261 nxt_queue_link_t *link, *next; in nxt_process_quit()
|
H A D | nxt_mem_zone.c | 53 nxt_queue_link_t link;
|
H A D | nxt_conn.h | 114 nxt_queue_link_t link; 172 nxt_queue_link_t link;
|
H A D | nxt_event_engine.h | 491 nxt_queue_link_t link; 493 nxt_queue_link_t link0;
|
H A D | nxt_conn_accept.c | 277 nxt_queue_link_t *link, *next; in nxt_conn_accept_close_idle_handler()
|
H A D | nxt_port_socket.c | 571 nxt_queue_link_t *lnk; in nxt_port_msg_first()
|
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_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_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_job.h | 44 nxt_queue_link_t link;
|
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()
|
/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 27 nxt_queue_link_t link;
|