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.h181 nxt_queue_each(port, &process->ports, nxt_port_t, link)
H A Dnxt_main_process.c943 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
954 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
972 nxt_queue_each(child, &children, nxt_process_t, link) { in nxt_main_process_sigchld_handler()
H A Dnxt_unit.c4068 nxt_queue_each(rbuf, &awaiting_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_incoming_mmap()
4762 nxt_queue_each(rbuf, &pending_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_process_pending_rbuf()
4808 nxt_queue_each(req_impl, &ready_req, in nxt_unit_process_ready_req()
5189 nxt_queue_each(req_impl, &ctx_impl->active_req, in nxt_unit_ctx_free()
5207 nxt_queue_each(req_impl, &ctx_impl->free_req, in nxt_unit_ctx_free()
5214 nxt_queue_each(ws_impl, &ctx_impl->free_ws, in nxt_unit_ctx_free()
5221 nxt_queue_each(rbuf, &ctx_impl->free_rbuf, nxt_unit_read_buf_t, link) in nxt_unit_ctx_free()
5622 nxt_queue_each(req_impl, awaiting_req, in nxt_unit_process_awaiting_req()
5729 nxt_queue_each(port, &ports, nxt_unit_port_impl_t, link) { in nxt_unit_remove_process()
5737 nxt_queue_each(port, &ports, nxt_unit_port_impl_t, link) { in nxt_unit_remove_process()
[all …]
H A Dnxt_router.c948 nxt_queue_each(app, &nxt_router->apps, nxt_app_t, link) { in nxt_router_status_handler()
965 nxt_queue_each(engine, &nxt_router->engines, nxt_event_engine_t, link0) { in nxt_router_status_handler()
978 nxt_queue_each(app, &nxt_router->apps, nxt_app_t, link) { in nxt_router_status_handler()
1025 nxt_queue_each(engine, &nxt_router->engines, nxt_event_engine_t, link0) in nxt_router_remove_pid_handler()
1179 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_apply()
1318 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_error()
2056 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_create()
2284 nxt_queue_each(app, queue, nxt_app_t, link) { in nxt_router_app_find()
3333 nxt_queue_each(app, &router->apps, nxt_app_t, link) { in nxt_router_apps_sort()
4400 nxt_queue_each(port, &app->ports, nxt_port_t, app_link) { in nxt_router_app_get_port_for_quit()
H A Dnxt_runtime.c594 nxt_queue_each(engine, &rt->engines, nxt_event_engine_t, link) { in nxt_runtime_exit()
1406 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.c300 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.c556 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()