Function cli_wait_distributed_route

ds4_cli.c:100–129

    /* CLI flag wiring: raw argv values for --gpu-vram and --gpu-devices.
     * Resolved post-parse via parse_gpu_vram_arg(). */
    const char *gpu_vram_arg;
    const char *gpu_devices_arg;
} cli_config;

static volatile sig_atomic_t cli_interrupted;
static volatile sig_atomic_t cli_dist_busy;
static volatile sig_atomic_t cli_dist_notice_printed;

static const char cli_dist_drain_msg[] =
    "\nds4: stopping after the distributed cluster finishes the current token/chunk...\n";

static void cli_sigint_handler(int sig) {
    (void)sig;
    cli_interrupted = 1;
    if (cli_dist_busy && !cli_dist_notice_printed) {
        cli_dist_notice_printed = 1;
        ssize_t ignored = write(STDERR_FILENO,
                                cli_dist_drain_msg,
                                sizeof(cli_dist_drain_msg) - 1u);
        (void)ignored;
    }
}

static bool cli_interrupt_requested(void) {
    return cli_interrupted != 0;
}

static void cli_interrupt_clear(void) {
    cli_interrupted = 0;
    cli_dist_notice_printed = 0;
}

static bool cli_distributed_coordinator(const cli_config *cfg) {