Home
last modified time | relevance | path

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

/unit/src/
H A Dnxt_port.c38 nxt_assert(nxt_queue_is_empty(&port->messages)); in nxt_port_mp_cleanup()
327 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_port_process_ready_handler()
474 || nxt_queue_is_empty(&p->ports)) in nxt_port_remove_notify_others()
H A Dnxt_queue.h47 #define nxt_queue_is_empty(queue) \ macro
H A Dnxt_application.c680 if (nxt_queue_is_empty(&nxt_proto_children)) { in nxt_proto_quit_handler()
730 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_proto_process_created_handler()
757 if (nxt_queue_is_empty(&nxt_proto_children)) { in nxt_proto_sigterm_handler()
840 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_proto_sigchld_handler()
855 if (nxt_proto_exiting && nxt_queue_is_empty(&nxt_proto_children)) { in nxt_proto_sigchld_handler()
H A Dnxt_mp.c385 && nxt_queue_is_empty(&mp->free_pages)); in nxt_mp_is_empty()
537 if (nxt_fast_path(!nxt_queue_is_empty(chunk_pages))) { in nxt_mp_alloc_small()
651 if (nxt_queue_is_empty(&mp->free_pages)) { in nxt_mp_alloc_page()
H A Dnxt_process.c373 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_process_create()
977 return nxt_queue_is_empty(&process->ports) ? 0 : in nxt_process_type()
H A Dnxt_router.c3633 if (nxt_queue_is_empty(&engine->joints)) { in nxt_router_worker_thread_quit()
3724 if (engine->shutdown && nxt_queue_is_empty(&engine->joints)) { in nxt_router_listen_event_release()
4083 nxt_assert(!nxt_queue_is_empty(&app->idle_ports)); in nxt_router_req_headers_ack_handler()
4359 if (app->processes == 0 && !nxt_queue_is_empty(&app->ack_waiting_req)) { in nxt_router_app_port_error()
4378 && !nxt_queue_is_empty(&app->ack_waiting_req)) in nxt_router_app_port_error()
4628 nxt_assert(!nxt_queue_is_empty(&app->idle_ports)); in nxt_router_app_port_close()
4703 nxt_assert(!nxt_queue_is_empty(&app->idle_ports)); in nxt_router_adjust_idle_timer()
4850 nxt_assert(nxt_queue_is_empty(&app->ports)); in nxt_router_free_app()
4851 nxt_assert(nxt_queue_is_empty(&app->spare_ports)); in nxt_router_free_app()
4852 nxt_assert(nxt_queue_is_empty(&app->idle_ports)); in nxt_router_free_app()
H A Dnxt_unit.c1757 if (nxt_queue_is_empty(&ctx_impl->free_req)) { in nxt_unit_request_info_get()
1868 if (nxt_queue_is_empty(&ctx_impl->free_ws)) { in nxt_unit_websocket_frame_get()
2808 if (!nxt_queue_is_empty(&ctx_impl->free_rbuf)) { in nxt_unit_read_buf_get_impl()
4193 need_rbuf = nxt_queue_is_empty(&mm->awaiting_rbuf); in nxt_unit_check_rbuf_mmap()
4747 if (nxt_queue_is_empty(&ctx_impl->pending_rbuf)) { in nxt_unit_process_pending_rbuf()
4795 if (nxt_queue_is_empty(&ctx_impl->ready_req)) { in nxt_unit_process_ready_req()
5496 if (!nxt_queue_is_empty(&old_port_impl->awaiting_req)) { in nxt_unit_add_port()
5511 if (!nxt_queue_is_empty(&old_port_impl->awaiting_req)) { in nxt_unit_add_port()
5602 if (!nxt_queue_is_empty(&new_port->awaiting_req)) { in nxt_unit_add_port()
5794 quit = nxt_queue_is_empty(&ctx_impl->active_req) in nxt_unit_quit()
[all …]
H A Dnxt_port_memory.c858 if (nxt_slow_path(process == NULL || nxt_queue_is_empty(&process->ports))) in nxt_process_broadcast_shm_ack()
H A Dnxt_port_socket.c311 && nxt_queue_is_empty(&port->messages))) in nxt_port_msg_chk_insert()
H A Dnxt_runtime.c1413 nxt_assert(nxt_queue_is_empty(&process->ports)); in nxt_runtime_process_release()
H A Dnxt_main_process.c938 if (!nxt_queue_is_empty(&process->children)) { in nxt_main_process_sigchld_handler()
H A Dnxt_controller.c1486 if (!nxt_queue_is_empty(&nxt_controller_waiting_requests) in nxt_controller_check_postpone_request()
/unit/src/python/
H A Dnxt_python_asgi_websocket.c544 if (!nxt_queue_is_empty(&ws->pending_frames)) { in nxt_py_asgi_websocket_handler()
745 if (nxt_queue_is_empty(&ws->pending_frames) in nxt_py_asgi_websocket_pop_msg()
861 while (!nxt_queue_is_empty(&ws->pending_frames)) { in nxt_py_asgi_websocket_pop_msg()
1081 while (!nxt_queue_is_empty(&ws->pending_frames)) { in nxt_py_asgi_websocket_done()
H A Dnxt_python_asgi.c1075 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()