Prepare for pipewire audio routing

1 files changed, 0 insertions, 788 deletions

diff --git a/src/pipewire.c b/src/pipewire.c
deleted file mode 100644
index 3bf54db..0000000
--- a/src/pipewire.c
+++ /dev/null
@@ -1,788 +0,0 @@
-#include "../include/pipewire.h"
-#include "../include/egl.h"
-#include "../include/utils.h"
-
-#include <pipewire/pipewire.h>
-#include <spa/param/video/format-utils.h>
-#include <spa/debug/types.h>
-
-#include <libdrm/drm_fourcc.h>
-
-#include <fcntl.h>
-#include <unistd.h>
-
-/* This code is partially based on xr-video-player pipewire implementation which is based on obs-studio's pipewire implementation */
-
-/* TODO: Make gsr_pipewire_init asynchronous */
-/* TODO: Support 10-bit capture (hdr) when pipewire supports it */
-/* TODO: Test all of the image formats */
-
-#ifndef SPA_POD_PROP_FLAG_DONT_FIXATE
-#define SPA_POD_PROP_FLAG_DONT_FIXATE (1 << 4)
-#endif
-
-#define CURSOR_META_SIZE(width, height)                                    \
-    (sizeof(struct spa_meta_cursor) + sizeof(struct spa_meta_bitmap) + \
-     width * height * 4)
-
-static bool parse_pw_version(gsr_pipewire_data_version *dst, const char *version) {
-    const int n_matches = sscanf(version, "%d.%d.%d", &dst->major, &dst->minor, &dst->micro);
-    return n_matches == 3;
-}
-
-static bool check_pw_version(const gsr_pipewire_data_version *pw_version, int major, int minor, int micro) {
-    if (pw_version->major != major)
-        return pw_version->major > major;
-    if (pw_version->minor != minor)
-        return pw_version->minor > minor;
-    return pw_version->micro >= micro;
-}
-
-static void update_pw_versions(gsr_pipewire *self, const char *version) {
-    fprintf(stderr, "gsr info: pipewire: server version: %s\n", version);
-    fprintf(stderr, "gsr info: pipewire: library version: %s\n", pw_get_library_version());
-    fprintf(stderr, "gsr info: pipewire: header version: %s\n", pw_get_headers_version());
-    if(!parse_pw_version(&self->server_version, version))
-        fprintf(stderr, "gsr error: pipewire: failed to parse server version\n");
-}
-
-static void on_core_info_cb(void *user_data, const struct pw_core_info *info) {
-    gsr_pipewire *self = user_data;
-    update_pw_versions(self, info->version);
-}
-
-static void on_core_error_cb(void *user_data, uint32_t id, int seq, int res, const char *message) {
-    gsr_pipewire *self = user_data;
-    fprintf(stderr, "gsr error: pipewire: error id:%u seq:%d res:%d: %s\n", id, seq, res, message);
-    pw_thread_loop_signal(self->thread_loop, false);
-}
-
-static void on_core_done_cb(void *user_data, uint32_t id, int seq) {
-    gsr_pipewire *self = user_data;
-    if (id == PW_ID_CORE && self->server_version_sync == seq)
-        pw_thread_loop_signal(self->thread_loop, false);
-}
-
-static bool is_cursor_format_supported(const enum spa_video_format format) {
-    switch(format) {
-        case SPA_VIDEO_FORMAT_RGBx: return true;
-        case SPA_VIDEO_FORMAT_BGRx: return true;
-        case SPA_VIDEO_FORMAT_xRGB: return true;
-        case SPA_VIDEO_FORMAT_xBGR: return true;
-        case SPA_VIDEO_FORMAT_RGBA: return true;
-        case SPA_VIDEO_FORMAT_BGRA: return true;
-        case SPA_VIDEO_FORMAT_ARGB: return true;
-        case SPA_VIDEO_FORMAT_ABGR: return true;
-        default:                    break;
-    }
-    return false;
-}
-
-static const struct pw_core_events core_events = {
-    PW_VERSION_CORE_EVENTS,
-    .info = on_core_info_cb,
-    .done = on_core_done_cb,
-    .error = on_core_error_cb,
-};
-
-static void on_process_cb(void *user_data) {
-    gsr_pipewire *self = user_data;
-    struct spa_meta_cursor *cursor = NULL;
-    //struct spa_meta *video_damage = NULL;
-
-    /* Find the most recent buffer */
-    struct pw_buffer *pw_buf = NULL;
-    for(;;) {
-        struct pw_buffer *aux = pw_stream_dequeue_buffer(self->stream);
-        if(!aux)
-            break;
-        if(pw_buf)
-            pw_stream_queue_buffer(self->stream, pw_buf);
-        pw_buf = aux;
-    }
-
-    if(!pw_buf) {
-        fprintf(stderr, "gsr info: pipewire: out of buffers!\n");
-        return;
-    }
-
-    struct spa_buffer *buffer = pw_buf->buffer;
-    const bool has_buffer = buffer->datas[0].chunk->size != 0;
-    if(!has_buffer)
-        goto read_metadata;
-
-    pthread_mutex_lock(&self->mutex);
-
-    if(buffer->datas[0].type == SPA_DATA_DmaBuf) {
-        for(size_t i = 0; i < self->dmabuf_num_planes; ++i) {
-            if(self->dmabuf_data[i].fd > 0) {
-                close(self->dmabuf_data[i].fd);
-                self->dmabuf_data[i].fd = -1;
-            }
-        }
-
-        self->dmabuf_num_planes = buffer->n_datas;
-        if(self->dmabuf_num_planes > GSR_PIPEWIRE_DMABUF_MAX_PLANES)
-            self->dmabuf_num_planes = GSR_PIPEWIRE_DMABUF_MAX_PLANES;
-
-        for(size_t i = 0; i < self->dmabuf_num_planes; ++i) {
-            self->dmabuf_data[i].fd = dup(buffer->datas[i].fd);
-            self->dmabuf_data[i].offset = buffer->datas[i].chunk->offset;
-            self->dmabuf_data[i].stride = buffer->datas[i].chunk->stride;
-        }
-
-        self->damaged = true;
-    } else {
-        // TODO:
-    }
-
-    // TODO: Move down to read_metadata
-    struct spa_meta_region *region = spa_buffer_find_meta_data(buffer, SPA_META_VideoCrop, sizeof(*region));
-    if(region && spa_meta_region_is_valid(region)) {
-        // fprintf(stderr, "gsr info: pipewire: crop Region available (%dx%d+%d+%d)\n",
-        //      region->region.position.x, region->region.position.y,
-        //      region->region.size.width, region->region.size.height);
-        self->crop.x = region->region.position.x;
-        self->crop.y = region->region.position.y;
-        self->crop.width = region->region.size.width;
-        self->crop.height = region->region.size.height;
-        self->crop.valid = true;
-    } else {
-        self->crop.valid = false;
-    }
-
-    pthread_mutex_unlock(&self->mutex);
-
-read_metadata:
-
-    // video_damage = spa_buffer_find_meta(buffer, SPA_META_VideoDamage);
-    // if(video_damage) {
-    //     struct spa_meta_region *r = spa_meta_first(video_damage);
-    //     if(spa_meta_check(r, video_damage)) {
-    //         //fprintf(stderr, "damage: %d,%d %ux%u\n", r->region.position.x, r->region.position.y, r->region.size.width, r->region.size.height);
-    //         pthread_mutex_lock(&self->mutex);
-    //         self->damaged = true;
-    //         pthread_mutex_unlock(&self->mutex);
-    //     }
-    // }
-
-    cursor = spa_buffer_find_meta_data(buffer, SPA_META_Cursor, sizeof(*cursor));
-    self->cursor.valid = cursor && spa_meta_cursor_is_valid(cursor);
-    
-    if (self->cursor.visible && self->cursor.valid) {
-        pthread_mutex_lock(&self->mutex);
-
-        struct spa_meta_bitmap *bitmap = NULL;
-        if (cursor->bitmap_offset)
-            bitmap = SPA_MEMBER(cursor, cursor->bitmap_offset, struct spa_meta_bitmap);
-
-        if (bitmap && bitmap->size.width > 0 && bitmap->size.height && is_cursor_format_supported(bitmap->format)) {
-            const uint8_t *bitmap_data = SPA_MEMBER(bitmap, bitmap->offset, uint8_t);
-            fprintf(stderr, "gsr info: pipewire: cursor bitmap update, size: %dx%d, format: %s\n",
-                (int)bitmap->size.width, (int)bitmap->size.height, spa_debug_type_find_name(spa_type_video_format, bitmap->format));
-
-            const size_t bitmap_size = bitmap->size.width * bitmap->size.height * 4;
-            uint8_t *new_bitmap_data = realloc(self->cursor.data, bitmap_size);
-            if(new_bitmap_data) {
-                self->cursor.data = new_bitmap_data;
-                /* TODO: Convert bgr and other image formats to rgb here */
-                memcpy(self->cursor.data, bitmap_data, bitmap_size);
-            }
-        
-            self->cursor.hotspot_x = cursor->hotspot.x;
-            self->cursor.hotspot_y = cursor->hotspot.y;
-            self->cursor.width = bitmap->size.width;
-            self->cursor.height = bitmap->size.height;
-        }
-
-        self->cursor.x = cursor->position.x;
-        self->cursor.y = cursor->position.y;
-        pthread_mutex_unlock(&self->mutex);
-
-        //fprintf(stderr, "gsr info: pipewire: cursor: %d %d %d %d\n", cursor->hotspot.x, cursor->hotspot.y, cursor->position.x, cursor->position.y);
-    }
-
-    pw_stream_queue_buffer(self->stream, pw_buf);
-}
-
-static void on_param_changed_cb(void *user_data, uint32_t id, const struct spa_pod *param) {
-    gsr_pipewire *self = user_data;
-
-    if (!param || id != SPA_PARAM_Format)
-        return;
-
-    int result = spa_format_parse(param, &self->format.media_type, &self->format.media_subtype);
-    if (result < 0)
-        return;
-
-    if (self->format.media_type != SPA_MEDIA_TYPE_video || self->format.media_subtype != SPA_MEDIA_SUBTYPE_raw)
-        return;
-
-    pthread_mutex_lock(&self->mutex);
-    spa_format_video_raw_parse(param, &self->format.info.raw);
-    pthread_mutex_unlock(&self->mutex);
-
-    uint32_t buffer_types = 0;
-    const bool has_modifier = spa_pod_find_prop(param, NULL, SPA_FORMAT_VIDEO_modifier) != NULL;
-    if(has_modifier || check_pw_version(&self->server_version, 0, 3, 24))
-        buffer_types |= 1 << SPA_DATA_DmaBuf;
-
-    fprintf(stderr, "gsr info: pipewire: negotiated format:\n");
-
-    fprintf(stderr, "gsr info: pipewire:    Format: %d (%s)\n",
-         self->format.info.raw.format,
-         spa_debug_type_find_name(spa_type_video_format, self->format.info.raw.format));
-
-    if(has_modifier) {
-        fprintf(stderr, "gsr info: pipewire:    Modifier: 0x%" PRIx64 "\n", self->format.info.raw.modifier);
-    }
-
-    fprintf(stderr, "gsr info: pipewire:    Size: %dx%d\n", self->format.info.raw.size.width, self->format.info.raw.size.height);
-    fprintf(stderr, "gsr info: pipewire:    Framerate: %d/%d\n", self->format.info.raw.framerate.num, self->format.info.raw.framerate.denom);
-
-    uint8_t params_buffer[1024];
-    struct spa_pod_builder pod_builder = SPA_POD_BUILDER_INIT(params_buffer, sizeof(params_buffer));
-    const struct spa_pod *params[4];
-
-    params[0] = spa_pod_builder_add_object(
-        &pod_builder, SPA_TYPE_OBJECT_ParamMeta, SPA_PARAM_Meta,
-        SPA_PARAM_META_type, SPA_POD_Id(SPA_META_VideoCrop),
-        SPA_PARAM_META_size,
-        SPA_POD_Int(sizeof(struct spa_meta_region)));
-
-    params[1] = spa_pod_builder_add_object(
-        &pod_builder, SPA_TYPE_OBJECT_ParamMeta, SPA_PARAM_Meta,
-        SPA_PARAM_META_type, SPA_POD_Id(SPA_META_VideoDamage),
-        SPA_PARAM_META_size, SPA_POD_CHOICE_RANGE_Int(
-                                sizeof(struct spa_meta_region) * 16,
-                                sizeof(struct spa_meta_region) * 1,
-                                sizeof(struct spa_meta_region) * 16));
-
-    params[2] = spa_pod_builder_add_object(
-        &pod_builder, SPA_TYPE_OBJECT_ParamMeta, SPA_PARAM_Meta,
-        SPA_PARAM_META_type, SPA_POD_Id(SPA_META_Cursor),
-        SPA_PARAM_META_size,
-        SPA_POD_CHOICE_RANGE_Int(CURSOR_META_SIZE(64, 64),
-                     CURSOR_META_SIZE(1, 1),
-                     CURSOR_META_SIZE(1024, 1024)));
-
-    params[3] = spa_pod_builder_add_object(
-        &pod_builder, SPA_TYPE_OBJECT_ParamBuffers, SPA_PARAM_Buffers,
-        SPA_PARAM_BUFFERS_dataType, SPA_POD_Int(buffer_types));
-
-    pw_stream_update_params(self->stream, params, 4);
-    self->negotiated = true;
-}
-
-static void on_state_changed_cb(void *user_data, enum pw_stream_state old, enum pw_stream_state state, const char *error) {
-    (void)old;
-    gsr_pipewire *self = user_data;
-
-    fprintf(stderr, "gsr info: pipewire: stream %p state: \"%s\" (error: %s)\n",
-         (void*)self->stream, pw_stream_state_as_string(state),
-         error ? error : "none");
-}
-
-static const struct pw_stream_events stream_events = {
-    PW_VERSION_STREAM_EVENTS,
-    .state_changed = on_state_changed_cb,
-    .param_changed = on_param_changed_cb,
-    .process = on_process_cb,
-};
-
-static inline struct spa_pod *build_format(struct spa_pod_builder *b,
-                       const gsr_pipewire_video_info *ovi,
-                       uint32_t format, const uint64_t *modifiers,
-                       size_t modifier_count)
-{
-    struct spa_pod_frame format_frame;
-
-    spa_pod_builder_push_object(b, &format_frame, SPA_TYPE_OBJECT_Format, SPA_PARAM_EnumFormat);
-    spa_pod_builder_add(b, SPA_FORMAT_mediaType, SPA_POD_Id(SPA_MEDIA_TYPE_video), 0);
-    spa_pod_builder_add(b, SPA_FORMAT_mediaSubtype, SPA_POD_Id(SPA_MEDIA_SUBTYPE_raw), 0);
-
-    spa_pod_builder_add(b, SPA_FORMAT_VIDEO_format, SPA_POD_Id(format), 0);
-
-    if (modifier_count > 0) {
-        struct spa_pod_frame modifier_frame;
-
-        spa_pod_builder_prop(b, SPA_FORMAT_VIDEO_modifier, SPA_POD_PROP_FLAG_MANDATORY | SPA_POD_PROP_FLAG_DONT_FIXATE);
-        spa_pod_builder_push_choice(b, &modifier_frame, SPA_CHOICE_Enum, 0);
-
-        /* The first element of choice pods is the preferred value. Here
-         * we arbitrarily pick the first modifier as the preferred one.
-         */
-        // TODO:
-        spa_pod_builder_long(b, modifiers[0]);
-
-        for(uint32_t i = 0; i < modifier_count; i++)
-            spa_pod_builder_long(b, modifiers[i]);
-
-        spa_pod_builder_pop(b, &modifier_frame);
-    }
-
-    spa_pod_builder_add(b, SPA_FORMAT_VIDEO_size,
-                SPA_POD_CHOICE_RANGE_Rectangle(
-                    &SPA_RECTANGLE(32, 32),
-                    &SPA_RECTANGLE(1, 1),
-                    &SPA_RECTANGLE(16384, 16384)),
-                SPA_FORMAT_VIDEO_framerate,
-                SPA_POD_CHOICE_RANGE_Fraction(
-                    &SPA_FRACTION(ovi->fps_num, ovi->fps_den),
-                    &SPA_FRACTION(0, 1), &SPA_FRACTION(500, 1)),
-                0);
-    return spa_pod_builder_pop(b, &format_frame);
-}
-
-/* https://gstreamer.freedesktop.org/documentation/additional/design/mediatype-video-raw.html?gi-language=c#formats */
-/* For some reason gstreamer formats are in opposite order to drm formats */
-static int64_t spa_video_format_to_drm_format(const enum spa_video_format format) {
-    switch(format) {
-        case SPA_VIDEO_FORMAT_RGBx: return DRM_FORMAT_XBGR8888;
-        case SPA_VIDEO_FORMAT_BGRx: return DRM_FORMAT_XRGB8888;
-        case SPA_VIDEO_FORMAT_RGBA: return DRM_FORMAT_ABGR8888;
-        case SPA_VIDEO_FORMAT_BGRA: return DRM_FORMAT_ARGB8888;
-        case SPA_VIDEO_FORMAT_RGB:  return DRM_FORMAT_XBGR8888;
-        case SPA_VIDEO_FORMAT_BGR:  return DRM_FORMAT_XRGB8888;
-        default:                    break;
-    }
-    return DRM_FORMAT_INVALID;
-}
-
-static const enum spa_video_format video_formats[] = {
-    SPA_VIDEO_FORMAT_BGRA,
-    SPA_VIDEO_FORMAT_BGRx,
-    SPA_VIDEO_FORMAT_BGR,
-    SPA_VIDEO_FORMAT_RGBx,
-    SPA_VIDEO_FORMAT_RGBA,
-    SPA_VIDEO_FORMAT_RGB,
-};
-
-static bool gsr_pipewire_build_format_params(gsr_pipewire *self, struct spa_pod_builder *pod_builder, struct spa_pod **params, uint32_t *num_params) {
-    *num_params = 0;
-
-    if(!check_pw_version(&self->server_version, 0, 3, 33))
-        return false;
-
-    for(size_t i = 0; i < GSR_PIPEWIRE_NUM_VIDEO_FORMATS; i++) {
-        if(self->supported_video_formats[i].modifiers_size == 0)
-            continue;
-        params[i] = build_format(pod_builder, &self->video_info, self->supported_video_formats[i].format, self->modifiers + self->supported_video_formats[i].modifiers_index, self->supported_video_formats[i].modifiers_size);
-        ++(*num_params);
-    }
-
-    return true;
-}
-
-static void renegotiate_format(void *data, uint64_t expirations) {
-    (void)expirations;
-    gsr_pipewire *self = (gsr_pipewire*)data;
-
-    pw_thread_loop_lock(self->thread_loop);
-
-    struct spa_pod *params[GSR_PIPEWIRE_NUM_VIDEO_FORMATS];
-    uint32_t num_video_formats = 0;
-    uint8_t params_buffer[2048];
-    struct spa_pod_builder pod_builder = SPA_POD_BUILDER_INIT(params_buffer, sizeof(params_buffer));
-    if (!gsr_pipewire_build_format_params(self, &pod_builder, params, &num_video_formats)) {
-        pw_thread_loop_unlock(self->thread_loop);
-        return;
-    }
-
-    pw_stream_update_params(self->stream, (const struct spa_pod**)params, num_video_formats);
-    pw_thread_loop_unlock(self->thread_loop);
-}
-
-static bool spa_video_format_get_modifiers(gsr_pipewire *self, const enum spa_video_format format, uint64_t *modifiers, int32_t max_modifiers, int32_t *num_modifiers) {
-    *num_modifiers = 0;
-
-    if(max_modifiers == 0) {
-        fprintf(stderr, "gsr error: spa_video_format_get_modifiers: no space for modifiers left\n");
-        //modifiers[0] = DRM_FORMAT_MOD_LINEAR;
-        //modifiers[1] = DRM_FORMAT_MOD_INVALID;
-        //*num_modifiers = 2;
-        return false;
-    }
-
-    if(!self->egl->eglQueryDmaBufModifiersEXT) {
-        fprintf(stderr, "gsr error: spa_video_format_get_modifiers: failed to initialize modifiers because eglQueryDmaBufModifiersEXT is not available\n");
-        //modifiers[0] = DRM_FORMAT_MOD_LINEAR;
-        //modifiers[1] = DRM_FORMAT_MOD_INVALID;
-        //*num_modifiers = 2;
-        return false;
-    }
-
-    const int64_t drm_format = spa_video_format_to_drm_format(format);
-    if(!self->egl->eglQueryDmaBufModifiersEXT(self->egl->egl_display, drm_format, max_modifiers, modifiers, NULL, num_modifiers)) {
-        fprintf(stderr, "gsr error: spa_video_format_get_modifiers: eglQueryDmaBufModifiersEXT failed with drm format %d, %" PRIi64 "\n", (int)format, drm_format);
-        //modifiers[0] = DRM_FORMAT_MOD_LINEAR;
-        //modifiers[1] = DRM_FORMAT_MOD_INVALID;
-        //*num_modifiers = 2;
-        *num_modifiers = 0;
-        return false;
-    }
-
-    // if(*num_modifiers + 2 <= max_modifiers) {
-    //     modifiers[*num_modifiers + 0] = DRM_FORMAT_MOD_LINEAR;
-    //     modifiers[*num_modifiers + 1] = DRM_FORMAT_MOD_INVALID;
-    //     *num_modifiers += 2;
-    // }
-    return true;
-}
-
-static void gsr_pipewire_init_modifiers(gsr_pipewire *self) {
-    for(size_t i = 0; i < GSR_PIPEWIRE_NUM_VIDEO_FORMATS; i++) {
-        self->supported_video_formats[i].format = video_formats[i];
-        int32_t num_modifiers = 0;
-        spa_video_format_get_modifiers(self, self->supported_video_formats[i].format, self->modifiers + self->num_modifiers, GSR_PIPEWIRE_MAX_MODIFIERS - self->num_modifiers, &num_modifiers);
-        self->supported_video_formats[i].modifiers_index = self->num_modifiers;
-        self->supported_video_formats[i].modifiers_size = num_modifiers;
-    }
-}
-
-static bool gsr_pipewire_setup_stream(gsr_pipewire *self) {
-    struct spa_pod *params[GSR_PIPEWIRE_NUM_VIDEO_FORMATS];
-    uint32_t num_video_formats = 0;
-    uint8_t params_buffer[2048];
-    struct spa_pod_builder pod_builder = SPA_POD_BUILDER_INIT(params_buffer, sizeof(params_buffer));
-
-    self->thread_loop = pw_thread_loop_new("PipeWire thread loop", NULL);
-    if(!self->thread_loop) {
-        fprintf(stderr, "gsr error: gsr_pipewire_setup_stream: failed to create pipewire thread\n");
-        goto error;
-    }
-
-    self->context = pw_context_new(pw_thread_loop_get_loop(self->thread_loop), NULL, 0);
-    if(!self->context) {
-        fprintf(stderr, "gsr error: gsr_pipewire_setup_stream: failed to create pipewire context\n");
-        goto error;
-    }
-
-    if(pw_thread_loop_start(self->thread_loop) < 0) {
-        fprintf(stderr, "gsr error: gsr_pipewire_setup_stream: failed to start thread\n");
-        goto error;
-    }
-
-    pw_thread_loop_lock(self->thread_loop);
-
-    // TODO: Why pass 5 to fcntl?
-    self->core = pw_context_connect_fd(self->context, fcntl(self->fd, F_DUPFD_CLOEXEC, 5), NULL, 0);
-    if(!self->core) {
-        pw_thread_loop_unlock(self->thread_loop);
-        fprintf(stderr, "gsr error: gsr_pipewire_setup_stream: failed to connect to fd %d\n", self->fd);
-        goto error;
-    }
-
-    // TODO: Error check
-    pw_core_add_listener(self->core, &self->core_listener, &core_events, self);
-
-    gsr_pipewire_init_modifiers(self);
-
-    // TODO: Cleanup?
-    self->reneg = pw_loop_add_event(pw_thread_loop_get_loop(self->thread_loop), renegotiate_format, self);
-    if(!self->reneg) {
-        pw_thread_loop_unlock(self->thread_loop);
-        fprintf(stderr, "gsr error: gsr_pipewire_setup_stream: pw_loop_add_event failed\n");
-        goto error;
-    }
-
-    self->server_version_sync = pw_core_sync(self->core, PW_ID_CORE, 0);
-    pw_thread_loop_wait(self->thread_loop);
-
-    self->stream = pw_stream_new(self->core, "com.dec05eba.gpu_screen_recorder",
-        pw_properties_new(PW_KEY_MEDIA_TYPE, "Video",
-                          PW_KEY_MEDIA_CATEGORY, "Capture",
-                          PW_KEY_MEDIA_ROLE, "Screen", NULL));
-    if(!self->stream) {
-        pw_thread_loop_unlock(self->thread_loop);
-        fprintf(stderr, "gsr error: gsr_pipewire_setup_stream: failed to create stream\n");
-        goto error;
-    }
-    pw_stream_add_listener(self->stream, &self->stream_listener, &stream_events, self);
-
-    if(!gsr_pipewire_build_format_params(self, &pod_builder, params, &num_video_formats)) {
-        pw_thread_loop_unlock(self->thread_loop);
-        fprintf(stderr, "gsr error: gsr_pipewire_setup_stream: failed to build format params\n");
-        goto error;
-    }
-
-    if(pw_stream_connect(
-        self->stream, PW_DIRECTION_INPUT, self->node,
-        PW_STREAM_FLAG_AUTOCONNECT | PW_STREAM_FLAG_MAP_BUFFERS, (const struct spa_pod**)params,
-        num_video_formats) < 0)
-    {
-        pw_thread_loop_unlock(self->thread_loop);
-        fprintf(stderr, "gsr error: gsr_pipewire_setup_stream: failed to connect stream\n");
-        goto error;
-    }
-
-    pw_thread_loop_unlock(self->thread_loop);
-    return true;
-
-    error:
-    if(self->thread_loop) {
-        //pw_thread_loop_wait(self->thread_loop);
-        pw_thread_loop_stop(self->thread_loop);
-    }
-
-    if(self->stream) {
-        pw_stream_disconnect(self->stream);
-        pw_stream_destroy(self->stream);
-        self->stream = NULL;
-    }
-
-    if(self->core) {
-        pw_core_disconnect(self->core);
-        self->core = NULL;
-    }
-
-    if(self->context) {
-        pw_context_destroy(self->context);
-        self->context = NULL;
-    }
-
-    if(self->thread_loop) {
-        pw_thread_loop_destroy(self->thread_loop);
-        self->thread_loop = NULL;
-    }
-    return false;
-}
-
-static int pw_init_counter = 0;
-bool gsr_pipewire_init(gsr_pipewire *self, int pipewire_fd, uint32_t pipewire_node, int fps, bool capture_cursor, gsr_egl *egl) {
-    if(pw_init_counter == 0)
-        pw_init(NULL, NULL);
-    ++pw_init_counter;
-
-    memset(self, 0, sizeof(*self));
-    self->egl = egl;
-    self->fd = pipewire_fd;
-    self->node = pipewire_node;
-    if(pthread_mutex_init(&self->mutex, NULL) != 0) {
-        fprintf(stderr, "gsr error: gsr_pipewire_init: failed to initialize mutex\n");
-        gsr_pipewire_deinit(self);
-        return false;
-    }
-    self->mutex_initialized = true;
-    self->video_info.fps_num = fps;
-    self->video_info.fps_den = 1;
-    self->cursor.visible = capture_cursor;
-    
-    if(!gsr_pipewire_setup_stream(self)) {
-        gsr_pipewire_deinit(self);
-        return false;
-    }
-
-    return true;
-}
-
-void gsr_pipewire_deinit(gsr_pipewire *self) {
-    if(self->thread_loop) {
-        //pw_thread_loop_wait(self->thread_loop);
-        pw_thread_loop_stop(self->thread_loop);
-    }
-
-    if(self->stream) {
-        pw_stream_disconnect(self->stream);
-        pw_stream_destroy(self->stream);
-        self->stream = NULL;
-    }
-
-    if(self->core) {
-        pw_core_disconnect(self->core);
-        self->core = NULL;
-    }
-
-    if(self->context) {
-        pw_context_destroy(self->context);
-        self->context = NULL;
-    }
-
-    if(self->thread_loop) {
-        pw_thread_loop_destroy(self->thread_loop);
-        self->thread_loop = NULL;
-    }
-
-    if(self->fd > 0) {
-        close(self->fd);
-        self->fd = -1;
-    }
-
-    for(size_t i = 0; i < self->dmabuf_num_planes; ++i) {
-        if(self->dmabuf_data[i].fd > 0) {
-            close(self->dmabuf_data[i].fd);
-            self->dmabuf_data[i].fd = -1;
-        }
-    }
-    self->dmabuf_num_planes = 0;
-
-    self->negotiated = false;
-
-    if(self->mutex_initialized) {
-        pthread_mutex_destroy(&self->mutex);
-        self->mutex_initialized = false;
-    }
-
-    if(self->cursor.data) {
-        free(self->cursor.data);
-        self->cursor.data = NULL;
-    }
-
-    --pw_init_counter;
-    if(pw_init_counter == 0) {
-#if PW_CHECK_VERSION(0, 3, 49)
-        pw_deinit();
-#endif
-    }
-}
-
-static EGLImage gsr_pipewire_create_egl_image(gsr_pipewire *self, const int *fds, const uint32_t *offsets, const uint32_t *pitches, const uint64_t *modifiers, bool use_modifiers) {
-    intptr_t img_attr[44];
-    setup_dma_buf_attrs(img_attr, spa_video_format_to_drm_format(self->format.info.raw.format), self->format.info.raw.size.width, self->format.info.raw.size.height,
-        fds, offsets, pitches, modifiers, self->dmabuf_num_planes, use_modifiers);
-    while(self->egl->eglGetError() != EGL_SUCCESS){}
-    EGLImage image = self->egl->eglCreateImage(self->egl->egl_display, 0, EGL_LINUX_DMA_BUF_EXT, NULL, img_attr);
-    if(!image || self->egl->eglGetError() != EGL_SUCCESS) {
-        if(image)
-            self->egl->eglDestroyImage(self->egl->egl_display, image);
-        return NULL;
-    }
-    return image;
-}
-
-static EGLImage gsr_pipewire_create_egl_image_with_fallback(gsr_pipewire *self) {
-    int fds[GSR_PIPEWIRE_DMABUF_MAX_PLANES];
-    uint32_t offsets[GSR_PIPEWIRE_DMABUF_MAX_PLANES];
-    uint32_t pitches[GSR_PIPEWIRE_DMABUF_MAX_PLANES];
-    uint64_t modifiers[GSR_PIPEWIRE_DMABUF_MAX_PLANES];
-    for(size_t i = 0; i < self->dmabuf_num_planes; ++i) {
-        fds[i] = self->dmabuf_data[i].fd;
-        offsets[i] = self->dmabuf_data[i].offset;
-        pitches[i] = self->dmabuf_data[i].stride;
-        modifiers[i] = self->format.info.raw.modifier;
-    }
-
-    EGLImage image = NULL;
-    if(self->no_modifiers_fallback) {
-        image = gsr_pipewire_create_egl_image(self, fds, offsets, pitches, modifiers, false);
-    } else {
-        image = gsr_pipewire_create_egl_image(self, fds, offsets, pitches, modifiers, true);
-        if(!image) {
-            fprintf(stderr, "gsr error: gsr_pipewire_create_egl_image_with_fallback: failed to create egl image with modifiers, trying without modifiers\n");
-            self->no_modifiers_fallback = true;
-            image = gsr_pipewire_create_egl_image(self, fds, offsets, pitches, modifiers, false);
-        }
-    }
-    return image;
-}
-
-static bool gsr_pipewire_bind_image_to_texture(gsr_pipewire *self, EGLImage image, unsigned int texture_id, bool external_texture) {
-    const int texture_target = external_texture ? GL_TEXTURE_EXTERNAL_OES : GL_TEXTURE_2D;
-    while(self->egl->glGetError() != 0){}
-    self->egl->glBindTexture(texture_target, texture_id);
-    self->egl->glEGLImageTargetTexture2DOES(texture_target, image);
-    const bool success = self->egl->glGetError() == 0;
-    self->egl->glBindTexture(texture_target, 0);
-    return success;
-}
-
-static void gsr_pipewire_bind_image_to_texture_with_fallback(gsr_pipewire *self, gsr_texture_map texture_map, EGLImage image) {
-    if(self->external_texture_fallback) {
-        gsr_pipewire_bind_image_to_texture(self, image, texture_map.external_texture_id, true);
-    } else {
-        if(!gsr_pipewire_bind_image_to_texture(self, image, texture_map.texture_id, false)) {
-            fprintf(stderr, "gsr error: gsr_pipewire_map_texture: failed to bind image to texture, trying with external texture\n");
-            self->external_texture_fallback = true;
-            gsr_pipewire_bind_image_to_texture(self, image, texture_map.external_texture_id, true);
-        }
-    }
-}
-
-static void gsr_pipewire_update_cursor_texture(gsr_pipewire *self, gsr_texture_map texture_map) {
-    if(!self->cursor.data)
-        return;
-
-    self->egl->glBindTexture(GL_TEXTURE_2D, texture_map.cursor_texture_id);
-    // TODO: glTextureSubImage2D if same size
-    self->egl->glTexImage2D(GL_TEXTURE_2D, 0, GL_RGBA8, self->cursor.width, self->cursor.height, 0, GL_RGBA, GL_UNSIGNED_BYTE, self->cursor.data);
-    self->egl->glTexParameteri(GL_TEXTURE_2D, GL_TEXTURE_WRAP_S, GL_CLAMP_TO_EDGE);
-    self->egl->glTexParameteri(GL_TEXTURE_2D, GL_TEXTURE_WRAP_T, GL_CLAMP_TO_EDGE);
-    self->egl->glTexParameteri(GL_TEXTURE_2D, GL_TEXTURE_MAG_FILTER, GL_LINEAR);
-    self->egl->glTexParameteri(GL_TEXTURE_2D, GL_TEXTURE_MIN_FILTER, GL_LINEAR);
-    self->egl->glBindTexture(GL_TEXTURE_2D, 0);
-
-    free(self->cursor.data);
-    self->cursor.data = NULL;
-}
-
-bool gsr_pipewire_map_texture(gsr_pipewire *self, gsr_texture_map texture_map, gsr_pipewire_region *region, gsr_pipewire_region *cursor_region, gsr_pipewire_dmabuf_data *dmabuf_data, int *num_dmabuf_data, uint32_t *fourcc, uint64_t *modifiers, bool *using_external_image) {
-    for(int i = 0; i < GSR_PIPEWIRE_DMABUF_MAX_PLANES; ++i) {
-        memset(&dmabuf_data[i], 0, sizeof(gsr_pipewire_dmabuf_data));
-    }
-    *num_dmabuf_data = 0;
-    *using_external_image = self->external_texture_fallback;
-    *fourcc = 0;
-    *modifiers = 0;
-    pthread_mutex_lock(&self->mutex);
-
-    if(!self->negotiated || self->dmabuf_data[0].fd <= 0) {
-        pthread_mutex_unlock(&self->mutex);
-        return false;
-    }
-
-    EGLImage image = gsr_pipewire_create_egl_image_with_fallback(self);
-    if(image) {
-        gsr_pipewire_bind_image_to_texture_with_fallback(self, texture_map, image);
-        *using_external_image = self->external_texture_fallback;
-        self->egl->eglDestroyImage(self->egl->egl_display, image);
-    }
-
-    gsr_pipewire_update_cursor_texture(self, texture_map);
-
-    region->x = 0;
-    region->y = 0;
-
-    region->width = self->format.info.raw.size.width;
-    region->height = self->format.info.raw.size.height;
-
-    if(self->crop.valid) {
-        region->x = self->crop.x;
-        region->y = self->crop.y;
-
-        region->width = self->crop.width;
-        region->height = self->crop.height;
-    }
-
-    /* TODO: Test if cursor hotspot is correct */
-    cursor_region->x = self->cursor.x - self->cursor.hotspot_x;
-    cursor_region->y = self->cursor.y - self->cursor.hotspot_y;
-
-    cursor_region->width = self->cursor.width;
-    cursor_region->height = self->cursor.height;
-
-    for(size_t i = 0; i < self->dmabuf_num_planes; ++i) {
-        dmabuf_data[i] = self->dmabuf_data[i];
-        self->dmabuf_data[i].fd = -1;
-    }
-    *num_dmabuf_data = self->dmabuf_num_planes;
-    *fourcc = spa_video_format_to_drm_format(self->format.info.raw.format);
-    *modifiers = self->format.info.raw.modifier;
-    self->dmabuf_num_planes = 0;
-
-    pthread_mutex_unlock(&self->mutex);
-    return true;
-}
-
-bool gsr_pipewire_is_damaged(gsr_pipewire *self) {
-    bool damaged = false;
-    pthread_mutex_lock(&self->mutex);
-    damaged = self->damaged;
-    pthread_mutex_unlock(&self->mutex);
-    return damaged;
-}
-
-void gsr_pipewire_clear_damage(gsr_pipewire *self) {
-    pthread_mutex_lock(&self->mutex);
-    self->damaged = false;
-    pthread_mutex_unlock(&self->mutex);
-}