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.c620 nxt_queue_init(&lib->contexts); in nxt_unit_create()
685 nxt_queue_init(&ctx_impl->free_req); in nxt_unit_ctx_init()
686 nxt_queue_init(&ctx_impl->free_ws); in nxt_unit_ctx_init()
688 nxt_queue_init(&ctx_impl->ready_req); in nxt_unit_ctx_init()
4029 nxt_queue_init(&awaiting_rbuf); in nxt_unit_incoming_mmap()
4462 nxt_queue_init(&process->ports); in nxt_unit_process_get()
4739 nxt_queue_init(&pending_rbuf); in nxt_unit_process_pending_rbuf()
4787 nxt_queue_init(&ready_req); in nxt_unit_process_ready_req()
5465 nxt_queue_init(&awaiting_req); in nxt_unit_add_port()
5582 nxt_queue_init(&awaiting_req); in nxt_unit_add_port()
[all …]
H A Dnxt_router.c369 nxt_queue_init(&router->engines); in nxt_router_start()
370 nxt_queue_init(&router->sockets); in nxt_router_start()
371 nxt_queue_init(&router->apps); in nxt_router_start()
1028 nxt_queue_init(&creating_sockets); in nxt_router_temp_conf()
1029 nxt_queue_init(&pending_sockets); in nxt_router_temp_conf()
1030 nxt_queue_init(&updating_sockets); in nxt_router_temp_conf()
1031 nxt_queue_init(&keeping_sockets); in nxt_router_temp_conf()
1035 nxt_queue_init(&tmcf->tls); in nxt_router_temp_conf()
1038 nxt_queue_init(&tmcf->apps); in nxt_router_temp_conf()
1039 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_controller.c305 nxt_queue_init(&nxt_controller_waiting_requests); in nxt_controller_start()
543 nxt_queue_init(&queue); in nxt_controller_flush_requests()
546 nxt_queue_init(&nxt_controller_waiting_requests); in nxt_controller_flush_requests()
H A Dnxt_port.c72 nxt_queue_init(&port->messages); in nxt_port_new()
H A Dnxt_main_process.c948 nxt_queue_init(&children); in nxt_main_process_sigchld_handler()
953 nxt_queue_init(&process->children); in nxt_main_process_sigchld_handler()
H A Dnxt_application.c507 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.c217 nxt_queue_init(&ctx_data->drain_queue); in nxt_python_asgi_ctx_data_alloc()