1 files changed, 152 insertions, 0 deletions
diff --git a/src/libs6rc/s6rc_servicedir_manage.c b/src/libs6rc/s6rc_servicedir_manage.c
new file mode 100644
index 0000000..3c883be
--- /dev/null
+++ b/src/libs6rc/s6rc_servicedir_manage.c
@@ -0,0 +1,152 @@
+/* ISC license. */
+
+#include <skalibs/tai.h>
+#include <s6-rc/s6rc-servicedir.h>
+
+
+static int s6rc_servicedir_manage (char const *live, unsigned char const *state, unsigned int nlong, tain_t const *deadline)
+{
+#if 0
+  unsigned int livelen = str_len(live) ;
+  char 
+    byte_copy(lfn + llen + 1, 12, "servicedirs") ;
+    byte_copy(cfn, llen + 1, lfn) ;
+    byte_copy(cfn + llen + 1, 21, "compiled/servicedirs") ;
+    if (!hiercopy(cfn, lfn))
+    {
+      cleanup() ;
+      strerr_diefu4sys(111, "recursively copy ", cfn, " to ", lfn) ;
+    }
+
+    tain_now_g() ;
+    tain_add_g(&deadline, &tto) ;
+    dir = opendir(lfn) ;
+    if (!dir)
+    {
+      cleanup() ;
+      strerr_diefu2sys(111, "opendir ", lfn) ;
+    }
+    for (;;)
+    {
+      unsigned int thislen ;
+      direntry *d ;
+      errno = 0 ;
+      d = readdir(dir) ;
+      if (!d) break ;
+      if (d->d_name[0] == '.') continue ;
+      thislen = str_len(d->d_name) ;
+      if (thislen > maxlen) maxlen = thislen ;
+      ndirs++ ;
+    }
+    if (errno)
+    {
+      int e = errno ;
+      dir_close(dir) ;
+      errno = e ;
+      cleanup() ;
+      strerr_diefu2sys(111, "readdir ", lfn) ;
+    }
+    if (ndirs)
+    {
+      ftrigr_t a = FTRIGR_ZERO ;
+      gid_t gid = getgid() ;
+      unsigned int i = 0 ;
+      int r ;
+      uint16 ids[ndirs] ;
+      char srcfn[llen + 23 + maxlen] ; /* XXX: unsafe if dir is writable by non-root */
+      char dstfn[llen + 9 + sizeof(S6_SVSCAN_CTLDIR "/control") + maxlen] ;
+      rewinddir(dir) ;
+      byte_copy(srcfn, llen + 12, lfn) ;
+      srcfn[llen + 12] = '/' ;
+      byte_copy(dstfn, llen, satmp.s) ;
+      byte_copy(dstfn + llen, 8, "/scandir") ;
+      dstfn[llen + 8] = '/' ;
+      if (!ftrigr_startf_g(&a, &deadline))
+      {
+        int e = errno ;
+        dir_close(dir) ;
+        errno = e ;
+        cleanup() ;
+        strerr_diefu1sys(111, "start event listener process") ;
+      }
+      for (;;)
+      {
+        unsigned int thislen ;
+        direntry *d ;
+        errno = 0 ;
+        d = readdir(dir) ;
+        if (!d) break ;
+        if (d->d_name[0] == '.') continue ;
+        thislen = str_len(d->d_name) ;
+        byte_copy(srcfn + llen + 13, thislen, d->d_name) ;
+        byte_copy(srcfn + llen + 13 + thislen, 6, "/down") ;
+        if (!touch(srcfn))
+        {
+          cleanup() ;
+          strerr_diefu2sys(111, "touch ", srcfn) ;
+        }
+        byte_copy(srcfn + llen + 14 + thislen, 9, "log/down") ;
+        if (!touch(srcfn))
+        {
+          cleanup() ;
+          strerr_diefu2sys(111, "touch ", srcfn) ;
+        }
+        byte_copy(srcfn + llen + 14 + thislen, 6, "event") ;
+        if (!ftrigw_fifodir_make(srcfn, gid, 0))
+        {
+          cleanup() ;
+          strerr_diefu2sys(111, "make fifodir ", srcfn) ;
+        }
+        ids[i] = ftrigr_subscribe_g(&a, srcfn, "s", 0, &deadline) ;
+        if (!ids[i])
+        {
+          int e = errno ;
+          dir_close(dir) ;
+          errno = e ;
+          cleanup() ;
+          strerr_diefu2sys(111, "subscribe to ", srcfn) ;
+        }
+        srcfn[llen + 13 + thislen] = 0 ;
+        byte_copy(dstfn + llen + 9, thislen + 1, d->d_name) ;
+        if (symlink(srcfn, dstfn) < 0)
+        {
+          int e = errno ;
+          dir_close(dir) ;
+          errno = e ;
+          cleanup() ;
+          strerr_diefu4sys(111, "symlink ", srcfn, " to ", dstfn) ;
+        }
+        i++ ;
+      }
+      if (errno)
+      {
+        int e = errno ;
+        dir_close(dir) ;
+        errno = e ;
+        cleanup() ;
+        strerr_diefu2sys(111, "readdir ", lfn) ;
+      }
+      dir_close(dir) ;
+      byte_copy(dstfn + llen + 9, sizeof(S6_SVSCAN_CTLDIR "/control"), S6_SVSCAN_CTLDIR "/control") ;
+      r = s6_svc_write(dstfn, "a", 1) ;
+      if (r < 0)
+      {
+        cleanup() ;
+        strerr_diefu2sys(111, "write to ", dstfn) ;
+      }
+      if (!r) strerr_warnw2x("s6-svscan not running on ", argv[0]) ;
+      else
+      {
+        if (ftrigr_wait_and_g(&a, ids, ndirs, &deadline) < 0)
+        {
+          cleanup() ;
+          strerr_diefu1sys(111, "wait for s6-supervise processes to come up") ;
+        }
+      }
+      ftrigr_end(&a) ;
+    }
+    else dir_close(dir) ;
+  }
+#endif
+  return 0 ;
+}