1 files changed, 75 insertions, 0 deletions
diff --git a/src/libplaynice/keventbridge_start.c b/src/libplaynice/keventbridge_start.c
new file mode 100644
index 0000000..21ead0e
--- /dev/null
+++ b/src/libplaynice/keventbridge_start.c
@@ -0,0 +1,75 @@
+/* ISC license. */
+
+#include <skalibs/sysdeps.h>
+
+#ifdef SKALIBS_HASKEVENT
+
+#include <errno.h>
+#include <pthread.h>
+
+#include <skalibs/fcntl.h>
+#include <skalibs/djbunix.h>
+#include <skalibs/keventbridge.h>
+
+#ifdef SKALIBS_HASKQUEUE1
+
+# define kqueuec() kqueue1(O_CLOEXEC)
+
+#else
+
+static int kqueuec (void)
+{
+  int kq = kqueue() ;
+  if (kq == -1) return -1 ;
+  if (coe(kq) == -1)
+  {
+    fd_close(kq) ;
+    return -1 ;
+  }
+  return kq ;
+}
+
+#endif
+
+static void *keventbridge_reader (void *arg)
+{
+  keventbridge *kbp = arg ;
+  struct kevent ke ;
+  for (;;)
+  {
+    int r = kevent(kbp->kq, 0, 0, &ke, 1, 0) ;
+    if (r == -1 && errno != EINTR) break ;
+    if (r && allwrite(kbp->p[1], (char *)&ke, sizeof(ke)) < sizeof(ke)) break ;
+  }
+  fd_close(kbp->p[1]) ;
+  kbp->p[1] = -1 ;
+  return 0 ;
+}
+
+int keventbridge_start (keventbridge *kbp)
+{
+  pthread_attr_t attr ;
+  int e ;
+
+  kbp->kq = kqueuec() ;
+  if (pipecoe(kbp->p) == -1) goto errkq ;
+  if (ndelay_on(kbp->p[0]) == -1) goto errp ;
+  e = pthread_attr_init(&attr) ;
+  if (e) { errno = e ; goto errp ; }
+  pthread_attr_setstacksize(&attr, PTHREAD_STACK_MIN) ;
+  e = pthread_create(&kbp->th, &attr, &keventbridge_reader, kbp) ;
+  if (e) { errno = e ; goto errattr ; }
+  pthread_attr_destroy(&attr) ;
+  return 1 ;
+
+ errattr:
+  pthread_attr_destroy(&attr) ;
+ errp:
+  fd_close(kbp->p[1]) ;
+  fd_close(kbp->p[0]) ;
+ errkq:
+  fd_close(kbp->kq) ;
+  return 0 ;
+}
+
+#endif