Function mcp_run_shell_command_cancellable

src/mcp/mcp.c:10048–10104

#endif

static int mcp_run_shell_command_cancellable(cbm_mcp_server_t *srv, const char *command,
                                             char output_path[CBM_SZ_2K],
                                             cbm_proc_result_t *result_out) {
    if (!srv || !command || !output_path || !result_out || !mcp_command_output_path(output_path)) {
        return -1;
    }
    /* Internal test seam: rejecting after output allocation exercises the same
     * cleanup contract as a contained process-tree failure. */
    if (srv->command_test_hook && !srv->command_test_hook(srv->command_test_context, command)) {
        return -1;
    }
#ifdef _WIN32
    char shell[CBM_SZ_4K];
    if (!mcp_resolve_windows_cmd(shell)) {
        (void)cbm_unlink(output_path);
        output_path[0] = '\0';
        return -1;
    }
#else
    const char *shell = "/bin/sh";
    const char *argv[] = {"sh", "-c", command, NULL};
#endif
    cbm_proc_opts_t options = {
        .bin = shell,
#ifdef _WIN32
        .windows_cmd_payload = command,
#else
        .argv = argv,
#endif
        .log_file = output_path,
        .quiet_timeout_ms = 0,
        .cancel_grace_ms = CBM_SUBPROCESS_DEFAULT_CANCEL_GRACE_MS,
        .delete_log_on_exit = false,
    };
    cbm_subprocess_t *process = NULL;
    if (cbm_subprocess_spawn(&options, &process) != 0) {
        (void)cbm_unlink(output_path);
        output_path[0] = '\0';
        return -1;
    }

    cbm_proc_poll_t state;
    for (;;) {
        if (mcp_request_cancelled(srv)) {
            (void)cbm_subprocess_request_cancel(process);
        }
        state = cbm_subprocess_poll(process, result_out);
        if (state != CBM_PROC_POLL_RUNNING) {
            break;
        }
        cbm_usleep(10000);
    }
    bool contained = state == CBM_PROC_POLL_TERMINAL && result_out->tree_quiesced &&
                     !result_out->supervision_failed;
    cbm_subprocess_destroy(process);
    return contained ? 0 : -1;
}