Function cbm_subprocess_poll_posix

src/foundation/subprocess.c:1298–1346

}

static cbm_proc_poll_t cbm_subprocess_poll_posix(cbm_subprocess_t *process,
                                                 cbm_proc_result_t *out) {
    uint64_t now = cbm_now_ms();

    if (!process->root_reaped) {
        int status = 0;
        pid_t waited = waitpid(process->pid, &status, WNOHANG);
        if (waited == process->pid) {
            cbm_posix_capture_root(process, status);
        } else if (waited < 0 && errno != EINTR) {
            /* ECHILD means another reaper consumed the status. Other permanent
             * wait failures are treated the same: retain containment, stop the
             * tree, and never spin forever on the failed wait operation. */
            process->root_reaped = true;
            process->result.outcome = process->timed_out ? CBM_PROC_HANG : CBM_PROC_KILLED;
            process->result.exit_code = -1;
            process->result.term_signal = 0;
            cbm_posix_begin_termination(process, now);
        }
    }

    bool group_active = cbm_posix_group_active(process);
    if (!process->termination_started) {
        if (cbm_subprocess_cancellation_requested(process)) {
            cbm_posix_begin_termination(process, now);
        } else if (!process->root_reaped && process->quiet_timeout_ms > 0 &&
                   now - process->last_activity_ms >= (uint64_t)process->quiet_timeout_ms) {
            process->timed_out = true;
            cbm_posix_begin_termination(process, now);
        } else if (process->root_reaped && group_active) {
            /* A root that daemonizes children is not terminal. Preserve its exit
             * classification, but drain the descendants through the same path. */
            cbm_posix_begin_termination(process, now);
        }
    }
    if (process->termination_started && group_active && !process->force_sent &&
        now - process->termination_started_ms >= (uint64_t)process->cancel_grace_ms) {
        cbm_posix_force_tree(process, now);
    }
    group_active = cbm_posix_group_active(process);
    if (process->force_started_ms != 0 && group_active &&
        now - process->force_started_ms >= CBM_SUBPROCESS_FORCE_SETTLE_MS) {
        return cbm_subprocess_finish_failed(process, out);
    }
    if (process->root_reaped && !group_active) {
        return cbm_subprocess_finish(process, out);
    }
    return CBM_PROC_POLL_RUNNING;
}

#endif /* _WIN32 */