Home
last modified time | relevance | path

Searched refs:nxt_queue_each (Results 1 – 12 of 12) sorted by relevance

/unit/src/test/
H A Dnxt_unit_websocket_chat.c149 nxt_queue_each(data, &ws_chat_sessions, ws_chat_request_data_t, link) { in ws_chat_broadcast()
/unit/src/
H A Dnxt_queue.h203 #define nxt_queue_each(elt, queue, type, link) \ macro
H A Dnxt_process.h179 nxt_queue_each(port, &process->ports, nxt_port_t, link)
H A Dnxt_main_process.c955 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
966 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
984 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
H A Dnxt_unit.c4054 nxt_queue_each(rbuf, &awaiting_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_incoming_mmap()
4748 nxt_queue_each(rbuf, &pending_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_process_pending_rbuf()
4794 nxt_queue_each(req_impl, &ready_req, in nxt_unit_process_ready_req()
5175 nxt_queue_each(req_impl, &ctx_impl->active_req, in nxt_unit_ctx_free()
5193 nxt_queue_each(req_impl, &ctx_impl->free_req, in nxt_unit_ctx_free()
5200 nxt_queue_each(ws_impl, &ctx_impl->free_ws, in nxt_unit_ctx_free()
5207 nxt_queue_each(rbuf, &ctx_impl->free_rbuf, nxt_unit_read_buf_t, link) in nxt_unit_ctx_free()
5608 nxt_queue_each(req_impl, awaiting_req, in nxt_unit_process_awaiting_req()
5715 nxt_queue_each(port, &ports, nxt_unit_port_impl_t, link) { in nxt_unit_remove_process()
5723 nxt_queue_each(port, &ports, nxt_unit_port_impl_t, link) { in nxt_unit_remove_process()
[all …]
H A Dnxt_runtime.c594 nxt_queue_each(engine, &rt->engines, nxt_event_engine_t, link) { in nxt_runtime_exit()
1404 nxt_queue_each(child, &process->children, nxt_process_t, link) { in nxt_runtime_process_release()
H A Dnxt_router.c969 nxt_queue_each(engine, &nxt_router->engines, nxt_event_engine_t, link0) in nxt_router_remove_pid_handler()
1118 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_apply()
1257 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_error()
2018 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_create()
2246 nxt_queue_each(app, queue, nxt_app_t, link) { in nxt_router_app_find()
3295 nxt_queue_each(app, &router->apps, nxt_app_t, link) { in nxt_router_apps_sort()
4740 nxt_queue_each(port, &app->ports, nxt_port_t, app_link) { in nxt_router_app_get_port_for_quit()
H A Dnxt_port_memory.c878 nxt_queue_each(port, &process->ports, nxt_port_t, link) { in nxt_port_broadcast_shm_ack()
H A Dnxt_application.c683 nxt_queue_each(process, &nxt_proto_children, nxt_process_t, link) { in nxt_proto_quit_children()
H A Dnxt_port_socket.c1359 nxt_queue_each(msg, &port->messages, nxt_port_send_msg_t, link) { in nxt_port_error_handler()
H A Dnxt_controller.c548 nxt_queue_each(req, &queue, nxt_controller_request_t, link) { in nxt_controller_flush_requests()
/unit/src/python/
H A Dnxt_python_asgi_websocket.c930 nxt_queue_each(p, &ws->pending_frames, nxt_py_asgi_penging_frame_t, link) { in nxt_py_asgi_websocket_pending_len()