Home
last modified time | relevance | path

Searched refs:nxt_queue_link_t (Results 1 – 24 of 24) sorted by last modified time

/unit/src/python/
H A Dnxt_python_asgi_http.c21 nxt_queue_link_t link;
565 nxt_py_asgi_http_drain(nxt_queue_link_t *lnk) in nxt_py_asgi_http_drain()
H A Dnxt_python_asgi.c1138 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 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.h14 nxt_queue_link_t *link);
59 int nxt_py_asgi_http_drain(nxt_queue_link_t *lnk);
/unit/src/
H A Dnxt_router.c66 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 Dnxt_runtime.c473 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 Dnxt_router.h147 nxt_queue_link_t link;
171 nxt_queue_link_t link;
223 nxt_queue_link_t link;
H A Dnxt_controller.c28 nxt_queue_link_t link;
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;
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 Dnxt_http.h186 nxt_queue_link_t app_link; /* nxt_app_t.ack_waiting_req */
H A Dnxt_port.h195 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 Dnxt_process.h124 nxt_queue_link_t link; /* for nxt_process_t.children */
H A Dnxt_process.c1261 nxt_queue_link_t *link, *next; in nxt_process_quit()
H A Dnxt_mem_zone.c53 nxt_queue_link_t link;
H A Dnxt_conn.h114 nxt_queue_link_t link;
172 nxt_queue_link_t link;
H A Dnxt_event_engine.h491 nxt_queue_link_t link;
493 nxt_queue_link_t link0;
H A Dnxt_conn_accept.c277 nxt_queue_link_t *link, *next; in nxt_conn_accept_close_idle_handler()
H A Dnxt_port_socket.c571 nxt_queue_link_t *lnk; in nxt_port_msg_first()
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_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_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_job.h44 nxt_queue_link_t link;
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()
/unit/src/test/
H A Dnxt_unit_websocket_chat.c27 nxt_queue_link_t link;