/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 149 nxt_queue_each(data, &ws_chat_sessions, ws_chat_request_data_t, link) { in ws_chat_broadcast()
|
/unit/src/ |
H A D | nxt_queue.h | 203 #define nxt_queue_each(elt, queue, type, link) \ macro
|
H A D | nxt_process.h | 185 nxt_queue_each(port, &process->ports, nxt_port_t, link)
|
H A D | nxt_unit.c | 4069 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 D | nxt_main_process.c | 1035 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 D | nxt_router.c | 970 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 D | nxt_runtime.c | 611 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 D | nxt_port_memory.c | 878 nxt_queue_each(port, &process->ports, nxt_port_t, link) { in nxt_port_broadcast_shm_ack()
|
H A D | nxt_process.c | 316 nxt_queue_each(p, init->siblings, nxt_process_t, link) { in nxt_process_child_fixup()
|
H A D | nxt_application.c | 692 nxt_queue_each(process, &nxt_proto_children, nxt_process_t, link) { in nxt_proto_quit_children()
|
H A D | nxt_port_socket.c | 1359 nxt_queue_each(msg, &port->messages, nxt_port_send_msg_t, link) { in nxt_port_error_handler()
|
H A D | nxt_controller.c | 581 nxt_queue_each(req, &queue, nxt_controller_request_t, link) { in nxt_controller_flush_requests()
|
/unit/src/python/ |
H A D | nxt_python_asgi_websocket.c | 930 nxt_queue_each(p, &ws->pending_frames, nxt_py_asgi_penging_frame_t, link) { in nxt_py_asgi_websocket_pending_len()
|