Home
last modified time | relevance | path

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

/unit/src/
H A Dnxt_application.c1223 nxt_queue_insert_tail(&nxt_proto_children, &process->link); in nxt_proto_process_add()
H A Dnxt_conn_accept.c75 nxt_queue_insert_tail(&engine->listen_connections, &lev->link); in nxt_listen_event()
H A Dnxt_controller.c1316 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config()
1429 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config()
1577 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_status()
2306 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_control()
H A Dnxt_main_process.c754 nxt_queue_insert_tail(&pprocess->children, &port->process->link); in nxt_main_process_whoami_handler()
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_process.c1224 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add()
H A Dnxt_queue.h105 #define nxt_queue_insert_tail(queue, link) \ macro
H A Dnxt_router.c1193 nxt_queue_insert_tail(&creating_sockets, qlk); in nxt_router_conf_apply()
1866 nxt_queue_insert_tail(&tmcf->apps, &app->link); in nxt_router_conf_create()
2192 nxt_queue_insert_tail(&tmcf->tls, &tls->link); in nxt_router_conf_tls_insert()
2265 nxt_queue_insert_tail(&tmcf->js_modules, &js_module->link); in nxt_router_js_module_insert()
2773 nxt_queue_insert_tail(&keeping_sockets, qlk); in nxt_router_listen_socket_find()
2781 nxt_queue_insert_tail(&pending_sockets, &nskcf->link); in nxt_router_listen_socket_find()
3141 nxt_queue_insert_tail(&app->ports, &port->app_link); in nxt_router_app_prefork_ready()
3142 nxt_queue_insert_tail(&app->spare_ports, &port->idle_link); in nxt_router_app_prefork_ready()
3487 nxt_queue_insert_tail(&rt->engines, &engine->link); in nxt_router_thread_create()
3742 nxt_queue_insert_tail(&engine->joints, &joint->link); in nxt_router_listen_socket_update()
[all …]
H A Dnxt_runtime.c309 nxt_queue_insert_tail(&rt->engines, &engine->link); in nxt_runtime_event_engines()
H A Dnxt_unit.c689 nxt_queue_insert_tail(&lib->contexts, &ctx_impl->link); in nxt_unit_ctx_init()
710 nxt_queue_insert_tail(&ctx_impl->free_req, &ctx_impl->req.link); in nxt_unit_ctx_init()
1506 nxt_queue_insert_tail(&port_impl->awaiting_req, in nxt_unit_request_check_response_port()
1559 nxt_queue_insert_tail(&process->ports, &port_impl->link); in nxt_unit_request_check_response_port()
1778 nxt_queue_insert_tail(&ctx_impl->active_req, &req_impl->link); in nxt_unit_request_info_get()
1832 nxt_queue_insert_tail(&ctx_impl->free_req, &req_impl->link); in nxt_unit_request_info_release()
1906 nxt_queue_insert_tail(&ws_impl->ctx_impl->free_ws, &ws_impl->link); in nxt_unit_websocket_frame_release()
3676 nxt_queue_insert_tail(&ctx_impl->pending_rbuf, &rbuf->link); in nxt_unit_wait_shm_ack()
4196 nxt_queue_insert_tail(&mm->awaiting_rbuf, &rbuf->link); in nxt_unit_check_rbuf_mmap()
5565 nxt_queue_insert_tail(&process->ports, &new_port->link); in nxt_unit_add_port()
[all …]
/unit/src/python/
H A Dnxt_python_asgi.c1510 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()
H A Dnxt_python_asgi_websocket.c710 nxt_queue_insert_tail(&ws->pending_frames, &p->link); in nxt_py_asgi_websocket_suspend_frame()
/unit/src/test/
H A Dnxt_unit_websocket_chat.c75 nxt_queue_insert_tail(&ws_chat_sessions, &data->link); in ws_chat_request_handler()