Home
last modified time | relevance | path

Searched refs:nxt_queue_is_empty (Results 1 – 13 of 13) 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_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_application.c671 if (nxt_queue_is_empty(&nxt_proto_children)) { in nxt_proto_quit_handler()
744 if (nxt_queue_is_empty(&nxt_proto_children)) { in nxt_proto_sigterm_handler()
812 if (nxt_proto_exiting && nxt_queue_is_empty(&nxt_proto_children)) { in nxt_proto_sigchld_handler()
H A Dnxt_router.c3595 if (nxt_queue_is_empty(&engine->joints)) { in nxt_router_worker_thread_quit()
3686 if (engine->shutdown && nxt_queue_is_empty(&engine->joints)) { in nxt_router_listen_event_release()
4423 nxt_assert(!nxt_queue_is_empty(&app->idle_ports)); in nxt_router_req_headers_ack_handler()
4699 if (app->processes == 0 && !nxt_queue_is_empty(&app->ack_waiting_req)) { in nxt_router_app_port_error()
4718 && !nxt_queue_is_empty(&app->ack_waiting_req)) in nxt_router_app_port_error()
4968 nxt_assert(!nxt_queue_is_empty(&app->idle_ports)); in nxt_router_app_port_close()
5043 nxt_assert(!nxt_queue_is_empty(&app->idle_ports)); in nxt_router_adjust_idle_timer()
5190 nxt_assert(nxt_queue_is_empty(&app->ports)); in nxt_router_free_app()
5191 nxt_assert(nxt_queue_is_empty(&app->spare_ports)); in nxt_router_free_app()
5192 nxt_assert(nxt_queue_is_empty(&app->idle_ports)); in nxt_router_free_app()
H A Dnxt_unit.c1743 if (nxt_queue_is_empty(&ctx_impl->free_req)) { in nxt_unit_request_info_get()
1854 if (nxt_queue_is_empty(&ctx_impl->free_ws)) { in nxt_unit_websocket_frame_get()
2794 if (!nxt_queue_is_empty(&ctx_impl->free_rbuf)) { in nxt_unit_read_buf_get_impl()
4179 need_rbuf = nxt_queue_is_empty(&mm->awaiting_rbuf); in nxt_unit_check_rbuf_mmap()
4733 if (nxt_queue_is_empty(&ctx_impl->pending_rbuf)) { in nxt_unit_process_pending_rbuf()
4781 if (nxt_queue_is_empty(&ctx_impl->ready_req)) { in nxt_unit_process_ready_req()
5482 if (!nxt_queue_is_empty(&old_port_impl->awaiting_req)) { in nxt_unit_add_port()
5497 if (!nxt_queue_is_empty(&old_port_impl->awaiting_req)) { in nxt_unit_add_port()
5588 if (!nxt_queue_is_empty(&new_port->awaiting_req)) { in nxt_unit_add_port()
5780 quit = nxt_queue_is_empty(&ctx_impl->active_req) in nxt_unit_quit()
[all …]
H A Dnxt_process.c1001 return nxt_queue_is_empty(&process->ports) ? 0 : in nxt_process_type()
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_main_process.c950 if (!nxt_queue_is_empty(&process->children)) { in nxt_main_process_sigchld_handler()
H A Dnxt_controller.c1439 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.c1033 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()