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.c1156 nxt_queue_insert_tail(&creating_sockets, qlk); in nxt_router_conf_apply()
1792 nxt_queue_insert_tail(&tmcf->apps, &app->link); in nxt_router_conf_create()
2088 nxt_queue_insert_tail(&tmcf->tls, &tls->link); in nxt_router_conf_tls_insert()
2601 nxt_queue_insert_tail(&keeping_sockets, qlk); in nxt_router_listen_socket_find()
2609 nxt_queue_insert_tail(&pending_sockets, &nskcf->link); in nxt_router_listen_socket_find()
2969 nxt_queue_insert_tail(&app->ports, &port->app_link); in nxt_router_app_prefork_ready()
2970 nxt_queue_insert_tail(&app->spare_ports, &port->idle_link); in nxt_router_app_prefork_ready()
3315 nxt_queue_insert_tail(&rt->engines, &engine->link); in nxt_router_thread_create()
3570 nxt_queue_insert_tail(&engine->joints, &joint->link); in nxt_router_listen_socket_update()
4089 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.c671 nxt_queue_insert_tail(&lib->contexts, &ctx_impl->link); in nxt_unit_ctx_init()
692 nxt_queue_insert_tail(&ctx_impl->free_req, &ctx_impl->req.link); in nxt_unit_ctx_init()
1488 nxt_queue_insert_tail(&port_impl->awaiting_req, in nxt_unit_request_check_response_port()
1541 nxt_queue_insert_tail(&process->ports, &port_impl->link); in nxt_unit_request_check_response_port()
1760 nxt_queue_insert_tail(&ctx_impl->active_req, &req_impl->link); in nxt_unit_request_info_get()
1814 nxt_queue_insert_tail(&ctx_impl->free_req, &req_impl->link); in nxt_unit_request_info_release()
1888 nxt_queue_insert_tail(&ws_impl->ctx_impl->free_ws, &ws_impl->link); in nxt_unit_websocket_frame_release()
3657 nxt_queue_insert_tail(&ctx_impl->pending_rbuf, &rbuf->link); in nxt_unit_wait_shm_ack()
4177 nxt_queue_insert_tail(&mm->awaiting_rbuf, &rbuf->link); in nxt_unit_check_rbuf_mmap()
5546 nxt_queue_insert_tail(&process->ports, &new_port->link); in nxt_unit_add_port()
[all …]
H A Dnxt_controller.c1242 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config()
1355 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config()
1503 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_status()
1944 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_control()
H A Dnxt_process.c968 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add()
H A Dnxt_application.c1164 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.c1444 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()