Searched refs:nxt_queue_is_empty (Results 1 – 13 of 13) sorted by relevance
38 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()
47 #define nxt_queue_is_empty(queue) \ macro
385 && 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()
671 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()
3595 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()
1743 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 …]
1001 return nxt_queue_is_empty(&process->ports) ? 0 : in nxt_process_type()
858 if (nxt_slow_path(process == NULL || nxt_queue_is_empty(&process->ports))) in nxt_process_broadcast_shm_ack()
311 && nxt_queue_is_empty(&port->messages))) in nxt_port_msg_chk_insert()
950 if (!nxt_queue_is_empty(&process->children)) { in nxt_main_process_sigchld_handler()
1439 if (!nxt_queue_is_empty(&nxt_controller_waiting_requests) in nxt_controller_check_postpone_request()
544 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()
1033 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()