fix(dxinput): use global mutex to prevent X11 thread race condition

Previously, list.c, type.c, property.c, button_map.c, and keyboard.c
each had their own local mutex, which failed to protect concurrent X11
access across different files. This caused heap corruption when multiple
threads simultaneously called XOpenDisplay/XCloseDisplay, resulting in
"malloc(): unaligned tcache chunk detected" errors.

Log:
- Add x11_mutex.h/c with global x11_global_mutex
- Replace all local mutexes with x11_global_mutex
- Add _unlocked internal versions of query_device_type and
  is_property_exist to avoid deadlock when called from within
  locked contexts
- Ensure all top-level functions (called from Go) acquire the lock
- Internal helper functions assume caller holds the lock

Influence: This ensures thread-safe X11 access while avoiding deadlock through
proper lock hierarchy.

---

修复(dxinput): 使用全局互斥锁防止 X11 线程竞争

之前 list.c、type.c、property.c、button_map.c 和 keyboard.c 各自
使用独立的局部互斥锁，无法保护跨文件的并发 X11 访问。这导致多个线程
同时调用 XOpenDisplay/XCloseDisplay 时发生堆损坏，触发 "malloc():
unaligned tcache chunk detected" 错误。

Log：
- 新增 x11_mutex.h/c，定义全局 x11_global_mutex
- 将所有局部互斥锁替换为 x11_global_mutex
- 新增 query_device_type 和 is_property_exist 的 _unlocked 内部版本，
  避免在已持锁的上下文中调用时发生死锁
- 确保所有顶层函数（被 Go 调用）获取锁
- 内部辅助函数假设调用者已持有锁

Influence: 通过正确的锁层次结构，确保线程安全的 X11 访问，同时避免死锁。

Author: fly602

dxinput/utils/button_map.c

@@ -12,6 +12,7 @@
 
 #include "button_map.h"
 #include "type.h"
+#include "x11_mutex.h"
 
 static int get_button_number(Display* disp, const char* name);
 static const XDeviceInfo* find_device_by_name(const XDeviceInfo* devs,
@@ -20,8 +21,6 @@ static int get_device_button_number(const XDeviceInfo* dev);
 static unsigned char* do_get_button_map(Display* disp,
                                         unsigned long xid, int nbuttons);
 
-static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
-
 unsigned char*
 get_button_map(unsigned long xid, const char* name, int* nbuttons)
 {
@@ -37,14 +36,14 @@ get_button_map(unsigned long xid, const char* name, int* nbuttons)
         return NULL;
     }
 
-    pthread_mutex_lock(&mutex);
+    pthread_mutex_lock(&x11_global_mutex);
     setErrorHandler();
 
     Display* disp = XOpenDisplay(NULL);
     if (!disp) {
         fprintf(stderr, "[get_button_map] open display failed for %lu %s\n",
                 xid, name);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return NULL;
     }
 
@@ -53,15 +52,15 @@ get_button_map(unsigned long xid, const char* name, int* nbuttons)
         XCloseDisplay(disp);
         fprintf(stderr, "[get_button_map] get button number failed for %lu %s\n",
                 xid, name);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return NULL;
     }
 
     *nbuttons = num_btn;
     unsigned char* map = do_get_button_map(disp, xid, num_btn);
     XCloseDisplay(disp);
 
-    pthread_mutex_unlock(&mutex);
+    pthread_mutex_unlock(&x11_global_mutex);
 
     return map;
 }
@@ -75,14 +74,14 @@ set_button_map(unsigned long xid, const char* name,
         return -1;
     }
 
-    pthread_mutex_lock(&mutex);
+    pthread_mutex_lock(&x11_global_mutex);
     setErrorHandler();
 
     Display* disp = XOpenDisplay(0);
     if (!disp) {
         fprintf(stderr, "[set_button_map] open display failed: %lu %s\n",
                 xid, name);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return -1;
     }
 
@@ -91,7 +90,7 @@ set_button_map(unsigned long xid, const char* name,
         XCloseDisplay(disp);
         fprintf(stderr, "[set_button_map] open device failed for %lu %s\n",
                 xid, name);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return -1;
     }
 
@@ -101,7 +100,7 @@ set_button_map(unsigned long xid, const char* name,
     XCloseDevice(disp, dev);
     XCloseDisplay(disp);
 
-    pthread_mutex_unlock(&mutex);
+    pthread_mutex_unlock(&x11_global_mutex);
 
     // TODO: if ret == MappingBusy, try again
     if (ret != MappingSuccess) {

dxinput/utils/keyboard.c

@@ -12,19 +12,18 @@
 #include <X11/Xlib.h>
 #include <X11/XKBlib.h>
 #include "type.h"
-
-static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
+#include "x11_mutex.h"
 
 int
 set_keyboard_repeat(int repeated, unsigned int delay, unsigned int interval)
 {
-    pthread_mutex_lock(&mutex);
+    pthread_mutex_lock(&x11_global_mutex);
     setErrorHandler();
 
     Display *disp = XOpenDisplay(0);
     if (!disp) {
         fprintf(stderr, "Open display failed\n");
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return -1;
     }
 
@@ -49,7 +48,7 @@ set_keyboard_repeat(int repeated, unsigned int delay, unsigned int interval)
     XSync(disp, False);
     XCloseDisplay(disp);
 
-    pthread_mutex_unlock(&mutex);
+    pthread_mutex_unlock(&x11_global_mutex);
 
     return ret;
 }

dxinput/utils/list.c

@@ -13,27 +13,27 @@
 
 #include "list.h"
 #include "type.h"
+#include "x11_mutex.h"
 
 static int append_device(DeviceInfo** devs, XIDeviceInfo* xinfo, int idx);
 static void free_device_info(DeviceInfo* dev);
-static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
 
 DeviceInfo*
 list_device(int* num)
 {
-    pthread_mutex_lock(&mutex);
+    pthread_mutex_lock(&x11_global_mutex);
     setErrorHandler();
 
     if (!num) {
         fprintf(stderr, "list_device failed, !num\n");
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return NULL;
     }
 
     Display* disp = XOpenDisplay(0);
     if (!disp) {
         fprintf(stderr, "Open display failed\n");
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return NULL;
     }
 
@@ -42,7 +42,7 @@ list_device(int* num)
     XCloseDisplay(disp);
     if (!xinfos) {
         fprintf(stderr, "List xinput device failed\n");
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return NULL;
     }
 
@@ -66,7 +66,7 @@ list_device(int* num)
     XIFreeDeviceInfo(xinfos);
     *num = j;
 
-    pthread_mutex_unlock(&mutex);
+    pthread_mutex_unlock(&x11_global_mutex);
 
     return devs;
 }
@@ -115,7 +115,7 @@ append_device(DeviceInfo** devs, XIDeviceInfo* xinfo, int idx)
     tmp[idx].name = name;
     tmp[idx].id = xinfo->deviceid;
     tmp[idx].enabled = xinfo->enabled;
-    tmp[idx].ty = query_device_type(xinfo->deviceid);
+    tmp[idx].ty = query_device_type_unlocked(xinfo->deviceid);
 
     return 0;
 }

dxinput/utils/property.c

@@ -10,11 +10,10 @@
 
 #include "property.h"
 #include "type.h"
+#include "x11_mutex.h"
 
 #define MAX_BUF_LEN 1000
 
-static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
-
 /**
  *  The return data type if 'char' must be convert to 'int8_t*'
  * if 'int' must be convert to 'int32_t*'
@@ -33,21 +32,21 @@ get_prop(int id, const char* prop, int* nitems)
         return NULL;
     }
 
-    pthread_mutex_lock(&mutex);
+    pthread_mutex_lock(&x11_global_mutex);
     setErrorHandler();
 
     Display* disp = XOpenDisplay(0);
     if (!disp) {
         fprintf(stderr, "[get_prop] Open display failed for %d\n", id);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return NULL;
     }
 
     Atom prop_id = XInternAtom(disp, prop, True);
     if (prop_id == None) {
         XCloseDisplay(disp);
         fprintf(stderr, "[get_prop] Intern atom %s failed\n", prop);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return NULL;
     }
 
@@ -61,14 +60,14 @@ get_prop(int id, const char* prop, int* nitems)
     if (ret != Success) {
         XCloseDisplay(disp);
         fprintf(stderr, "[get_prop] Get %s data failed for %d\n", prop, id);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return NULL;
     }
 
     *nitems = (int)num_items;
     XCloseDisplay(disp);
 
-    pthread_mutex_unlock(&mutex);
+    pthread_mutex_unlock(&x11_global_mutex);
 
     return data;
 }
@@ -83,25 +82,25 @@ set_prop_int(int id, const char* prop, unsigned char* data, int nitems, int bit)
 int
 set_prop_float(int id, const char* prop, unsigned char* data, int nitems)
 {
-    pthread_mutex_lock(&mutex);
+    pthread_mutex_lock(&x11_global_mutex);
     setErrorHandler();
 
     Display* disp = XOpenDisplay(NULL);
     if (!disp) {
         fprintf(stderr, "[set_prop_float] open display failed\n");
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return -1;
     }
 
     Atom type = XInternAtom(disp, "FLOAT", False);
     XCloseDisplay(disp);
     if (type == None) {
         fprintf(stderr, "[set_prop_float] Intern 'FLOAT' atom failed\n");
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return -1;
     }
 
-    pthread_mutex_unlock(&mutex);
+    pthread_mutex_unlock(&x11_global_mutex);
 
     // Format must be 32
     int ret = set_prop(id, prop, data, nitems, type, 32);
@@ -123,21 +122,21 @@ set_prop(int id, const char* prop, unsigned char* data, int nitems,
         return -1;
     }
 
-    pthread_mutex_lock(&mutex);
+    pthread_mutex_lock(&x11_global_mutex);
     setErrorHandler();
 
     Display* disp = XOpenDisplay(0);
     if (!disp) {
         fprintf(stderr, "[set_prop] Open display failed for %d\n", id);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return -1;
     }
 
     Atom prop_id = XInternAtom(disp, prop, True);
     if (prop_id == None) {
         XCloseDisplay(disp);
         fprintf(stderr, "[set_prop] Intern atom %s failed\n", prop);
-        pthread_mutex_unlock(&mutex);
+        pthread_mutex_unlock(&x11_global_mutex);
         return -1;
     }
 
@@ -146,7 +145,7 @@ set_prop(int id, const char* prop, unsigned char* data, int nitems,
     /* XFree(&prop_id); */
     XCloseDisplay(disp);
 
-    pthread_mutex_unlock(&mutex);
+    pthread_mutex_unlock(&x11_global_mutex);
 
     return 0;
 }