fix this mess of libraries

2026-07-29 15:59:14 +02:00 · 2026-07-05 17:49:51 +02:00
parent b09834b801
commit 8e4709f456
24 changed files with 62 additions and 82 deletions
@@ -0,0 +1,97 @@
+#include "ipc.h"
+
+#include <stdlib.h>
+#include <string.h>
+#include <errno.h>
+#include <pthread.h>
+#include <sys/un.h>
+
+static int make_server_socket(const char *path)
+{
+    int fd = socket(AF_UNIX, SOCK_STREAM, 0);
+    if (fd < 0) { perror("ipc: socket"); return -1; }
+
+    unlink(path);
+
+    struct sockaddr_un addr = { .sun_family = AF_UNIX };
+    strncpy(addr.sun_path, path, sizeof(addr.sun_path) - 1);
+
+    if (bind(fd, (struct sockaddr *)&addr, sizeof(addr)) < 0) {
+        perror("ipc: bind"); close(fd); return -1;
+    }
+    if (listen(fd, IPC_BACKLOG) < 0) {
+        perror("ipc: listen"); close(fd); return -1;
+    }
+    return fd;
+}
+
+static void *listener_thread(void *arg) {
+    ipc_ctx_t *ctx = (ipc_ctx_t *)arg;
+
+    while (ctx->running) {
+        struct sockaddr_un peer;
+        socklen_t peer_len = sizeof(peer);
+
+        int client_fd = accept(ctx->server_fd,
+                               (struct sockaddr *)&peer, &peer_len);
+        if (client_fd < 0) {
+            if (errno == EINVAL || errno == EBADF) break; /* shutting down */
+            if (errno == EINTR)                   continue;
+            perror("ipc: accept");
+            continue;
+        }
+
+        printf("[ipc] new client fd=%d\n", client_fd);
+
+        ipc_client_arg_t *carg = malloc(sizeof(ipc_client_arg_t));
+        if (!carg) { close(client_fd); continue; }
+        carg->client_fd = client_fd;
+        carg->user_data = ctx->user_data;
+
+        pthread_t tid;
+        if (pthread_create(&tid, NULL,
+                           (void *(*)(void *))ctx->handler, carg) != 0) {
+            perror("ipc: pthread_create");
+            free(carg);
+            close(client_fd);
+            continue;
+        }
+        pthread_detach(tid);
+    }
+
+    printf("[ipc] listener exiting\n");
+    return NULL;
+}
+
+int create_ipc(ipc_ctx_t *ctx, ipc_client_fn handler,
+               const char *socket_path, void *user_data)
+{
+    ctx->handler     = handler;
+    ctx->user_data   = user_data;
+    ctx->running     = 1;
+    ctx->server_fd   = make_server_socket(socket_path);
+    ctx->socket_path = strdup(socket_path);
+    if (ctx->server_fd < 0) return -1;
+
+    pthread_t tid;
+    if (pthread_create(&tid, NULL, listener_thread, ctx) != 0) {
+        perror("ipc: pthread_create");
+        close(ctx->server_fd);
+        unlink(socket_path);
+        return -1;
+    }
+
+    ctx->_tid = tid;
+
+    printf("[ipc] listening on %s\n", socket_path);
+    return 0;
+}
+
+void destroy_ipc(ipc_ctx_t *ctx) {
+    ctx->running = 0;
+    shutdown(ctx->server_fd, SHUT_RDWR); /* unblock accept() */
+    close(ctx->server_fd);
+    unlink(ctx->socket_path);
+    pthread_join(ctx->_tid, NULL);
+    printf("[ipc] shut down\n");
+}