Function cbm_daemon_ipc_connect

src/daemon/ipc.c:2957–3030

}

cbm_daemon_ipc_connection_t *cbm_daemon_ipc_connect(const cbm_daemon_ipc_endpoint_t *endpoint,
                                                    uint32_t timeout_ms) {
    if (!endpoint_runtime_still_valid(endpoint)) {
        return NULL;
    }
    uint64_t deadline_ms = ipc_deadline_after(timeout_ms);
    for (;;) {
        struct stat status;
        if (fstatat(endpoint->dir_fd, endpoint->socket_name, &status, AT_SYMLINK_NOFOLLOW) != 0) {
            int path_error = errno;
            if (path_error == ENOENT && ipc_retry_pause(deadline_ms)) {
                continue;
            }
            return NULL;
        }
        if (!posix_socket_status_secure_transport(&status)) {
            return NULL;
        }

        int fd = local_socket_new();
        if (fd < 0) {
            return NULL;
        }
        struct sockaddr_un address;
        socklen_t address_length;
        if (!unix_address_set(&address, endpoint->address, &address_length)) {
            (void)close(fd);
            return NULL;
        }

        int result = local_socket_connect(fd, &address, address_length);
        int connect_error = result == 0 ? 0 : errno;
        if (result != 0 && connect_error != EINPROGRESS && connect_error != EAGAIN &&
            connect_error != EWOULDBLOCK) {
            (void)close(fd);
            if ((connect_error == ENOENT || connect_error == ECONNREFUSED) &&
                ipc_retry_pause(deadline_ms)) {
                continue;
            }
            return NULL;
        }
        if (result != 0) {
            int ready = poll_until(fd, POLLOUT, deadline_ms);
            int socket_error = 0;
            socklen_t error_length = sizeof(socket_error);
            if (ready != 1 ||
                getsockopt(fd, SOL_SOCKET, SO_ERROR, &socket_error, &error_length) != 0) {
                (void)close(fd);
                return NULL;
            }
            if (socket_error != 0) {
                (void)close(fd);
                if ((socket_error == ENOENT || socket_error == ECONNREFUSED) &&
                    ipc_retry_pause(deadline_ms)) {
                    continue;
                }
                return NULL;
            }