tabs and tab overview

reaper.c

@@ -0,0 +1,120 @@
+#include "reaper.h"
+
+#include <stdlib.h>
+#include <unistd.h>
+#include <sys/epoll.h>
+#include <signal.h>
+#include <sys/wait.h>
+#include <tllist.h>
+
+#define LOG_MODULE "reaper"
+#define LOG_ENABLE_DBG 0
+#include "log.h"
+
+struct child {
+    pid_t pid;
+    reaper_cb cb;
+    void *cb_data;
+};
+
+struct reaper {
+    struct fdm *fdm;
+    tll(struct child) children;
+};
+
+static bool fdm_reap(struct fdm *fdm, int signo, void *data);
+
+struct reaper *
+reaper_init(struct fdm *fdm)
+{
+    struct reaper *reaper = malloc(sizeof(*reaper));
+    if (unlikely(reaper == NULL)) {
+        LOG_ERRNO("malloc() failed");
+        return NULL;
+    }
+
+    *reaper = (struct reaper){
+        .fdm = fdm,
+        .children = tll_init(),
+    };
+
+    if (!fdm_signal_add(fdm, SIGCHLD, &fdm_reap, reaper))
+        goto err;
+
+    return reaper;
+
+err:
+    tll_free(reaper->children);
+    free(reaper);
+    return NULL;
+}
+
+void
+reaper_destroy(struct reaper *reaper)
+{
+    if (reaper == NULL)
+        return;
+
+    fdm_signal_del(reaper->fdm, SIGCHLD);
+    tll_free(reaper->children);
+    free(reaper);
+}
+
+void
+reaper_add(struct reaper *reaper, pid_t pid, reaper_cb cb, void *cb_data)
+{
+    LOG_DBG("adding pid=%d", pid);
+    tll_push_back(
+        reaper->children,
+        ((struct child){.pid = pid, .cb = cb, .cb_data = cb_data}));
+}
+
+void
+reaper_del(struct reaper *reaper, pid_t pid)
+{
+    tll_foreach(reaper->children, it) {
+        if (it->item.pid == pid) {
+            tll_remove(reaper->children, it);
+            break;
+        }
+    }
+}
+
+static bool
+fdm_reap(struct fdm *fdm, int signo, void *data)
+{
+    struct reaper *reaper = data;
+
+    while (true) {
+        int status;
+        pid_t pid = waitpid(-1, &status, WNOHANG);
+        if (pid <= 0)
+            break;
+
+        if (WIFEXITED(status))
+            LOG_DBG("pid=%d: exited with status=%d", pid, WEXITSTATUS(status));
+        else if (WIFSIGNALED(status))
+            LOG_DBG("pid=%d: killed by signal=%d", pid, WTERMSIG(status));
+        else
+            LOG_DBG("pid=%d: died of unknown resason", pid);
+
+        tll_foreach(reaper->children, it) {
+            struct child *_child = &it->item;
+
+            if (_child->pid != pid)
+                continue;
+
+            /* Make sure we remove it *before* the callback, since it too
+             * may remove it */
+            struct child child = it->item;
+            tll_remove(reaper->children, it);
+
+            if (child.cb != NULL)
+                child.cb(reaper, child.pid, status, child.cb_data);
+
+            break;
+        }
+    }
+
+    return true;
+}