fifo-v1: implement protocol

Signed-off-by: Sergio Gómez <[email protected]>

Author: sergio-gdr

include/sway/fifo.h

@@ -0,0 +1,19 @@
+#ifndef _SWAY_FIFO_H
+#define _SWAY_FIFO_H
+
+#include "util.h"
+
+struct sway_fifo {
+	struct wlr_fifo_v1 *wlr_fifo;
+
+	struct wlr_output *output;
+
+	struct wl_listener fifo_barrier;
+	struct wl_listener output_commit;
+};
+
+void handle_fifo_barrier(struct wl_listener *listener, void *data);
+
+void handle_fifo_manager_create_fifo(struct wl_listener *listener, void *data);
+
+#endif

include/sway/server.h

@@ -89,6 +89,9 @@ struct sway_server {
 	struct wlr_gamma_control_manager_v1 *gamma_control_manager_v1;
 	struct wl_listener gamma_control_set_gamma;
 
+	struct wlr_fifo_v1_manager *fifo_manager;
+	struct wl_listener fifo_create;
+
 	struct {
 		struct sway_session_lock *lock;
 		struct wlr_session_lock_manager_v1 *manager;

sway/fifo.c

@@ -0,0 +1,45 @@
+#include <wlr/types/wlr_fifo_v1.h>
+#include "sway/fifo.h"
+#include "sway/tree/view.h"
+
+void handle_output_commit(struct wl_listener *listener, void *data) {
+	struct sway_fifo *fifo =
+		wl_container_of(listener, fifo, output_commit);
+
+	wlr_fifo_signal_barrier(fifo->wlr_fifo);
+	wl_list_remove(&fifo->output_commit.link);
+}
+
+static void find_scene_buffer(struct wlr_scene_buffer *buffer, int sx, int sy, void *user_data) {
+	struct wlr_scene_surface *scene_surface =
+		wlr_scene_surface_try_from_buffer(buffer);
+	struct sway_fifo *sway_fifo = user_data;
+
+	if (scene_surface && scene_surface->surface == sway_fifo->wlr_fifo->surface &&
+			buffer->primary_output) {
+		sway_fifo->output = buffer->primary_output->output;
+	}
+}
+
+void handle_fifo_barrier(struct wl_listener *listener, void *data) {
+	struct sway_fifo *sway_fifo =
+		wl_container_of(listener, sway_fifo, fifo_barrier);
+	struct sway_view *view =
+		view_from_wlr_surface(sway_fifo->wlr_fifo->surface);
+
+	wlr_scene_node_for_each_buffer(&view->content_tree->node, find_scene_buffer, sway_fifo);
+	if (sway_fifo->output) {
+		sway_fifo->output_commit.notify = handle_output_commit;
+		wl_signal_add(&sway_fifo->output->events.commit, &sway_fifo->output_commit);
+	}
+}
+
+void handle_fifo_manager_create_fifo(struct wl_listener *listener, void *data) {
+	struct wlr_fifo_v1 *wlr_fifo = data;
+
+	struct sway_fifo *sway_fifo = calloc(1, sizeof(*sway_fifo));
+	sway_fifo->wlr_fifo = wlr_fifo;
+
+	sway_fifo->fifo_barrier.notify = handle_fifo_barrier;
+	wl_signal_add(&wlr_fifo->events.fifo_barrier, &sway_fifo->fifo_barrier);
+}

sway/meson.build

@@ -3,6 +3,7 @@ sway_sources = files(
 	'config.c',
 	'criteria.c',
 	'decoration.c',
+	'fifo.c',
 	'ipc-json.c',
 	'ipc-server.c',
 	'lock.c',

sway/server.c

@@ -18,6 +18,7 @@
 #include <wlr/types/wlr_drm.h>
 #include <wlr/types/wlr_export_dmabuf_v1.h>
 #include <wlr/types/wlr_ext_foreign_toplevel_list_v1.h>
+#include <wlr/types/wlr_fifo_v1.h>
 #include <wlr/types/wlr_foreign_toplevel_management_v1.h>
 #include <wlr/types/wlr_fractional_scale_v1.h>
 #include <wlr/types/wlr_gamma_control_v1.h>
@@ -57,6 +58,7 @@
 #include "sway/server.h"
 #include "sway/input/cursor.h"
 #include "sway/tree/root.h"
+#include "sway/fifo.h"
 
 #if WLR_HAS_XWAYLAND
 #include <wlr/xwayland/shell.h>
@@ -405,6 +407,10 @@ bool server_init(struct sway_server *server) {
 
 	wl_list_init(&server->pending_launcher_ctxs);
 
+	server->fifo_manager = wlr_fifo_manager_create(server->wl_display, 1);
+	server->fifo_create.notify = handle_fifo_manager_create_fifo;
+	wl_signal_add(&server->fifo_manager->events.fifo_create, &server->fifo_create);
+
 	// Avoid using "wayland-0" as display socket
 	char name_candidate[16];
 	for (unsigned int i = 1; i <= 32; ++i) {