Home
last modified time | relevance | path

Searched refs:nxt_queue_insert_tail (Results 1 – 13 of 13) sorted by relevance

/unit/src/test/
H A Dnxt_unit_websocket_chat.c75 nxt_queue_insert_tail(&ws_chat_sessions, &data->link); in ws_chat_request_handler()
/unit/src/
H A Dnxt_queue.h105 #define nxt_queue_insert_tail(queue, link) \ macro
H A Dnxt_router.c1095 nxt_queue_insert_tail(&creating_sockets, qlk); in nxt_router_conf_apply()
1732 nxt_queue_insert_tail(&tmcf->apps, &app->link); in nxt_router_conf_create()
2050 nxt_queue_insert_tail(&tmcf->tls, &tls->link); in nxt_router_conf_tls_insert()
2563 nxt_queue_insert_tail(&keeping_sockets, qlk); in nxt_router_listen_socket_find()
2571 nxt_queue_insert_tail(&pending_sockets, &nskcf->link); in nxt_router_listen_socket_find()
2931 nxt_queue_insert_tail(&app->ports, &port->app_link); in nxt_router_app_prefork_ready()
2932 nxt_queue_insert_tail(&app->spare_ports, &port->idle_link); in nxt_router_app_prefork_ready()
3277 nxt_queue_insert_tail(&rt->engines, &engine->link); in nxt_router_thread_create()
3532 nxt_queue_insert_tail(&engine->joints, &joint->link); in nxt_router_listen_socket_update()
4429 nxt_queue_insert_tail(&app->spare_ports, idle_lnk); in nxt_router_req_headers_ack_handler()
[all …]
H A Dnxt_conn_accept.c75 nxt_queue_insert_tail(&engine->listen_connections, &lev->link); in nxt_listen_event()
H A Dnxt_port_socket.c319 nxt_queue_insert_tail(&port->messages, &msg->link); in nxt_port_msg_chk_insert()
480 nxt_queue_insert_tail(&port->messages, &msg->link); in nxt_port_write_handler()
694 nxt_queue_insert_tail(&port->messages, &msg->link); in nxt_port_msg_insert_tail()
H A Dnxt_unit.c675 nxt_queue_insert_tail(&lib->contexts, &ctx_impl->link); in nxt_unit_ctx_init()
696 nxt_queue_insert_tail(&ctx_impl->free_req, &ctx_impl->req.link); in nxt_unit_ctx_init()
1492 nxt_queue_insert_tail(&port_impl->awaiting_req, in nxt_unit_request_check_response_port()
1545 nxt_queue_insert_tail(&process->ports, &port_impl->link); in nxt_unit_request_check_response_port()
1764 nxt_queue_insert_tail(&ctx_impl->active_req, &req_impl->link); in nxt_unit_request_info_get()
1818 nxt_queue_insert_tail(&ctx_impl->free_req, &req_impl->link); in nxt_unit_request_info_release()
1892 nxt_queue_insert_tail(&ws_impl->ctx_impl->free_ws, &ws_impl->link); in nxt_unit_websocket_frame_release()
3661 nxt_queue_insert_tail(&ctx_impl->pending_rbuf, &rbuf->link); in nxt_unit_wait_shm_ack()
4181 nxt_queue_insert_tail(&mm->awaiting_rbuf, &rbuf->link); in nxt_unit_check_rbuf_mmap()
5550 nxt_queue_insert_tail(&process->ports, &new_port->link); in nxt_unit_add_port()
[all …]
H A Dnxt_controller.c1203 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config()
1316 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config()
1783 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_control()
H A Dnxt_process.c992 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add()
H A Dnxt_application.c1121 nxt_queue_insert_tail(&nxt_proto_children, &process->link); in nxt_proto_process_add()
H A Dnxt_runtime.c309 nxt_queue_insert_tail(&rt->engines, &engine->link); in nxt_runtime_event_engines()
H A Dnxt_main_process.c674 nxt_queue_insert_tail(&pprocess->children, &port->process->link); in nxt_main_process_whoami_handler()
/unit/src/python/
H A Dnxt_python_asgi_websocket.c710 nxt_queue_insert_tail(&ws->pending_frames, &p->link); in nxt_py_asgi_websocket_suspend_frame()
H A Dnxt_python_asgi.c1400 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()