Searched refs:nxt_queue_insert_tail (Results 1 – 13 of 13) sorted by path
/unit/src/ |
H A D | nxt_application.c | 1223 nxt_queue_insert_tail(&nxt_proto_children, &process->link); in nxt_proto_process_add()
|
H A D | nxt_conn_accept.c | 75 nxt_queue_insert_tail(&engine->listen_connections, &lev->link); in nxt_listen_event()
|
H A D | nxt_controller.c | 1316 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 D | nxt_main_process.c | 754 nxt_queue_insert_tail(&pprocess->children, &port->process->link); in nxt_main_process_whoami_handler()
|
H A D | nxt_port_socket.c | 319 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 D | nxt_process.c | 1224 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add()
|
H A D | nxt_queue.h | 105 #define nxt_queue_insert_tail(queue, link) \ macro
|
H A D | nxt_router.c | 1193 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 D | nxt_runtime.c | 309 nxt_queue_insert_tail(&rt->engines, &engine->link); in nxt_runtime_event_engines()
|
H A D | nxt_unit.c | 689 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 D | nxt_python_asgi.c | 1510 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()
|
H A D | nxt_python_asgi_websocket.c | 710 nxt_queue_insert_tail(&ws->pending_frames, &p->link); in nxt_py_asgi_websocket_suspend_frame()
|
/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 75 nxt_queue_insert_tail(&ws_chat_sessions, &data->link); in ws_chat_request_handler()
|