Home
last modified time | relevance | path

Searched refs:nxt_queue_init (Results 1 – 14 of 14) sorted by relevance

/unit/src/
H A Dnxt_mp.c267 nxt_queue_init(chunk_pages); in nxt_mp_create()
272 nxt_queue_init(&mp->free_pages); in nxt_mp_create()
273 nxt_queue_init(&mp->nget_pages); in nxt_mp_create()
274 nxt_queue_init(&mp->get_pages); in nxt_mp_create()
H A Dnxt_queue.h24 #define nxt_queue_init(queue) \ macro
H A Dnxt_event_engine.c139 nxt_queue_init(&engine->joints); in nxt_event_engine_create()
140 nxt_queue_init(&engine->listen_connections); in nxt_event_engine_create()
141 nxt_queue_init(&engine->idle_connections); in nxt_event_engine_create()
H A Dnxt_unit.c625 nxt_queue_init(&lib->contexts); in nxt_unit_create()
699 nxt_queue_init(&ctx_impl->free_req); in nxt_unit_ctx_init()
700 nxt_queue_init(&ctx_impl->free_ws); in nxt_unit_ctx_init()
702 nxt_queue_init(&ctx_impl->ready_req); in nxt_unit_ctx_init()
4043 nxt_queue_init(&awaiting_rbuf); in nxt_unit_incoming_mmap()
4476 nxt_queue_init(&process->ports); in nxt_unit_process_get()
4753 nxt_queue_init(&pending_rbuf); in nxt_unit_process_pending_rbuf()
4801 nxt_queue_init(&ready_req); in nxt_unit_process_ready_req()
5479 nxt_queue_init(&awaiting_req); in nxt_unit_add_port()
5596 nxt_queue_init(&awaiting_req); in nxt_unit_add_port()
[all …]
H A Dnxt_router.c347 nxt_queue_init(&router->engines); in nxt_router_start()
348 nxt_queue_init(&router->sockets); in nxt_router_start()
349 nxt_queue_init(&router->apps); in nxt_router_start()
1089 nxt_queue_init(&creating_sockets); in nxt_router_temp_conf()
1090 nxt_queue_init(&pending_sockets); in nxt_router_temp_conf()
1091 nxt_queue_init(&updating_sockets); in nxt_router_temp_conf()
1092 nxt_queue_init(&keeping_sockets); in nxt_router_temp_conf()
1096 nxt_queue_init(&tmcf->tls); in nxt_router_temp_conf()
1099 nxt_queue_init(&tmcf->apps); in nxt_router_temp_conf()
1100 nxt_queue_init(&tmcf->previous); in nxt_router_temp_conf()
[all …]
H A Dnxt_process.c108 nxt_queue_init(&process->ports); in nxt_process_new()
114 nxt_queue_init(&process->children); in nxt_process_new()
H A Dnxt_port.c72 nxt_queue_init(&port->messages); in nxt_port_new()
H A Dnxt_controller.c313 nxt_queue_init(&nxt_controller_waiting_requests); in nxt_controller_start()
551 nxt_queue_init(&queue); in nxt_controller_flush_requests()
554 nxt_queue_init(&nxt_controller_waiting_requests); in nxt_controller_flush_requests()
H A Dnxt_main_process.c936 nxt_queue_init(&children); in nxt_main_process_sigchld_handler()
941 nxt_queue_init(&process->children); in nxt_main_process_sigchld_handler()
H A Dnxt_application.c514 nxt_queue_init(&nxt_proto_children); in nxt_proto_setup()
H A Dnxt_runtime.c308 nxt_queue_init(&rt->engines); in nxt_runtime_event_engines()
/unit/src/test/
H A Dnxt_unit_websocket_chat.c214 nxt_queue_init(&ws_chat_sessions); in main()
/unit/src/python/
H A Dnxt_python_asgi_websocket.c126 nxt_queue_init(&ws->pending_frames); in nxt_py_asgi_websocket_create()
H A Dnxt_python_asgi.c219 nxt_queue_init(&ctx_data->drain_queue); in nxt_python_asgi_ctx_data_alloc()