fix

.clangd

@@ -1,2 +1,2 @@
 CompileFlags:
-  Add: ['-I/usr/include/gstreamer-1.0', '-I/usr/lib/glib-2.0/include', '-I/usr/include/glib-2.0']
+  Add: ['-I/usr/include/gstreamer-1.0', '-I/usr/lib/glib-2.0/include', '-I/usr/include/glib-2.0', '-I/media/user/luks/Work/Piklema/imx-weston']

clients/gstwestonimagesrc.c

@@ -1,7 +1,18 @@
-#include "gstwestonimagesrc.h"
+#include <errno.h>
-#include "gst/gstinfo.h"
+#include <fcntl.h>
+#include <limits.h>
+#include <stdint.h>
+#include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
+#include <sys/mman.h>
+#include <sys/param.h>
+#include <unistd.h>
 
+#include "gst/gstinfo.h"
+#include "gstwestonimagesrc.h"
+
+// Gtreamer plugin related defines and declarations
 GST_DEBUG_CATEGORY_STATIC(gst_westonimagesrc_debug);
 #define GST_CAT_DEFAULT gst_westonimagesrc_debug
 
@@ -22,6 +33,125 @@ static void gst_westonimagesrc_get_property(GObject *object, guint prop_id, GVal
 
 G_DEFINE_TYPE(GstWestonImageSrc, gst_westonimagesrc, GST_TYPE_BASE_SRC);
 
+static void weston_display_handle_mode(void *data, struct wl_output *wl_output, uint32_t flags, int width, int height, int refresh);
+static void weston_display_handle_geometry(void *data, struct wl_output *wl_output, int x, int y, int physical_width, int physical_height, int subpixel, const char *make,
+                                           const char *model, int transform);
+static void weston_screenshot_done(void *data, struct weston_screenshooter *screenshooter);
+static void weston_handle_global(void *data, struct wl_registry *registry, uint32_t name, const char *interface, uint32_t version);
+static void weston_handle_global_remove(void *data, struct wl_registry *registry, uint32_t name);
+
+static void weston_handle_global_remove(void *data, struct wl_registry *registry, uint32_t name) { /* XXX: unimplemented */ }
+static struct wl_buffer *weston_screenshot_create_shm_buffer(int width, int height, void **data_out, struct wl_shm *shm);
+static int weston_screenshot_set_buffer_size(struct buffer_size *buff_size, struct wl_list *output_list);
+
+static const struct wl_output_listener output_listener = {weston_display_handle_geometry, weston_display_handle_mode};
+static const struct weston_screenshooter_listener screenshooter_listener = {weston_screenshot_done};
+static const struct wl_registry_listener registry_listener = {weston_handle_global, weston_handle_global_remove};
+
+static int weston_screenshot_set_buffer_size(struct buffer_size *buff_size, struct wl_list *output_list) {
+  struct screenshooter_output *output;
+  buff_size->min_x = buff_size->min_y = INT_MAX;
+  buff_size->max_x = buff_size->max_y = INT_MIN;
+  int position = 0;
+
+  wl_list_for_each_reverse(output, output_list, link) {
+    output->offset_x = position;
+    position += output->width;
+  }
+
+  wl_list_for_each(output, output_list, link) {
+    buff_size->min_x = MIN(buff_size->min_x, output->offset_x);
+    buff_size->min_y = MIN(buff_size->min_y, output->offset_y);
+    buff_size->max_x = MAX(buff_size->max_x, output->offset_x + output->width);
+    buff_size->max_y = MAX(buff_size->max_y, output->offset_y + output->height);
+  }
+
+  if (buff_size->max_x <= buff_size->min_x || buff_size->max_y <= buff_size->min_y)
+    return -1;
+
+  buff_size->width = buff_size->max_x - buff_size->min_x;
+  buff_size->height = buff_size->max_y - buff_size->min_y;
+
+  return 0;
+}
+
+static struct wl_buffer *weston_screenshot_create_shm_buffer(int width, int height, void **data_out, struct wl_shm *shm) {
+  struct wl_shm_pool *pool;
+  struct wl_buffer *buffer;
+  int fd, size, stride;
+  void *data;
+
+  stride = width * 4;
+  size = stride * height;
+
+  fd = os_create_anonymous_file(size);
+  if (fd < 0) {
+    fprintf(stderr, "creating a buffer file for %d B failed: %s\n", size, strerror(errno));
+    return NULL;
+  }
+
+  data = mmap(NULL, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
+  if (data == MAP_FAILED) {
+    fprintf(stderr, "mmap failed: %s\n", strerror(errno));
+    close(fd);
+    return NULL;
+  }
+
+  pool = wl_shm_create_pool(shm, fd, size);
+  close(fd);
+  buffer = wl_shm_pool_create_buffer(pool, 0, width, height, stride, WL_SHM_FORMAT_XRGB8888);
+  wl_shm_pool_destroy(pool);
+
+  *data_out = data;
+
+  return buffer;
+}
+
+static void weston_handle_global(void *data, struct wl_registry *registry, uint32_t name, const char *interface, uint32_t version) {
+  static struct screenshooter_output *output;
+  struct screenshooter_data *sh_data = data;
+
+  if (strcmp(interface, "wl_output") == 0) {
+
+    output = xmalloc(sizeof *output);
+    output->output = wl_registry_bind(registry, name, &wl_output_interface, 1);
+    wl_list_insert(&sh_data->output_list, &output->link);
+    wl_output_add_listener(output->output, &output_listener, output);
+  } else if (strcmp(interface, "wl_shm") == 0) {
+
+    sh_data->shm = wl_registry_bind(registry, name, &wl_shm_interface, 1);
+  } else if (strcmp(interface, "weston_screenshooter") == 0) {
+
+    sh_data->screenshooter = wl_registry_bind(registry, name, &weston_screenshooter_interface, 1);
+  }
+}
+
+static void weston_screenshot_done(void *data, struct weston_screenshooter *screenshooter) {
+  struct screenshooter_data *sh_data = data;
+  sh_data->buffer_copy_done = 1;
+}
+
+static void weston_display_handle_geometry(void *data, struct wl_output *wl_output, int x, int y, int physical_width, int physical_height, int subpixel, const char *make,
+                                           const char *model, int transform) {
+  struct screenshooter_output *output;
+  output = wl_output_get_user_data(wl_output);
+
+  if (wl_output == output->output) {
+    output->offset_x = x;
+    output->offset_y = y;
+  }
+}
+
+static void weston_display_handle_mode(void *data, struct wl_output *wl_output, uint32_t flags, int width, int height, int refresh) {
+  struct screenshooter_output *output;
+  output = wl_output_get_user_data(wl_output);
+
+  if (wl_output == output->output && (flags & WL_OUTPUT_MODE_CURRENT)) {
+    output->width = width;
+    output->height = height;
+  }
+}
+
 static void gst_westonimagesrc_class_init(GstWestonImageSrcClass *klass) {
   GObjectClass *gobject_class = G_OBJECT_CLASS(klass);
   GstElementClass *gstelement_class = GST_ELEMENT_CLASS(klass);
@@ -58,6 +188,25 @@ static void gst_westonimagesrc_init(GstWestonImageSrc *westonimagesrc) {
 
   g_mutex_init(&westonimagesrc->lock);
   g_cond_init(&westonimagesrc->cond);
+
+  // Get current display
+  display = wl_display_connect(NULL);
+  if (display == NULL) {
+    fprintf(stderr, "failed to create display: %s\n", strerror(errno));
+  }
+
+  wl_list_init(&sh_data.output_list);
+  registry = wl_display_get_registry(display);
+  wl_registry_add_listener(registry, &registry_listener, &sh_data);
+  wl_display_dispatch(display);
+  wl_display_roundtrip(display);
+
+  if (sh_data.screenshooter == NULL) {
+    fprintf(stderr, "display doesn't support screenshooter\n");
+  }
+
+  weston_screenshooter_add_listener(sh_data.screenshooter, &screenshooter_listener, &sh_data);
+  weston_screenshot_set_buffer_size(&buff_size, &sh_data.output_list);
 }
 
 static void gst_westonimagesrc_set_property(GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec) {
@@ -125,6 +274,7 @@ static gboolean gst_westonimagesrc_stop(GstBaseSrc *basesrc) {
 }
 
 static GstFlowReturn gst_westonimagesrc_create(GstBaseSrc *basesrc, guint64 offset, guint size, GstBuffer **buf) {
+  // Gstreamer related
   GstWestonImageSrc *westonimagesrc = GST_WESTONIMAGESRC(basesrc);
   GstMapInfo map;
   gchar *message;
@@ -149,6 +299,14 @@ static GstFlowReturn gst_westonimagesrc_create(GstBaseSrc *basesrc, guint64 offs
       return GST_FLOW_FLUSHING;
     }
 
+    wl_list_for_each(output, &sh_data.output_list, link) {
+      output->buffer = weston_screenshot_create_shm_buffer(output->width, output->height, &output->data, sh_data.shm);
+      weston_screenshooter_shoot(sh_data.screenshooter, output->output, output->buffer);
+      sh_data.buffer_copy_done = 0;
+      while (!sh_data.buffer_copy_done)
+        wl_display_roundtrip(display);
+    }
+
     message = g_strdup_printf("westonimagesrc world #%lu\n", (gulong)westonimagesrc->offset);
     message_len = strlen(message);
 

clients/gstwestonimagesrc.h

@@ -4,6 +4,26 @@
 #include <gst/base/gstbasesrc.h>
 #include <gst/gst.h>
 
+
+#include <stdint.h>
+#include <errno.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <limits.h>
+#include <sys/param.h>
+#include <sys/mman.h>
+#include <wayland-client.h>
+#include <wayland-util.h>
+
+#include "config.h"
+#include "weston-screenshooter-client-protocol.h"
+#include "shared/os-compatibility.h"
+#include "shared/xalloc.h"
+#include "shared/file-util.h"
+
 G_BEGIN_DECLS
 
 #define GST_TYPE_WESTONIMAGESRC (gst_westonimagesrc_get_type())
@@ -33,4 +53,33 @@ GType gst_westonimagesrc_get_type(void);
 
 G_END_DECLS
 
+// Screenshoter logic related declarations and defines
+struct screenshooter_output {
+  struct wl_output *output;
+  struct wl_buffer *buffer;
+  int width, height, offset_x, offset_y;
+  void *data;
+  struct wl_list link;
+};
+
+struct buffer_size {
+  int width, height;
+  int min_x, min_y;
+  int max_x, max_y;
+};
+
+struct screenshooter_data {
+  struct wl_shm *shm;
+  struct wl_list output_list;
+  struct weston_screenshooter *screenshooter;
+  int buffer_copy_done;
+};
+
+// Weston related structures
+struct wl_display *display;
+struct wl_registry *registry;
+struct screenshooter_output *output;
+struct buffer_size buff_size = {};
+struct screenshooter_data sh_data = {};
+
 #endif /* __GST_WESTONIMAGESRC_H__ */

clients/meson.build

@@ -353,6 +353,44 @@ if get_option('shell-desktop')
 	  install: true
 	)
 	env_modmap += 'weston-desktop-shell=@0@;'.format(exe_shell_desktop.full_path())
+
+    plugins_install_dir = join_paths(get_option('libdir'), 'gstreamer-1.0')
+    cc = meson.get_compiler('c')
+    gst_version = meson.project_version()
+    api_version = '0.1'
+
+    gst_dep = dependency('gstreamer-1.0', version : '>=1.18',
+                         fallback : ['gstreamer', 'gst_dep'])
+
+    gstbase_dep = dependency('gstreamer-base-1.0', version : '>=1.18',
+                             fallback : ['gstreamer', 'gst_base_dep'])
+    
+    gst_westonimagesrc_plugin_c_args = ['-DHAVE_CONFIG_H']
+
+    gst_westonimagesrc_cdata = configuration_data()
+    gst_westonimagesrc_cdata.set_quoted('PACKAGE_VERSION', gst_version)
+    gst_westonimagesrc_cdata.set_quoted('PACKAGE', 'gst-template-plugin')
+    gst_westonimagesrc_cdata.set_quoted('GST_LICENSE', 'LGPL')
+    gst_westonimagesrc_cdata.set_quoted('GST_API_VERSION', api_version)
+    gst_westonimagesrc_cdata.set_quoted('GST_PACKAGE_NAME', 'GStreamer template Plug-ins')
+    gst_westonimagesrc_cdata.set_quoted('GST_PACKAGE_ORIGIN', 'https://gstreamer.freedesktop.org')
+    configure_file(output : 'config.h', configuration : gst_westonimagesrc_cdata)
+
+    # The westonimagesrc Plugin
+    gstwestonimagesrc_sources = [
+      'gstwestonimagesrc.c',
+    ]
+
+    gstwestonimagesrcexample = library('gstwestonimagesrc',
+                                       gstwestonimagesrc_sources,
+		                               weston_screenshooter_client_protocol_h,
+		                               weston_screenshooter_protocol_c,
+		                               include_directories: common_inc,
+                                       c_args: gst_westonimagesrc_plugin_c_args,
+                                       dependencies : [gst_dep, gstbase_dep, dep_toytoolkit],
+                                       install : true,
+                                       install_dir : plugins_install_dir,
+                                      )
 endif
 
 

clients/screenshot.c

@@ -36,6 +36,7 @@
 #include <cairo.h>
 
 #include <wayland-client.h>
+#include <wayland-util.h>
 #include "weston-screenshooter-client-protocol.h"
 #include "shared/os-compatibility.h"
 #include "shared/xalloc.h"