Home
last modified time | relevance | path

Searched refs:nxt_queue_each (Results 1 – 13 of 13) 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.h185 nxt_queue_each(port, &process->ports, nxt_port_t, link)
H A Dnxt_unit.c4069 nxt_queue_each(rbuf, &awaiting_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_incoming_mmap()
4763 nxt_queue_each(rbuf, &pending_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_process_pending_rbuf()
4809 nxt_queue_each(req_impl, &ready_req, in nxt_unit_process_ready_req()
5190 nxt_queue_each(req_impl, &ctx_impl->active_req, in nxt_unit_ctx_free()
5208 nxt_queue_each(req_impl, &ctx_impl->free_req, in nxt_unit_ctx_free()
5215 nxt_queue_each(ws_impl, &ctx_impl->free_ws, in nxt_unit_ctx_free()
5222 nxt_queue_each(rbuf, &ctx_impl->free_rbuf, nxt_unit_read_buf_t, link) in nxt_unit_ctx_free()
5623 nxt_queue_each(req_impl, awaiting_req, in nxt_unit_process_awaiting_req()
5730 nxt_queue_each(port, &ports, nxt_unit_port_impl_t, link) { in nxt_unit_remove_process()
5738 nxt_queue_each(port, &ports, nxt_unit_port_impl_t, link) { in nxt_unit_remove_process()
[all …]
H A Dnxt_main_process.c1035 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
1046 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
1064 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
H A Dnxt_router.c970 nxt_queue_each(app, &nxt_router->apps, nxt_app_t, link) { in nxt_router_status_handler()
987 nxt_queue_each(engine, &nxt_router->engines, nxt_event_engine_t, link0) { in nxt_router_status_handler()
1000 nxt_queue_each(app, &nxt_router->apps, nxt_app_t, link) { in nxt_router_status_handler()
1047 nxt_queue_each(engine, &nxt_router->engines, nxt_event_engine_t, link0) in nxt_router_remove_pid_handler()
1237 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_apply()
1374 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_error()
2160 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_create()
2456 nxt_queue_each(app, queue, nxt_app_t, link) { in nxt_router_app_find()
3505 nxt_queue_each(app, &router->apps, nxt_app_t, link) { in nxt_router_apps_sort()
4609 nxt_queue_each(port, &app->ports, nxt_port_t, app_link) { in nxt_router_app_get_port_for_quit()
H A Dnxt_runtime.c611 nxt_queue_each(engine, &rt->engines, nxt_event_engine_t, link) { in nxt_runtime_exit()
1527 nxt_queue_each(child, &process->children, nxt_process_t, link) { in nxt_runtime_process_release()
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_process.c316 nxt_queue_each(p, init->siblings, nxt_process_t, link) { in nxt_process_child_fixup()
H A Dnxt_application.c692 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.c581 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()