Home
last modified time | relevance | path

Searched refs:nxt_queue_link_t (Results 1 – 25 of 26) sorted by relevance

12

/unit/src/
H A Dnxt_queue.c16 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 Dnxt_queue.h11 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 Dnxt_router.h141 nxt_queue_link_t link;
165 nxt_queue_link_t link;
213 nxt_queue_link_t link;
H A Dnxt_port.h186 nxt_queue_link_t link;
230 nxt_queue_link_t link; /* for nxt_process_t.ports */
233 nxt_queue_link_t app_link; /* for nxt_app_t.ports */
237 nxt_queue_link_t idle_link; /* for nxt_app_t.idle_ports */
H A Dnxt_job.h44 nxt_queue_link_t link;
H A Dnxt_cache.h58 nxt_queue_link_t link;
H A Dnxt_port_rpc.c19 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 Dnxt_event_engine.h491 nxt_queue_link_t link;
493 nxt_queue_link_t link0;
H A Dnxt_conn.h114 nxt_queue_link_t link;
172 nxt_queue_link_t link;
H A Dnxt_mp.c32 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 Dnxt_process.h120 nxt_queue_link_t link; /* for nxt_process_t.children */
H A Dnxt_conn_accept.c277 nxt_queue_link_t *link, *next; in nxt_conn_accept_close_idle_handler()
H A Dnxt_router.c1141 nxt_queue_link_t *qlk; in nxt_router_conf_apply()
1296 nxt_queue_link_t *qlk; in nxt_router_conf_error()
2586 nxt_queue_link_t *qlk; in nxt_router_listen_socket_find()
3022 nxt_queue_link_t *qlk; in nxt_router_engines_create()
3165 nxt_queue_link_t *qlk; in nxt_router_engine_joints_create()
3245 nxt_queue_link_t *qlk; in nxt_router_engine_joints_delete()
3537 nxt_queue_link_t *qlk; in nxt_router_listen_event()
4027 nxt_queue_link_t *idle_lnk; in nxt_router_req_headers_ack_handler()
4328 nxt_queue_link_t *link; in nxt_router_app_port_error()
4582 nxt_queue_link_t *idle_lnk; in nxt_router_app_port_close()
[all …]
H A Dnxt_http.h181 nxt_queue_link_t app_link; /* nxt_app_t.ack_waiting_req */
H A Dnxt_cache.c559 nxt_queue_link_t *link; in nxt_cache_node_alloc()
H A Dnxt_unit.c259 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;
1729 nxt_queue_link_t *lnk; in nxt_unit_request_info_get()
1842 nxt_queue_link_t *lnk; in nxt_unit_websocket_frame_get()
2787 nxt_queue_link_t *link; in nxt_unit_read_buf_get_impl()
H A Dnxt_runtime.c473 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 Dnxt_mem_zone.c53 nxt_queue_link_t link;
H A Dnxt_process.c1007 nxt_queue_link_t *link, *next; in nxt_process_quit()
H A Dnxt_port_socket.c571 nxt_queue_link_t *lnk; in nxt_port_msg_first()
/unit/src/python/
H A Dnxt_python_asgi.h14 nxt_queue_link_t *link);
59 int nxt_py_asgi_http_drain(nxt_queue_link_t *lnk);
H A Dnxt_python_asgi_http.c21 nxt_queue_link_t link;
558 nxt_py_asgi_http_drain(nxt_queue_link_t *lnk) in nxt_py_asgi_http_drain()
H A Dnxt_python_asgi_websocket.c30 nxt_queue_link_t link;
949 nxt_queue_link_t *lnk; in nxt_py_asgi_websocket_pop_frame()
H A Dnxt_python_asgi.c1072 nxt_queue_link_t *lnk; in nxt_py_asgi_shm_ack_handler()
1438 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 Dnxt_unit_websocket_chat.c27 nxt_queue_link_t link;

12