开启 xcb 事件循环

src/include/xcb.h

@@ -5,6 +5,7 @@
 #include <xcb/xproto.h>
 
 bool has_other_wm_running(void);
+int get_xcb_connection_fd(void);
 
 typedef struct monitor_rect_t monitor_rect_t;
 struct monitor_rect_t {

src/main.c

@@ -20,6 +20,9 @@ static gboolean update_wallpaper(gpointer user_data);
 static void set_wallpaper_by_index(uint32_t index);
 static wallpaper_config_t *parse_wallpaper_config(const char **wallpapers);
 static void free_wallpaper_config(wallpaper_config_t *wallpaper_config);
+static void init_xcb_event_loop(void);
+static gboolean handle_xcb_event(GIOChannel *channel, GIOCondition condition,
+                                 gpointer userdata);
 static void cleanup(void);
 
 static monitor_t *monitors = NULL;
@@ -163,6 +166,25 @@ void free_wallpaper_config(wallpaper_config_t *wallpaper_config) {
   free(wallpaper_config);
 }
 
+void init_xcb_event_loop(void) {
+  GIOChannel *channel = g_io_channel_unix_new(get_xcb_connection_fd());
+  g_io_channel_set_encoding(channel, NULL, NULL);
+  GIOCondition cond = G_IO_IN | G_IO_HUP | G_IO_ERR;
+  g_io_add_watch(channel, cond, handle_xcb_event, NULL);
+  g_io_channel_unref(channel);
+}
+
+gboolean handle_xcb_event(GIOChannel *channel, GIOCondition condition,
+                          gpointer userdata) {
+  if ((condition & G_IO_HUP) || (condition & G_IO_ERR)) {
+    g_main_loop_quit(loop);
+    return false;
+  }
+
+  start_xcb_event_loop();
+  return true;
+}
+
 void cleanup(void) {
   clean_xcb();
 
@@ -200,6 +222,8 @@ int main(int argc, char *argv[]) {
 
   free_window_list(window_list);
 
+  init_xcb_event_loop();
+
   loop = g_main_loop_new(NULL, FALSE);
   g_main_loop_run(loop);
 

src/xcb/xcb.c

@@ -2,10 +2,12 @@
 
 #include <stdbool.h>
 #include <stdint.h>
+#include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
 #include <xcb/xcb.h>
 #include <xcb/xcb_aux.h>
+#include <xcb/xcb_event.h>
 #include <xcb/xcb_ewmh.h>
 #include <xcb/xcb_icccm.h>
 #include <xcb/xcb_image.h>
@@ -47,6 +49,11 @@ bool has_other_wm_running(void) {
   return false;
 }
 
+/**
+ * @brief 获取 xcb 链接对应的文件描述符
+ */
+int get_xcb_connection_fd(void) { return xcb_get_file_descriptor(conn); }
+
 /* xinerama 扩展是否激活 */
 static bool xinerama_active(void) {
   const char *name = "XINERAMA";
@@ -263,6 +270,16 @@ void free_window_list(window_list_t *window_list) {
   free(window_list);
 }
 
+void start_xcb_event_loop(void) {
+  xcb_generic_event_t *event = NULL;
+  while ((event = xcb_poll_for_event(conn)) != NULL) {
+    uint8_t event_type = XCB_EVENT_RESPONSE_TYPE(event);
+    const char *label = xcb_event_get_label(event_type);
+    printf("================== %s ==================\n", label);
+    free(event);
+  }
+}
+
 void clean_xcb(void) {
   if (wm_check_window != XCB_NONE) {
     xcb_destroy_window(conn, wm_check_window);