Function cbm_daemon_ipc_accept

src/daemon/ipc.c:2836–2872

}

int cbm_daemon_ipc_accept(cbm_daemon_ipc_listener_t *listener, uint32_t timeout_ms,
                          cbm_daemon_ipc_connection_t **connection_out) {
    if (connection_out) {
        *connection_out = NULL;
    }
    if (!listener || listener->fd < 0 || listener->owner_pid != getpid() || !connection_out) {
        return -1;
    }
    uint64_t deadline_ms = ipc_deadline_after(timeout_ms);
    for (;;) {
        int ready = poll_until(listener->fd, POLLIN, deadline_ms);
        if (ready != 1) {
            return ready;
        }
        int fd = accept(listener->fd, NULL, NULL);
        if (fd < 0) {
            if (errno == EINTR || errno == EAGAIN || errno == EWOULDBLOCK) {
                continue;
            }
            return -1;
        }
        if (!fd_set_cloexec(fd) || !fd_set_nonblocking(fd) || !socket_disable_sigpipe(fd) ||
            !socket_peer_is_current_user(fd)) {
            (void)close(fd);
            return -1;
        }
        cbm_daemon_ipc_connection_t *connection = malloc(sizeof(*connection));
        if (!connection) {
            (void)close(fd);
            return -1;
        }
        connection->fd = fd;
        atomic_init(&connection->poisoned, false);
        *connection_out = connection;
        return 1;
    }
}

int cbm_daemon_ipc_endpoint_probe(const cbm_daemon_ipc_endpoint_t *endpoint, uint32_t timeout_ms) {
    if (!endpoint_runtime_still_valid(endpoint)) {