Home
last modified time | relevance | path

Searched refs:nxt_queue_t (Results 1 – 20 of 20) sorted by relevance

/unit/src/
H A Dnxt_router.h32 nxt_queue_t engines;
34 nxt_queue_t sockets; /* of nxt_socket_conf_t */
35 nxt_queue_t apps; /* of nxt_app_t */
74 nxt_queue_t tls; /* of nxt_router_tlssock_t */
77 nxt_queue_t apps; /* of nxt_app_t */
78 nxt_queue_t previous; /* of nxt_app_t */
109 nxt_queue_t ports; /* of nxt_port_t.app_link */
112 nxt_queue_t spare_ports; /* of nxt_port_t.idle_link */
113 nxt_queue_t idle_ports; /* of nxt_port_t.idle_link */
146 nxt_queue_t ack_waiting_req; /* of nxt_http_request_t.app_link */
H A Dnxt_queue.c17 nxt_queue_middle(nxt_queue_t *queue) in nxt_queue_middle()
53 nxt_queue_sort(nxt_queue_t *queue, in nxt_queue_sort()
H A Dnxt_cache.h23 nxt_queue_t expiry_queue;
25 nxt_queue_t free_nodes;
H A Dnxt_queue.h21 } nxt_queue_t; typedef
197 NXT_EXPORT nxt_queue_link_t *nxt_queue_middle(nxt_queue_t *queue);
198 NXT_EXPORT void nxt_queue_sort(nxt_queue_t *queue,
H A Dnxt_process.h102 nxt_queue_t ports; /* of nxt_port_t.link */
119 nxt_queue_t children; /* of nxt_process_t.link */
152 nxt_queue_t *siblings;
H A Dnxt_mp.c121 nxt_queue_t free_pages;
122 nxt_queue_t nget_pages;
123 nxt_queue_t get_pages;
124 nxt_queue_t chunk_pages[];
150 static void *nxt_mp_get_small(nxt_mp_t *mp, nxt_queue_t *pages, size_t size);
247 nxt_queue_t *chunk_pages; in nxt_mp_create()
254 mp = nxt_zalloc(sizeof(nxt_mp_t) + pages * sizeof(nxt_queue_t)); in nxt_mp_create()
524 nxt_queue_t *chunk_pages; in nxt_mp_alloc_small()
595 nxt_mp_get_small(nxt_mp_t *mp, nxt_queue_t *pages, size_t size) in nxt_mp_get_small()
866 nxt_queue_t *chunk_pages; in nxt_mp_chunk_free()
H A Dnxt_event_engine.h481 nxt_queue_t joints;
482 nxt_queue_t listen_connections;
483 nxt_queue_t idle_connections;
H A Dnxt_runtime.h78 nxt_queue_t engines; /* of nxt_event_engine_t */
H A Dnxt_unit.c159 nxt_queue_t *awaiting_req);
302 nxt_queue_t free_req;
305 nxt_queue_t free_ws;
308 nxt_queue_t active_req;
314 nxt_queue_t ready_req;
320 nxt_queue_t free_rbuf;
338 nxt_queue_t awaiting_rbuf;
392 nxt_queue_t awaiting_req;
4739 nxt_queue_t pending_rbuf; in nxt_unit_process_pending_rbuf()
5434 nxt_queue_t awaiting_req; in nxt_unit_add_port()
[all …]
H A Dnxt_conn_accept.c276 nxt_queue_t *idle; in nxt_conn_accept_close_idle_handler()
H A Dnxt_port.h240 nxt_queue_t messages; /* of nxt_port_send_msg_t */
H A Dnxt_router.c163 nxt_router_engine_conf_t *recf, nxt_queue_t *sockets,
168 nxt_router_engine_conf_t *recf, nxt_queue_t *sockets);
297 nxt_queue_t creating_sockets;
298 nxt_queue_t pending_sockets;
299 nxt_queue_t updating_sockets;
300 nxt_queue_t keeping_sockets;
301 nxt_queue_t deleting_sockets;
2280 nxt_router_app_find(nxt_queue_t *queue, nxt_str_t *name) in nxt_router_app_find()
3160 nxt_router_engine_conf_t *recf, nxt_queue_t *sockets, in nxt_router_engine_joints_create()
3242 nxt_router_engine_conf_t *recf, nxt_queue_t *sockets) in nxt_router_engine_joints_delete()
[all …]
H A Dnxt_process.c1005 nxt_queue_t *listen; in nxt_process_quit()
H A Dnxt_controller.c128 static nxt_queue_t nxt_controller_waiting_requests;
548 nxt_queue_t queue; in nxt_controller_flush_requests()
H A Dnxt_application.c80 static nxt_queue_t nxt_proto_children;
H A Dnxt_runtime.c472 nxt_queue_t *idle; in nxt_runtime_close_idle_connections()
H A Dnxt_main_process.c877 nxt_queue_t children; in nxt_main_process_sigchld_handler()
/unit/src/python/
H A Dnxt_python_asgi.h27 nxt_queue_t drain_queue;
H A Dnxt_python_asgi_websocket.c41 nxt_queue_t pending_frames;
/unit/src/test/
H A Dnxt_unit_websocket_chat.c42 static nxt_queue_t ws_chat_sessions;