From e3aeb3b63b9996bd06c20861e1dac1c9421d9312 Mon Sep 17 00:00:00 2001
From: Laurent Bercot <ska-skaware@skarnet.org>
Date: Wed, 7 Jan 2015 01:12:01 +0000
Subject:  Experimental decoupling of socketbinders and daemons in ucspi
 servers.  Rewrite of s6-ipcserver as a small wrapper.  s6-tcpserver4 and
 s6-tcpserver6 will follow.

---
 src/conn-tools/s6-ipcserver-socketbinder.c | 49 ++++++++++++++++++++++++++++++
 1 file changed, 49 insertions(+)
 create mode 100644 src/conn-tools/s6-ipcserver-socketbinder.c

(limited to 'src/conn-tools/s6-ipcserver-socketbinder.c')

diff --git a/src/conn-tools/s6-ipcserver-socketbinder.c b/src/conn-tools/s6-ipcserver-socketbinder.c
new file mode 100644
index 0000000..b5a32f3
--- /dev/null
+++ b/src/conn-tools/s6-ipcserver-socketbinder.c
@@ -0,0 +1,49 @@
+/* ISC license. */
+
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <unistd.h>
+#include <skalibs/uint.h>
+#include <skalibs/sgetopt.h>
+#include <skalibs/strerr2.h>
+#include <skalibs/djbunix.h>
+#include <skalibs/webipc.h>
+
+#define USAGE "s6-ipcserver-socketbinder [ -d | -D ] [ -b backlog ] path prog..."
+#define dieusage() strerr_dieusage(100, USAGE)
+
+int main (int argc, char const *const *argv, char const *const *envp)
+{
+  unsigned int backlog = 20 ;
+  int flagreuse = 1 ;
+  PROG = "s6-ipcserver-socketbinder" ;
+  {
+    subgetopt_t l = SUBGETOPT_ZERO ;
+    for (;;)
+    {
+      register int opt = subgetopt_r(argc, argv, "Ddb:", &l) ;
+      if (opt == -1) break ;
+      switch (opt)
+      {
+        case 'D' : flagreuse = 0 ; break ;
+        case 'd' : flagreuse = 1 ; break ;
+        case 'b' : if (!uint0_scan(l.arg, &backlog)) dieusage() ; break ;
+        default : dieusage() ;
+      }
+    }
+    argc -= l.ind ; argv += l.ind ;
+  }
+  if (argc < 2) dieusage() ;
+  close(0) ;
+  if (ipc_stream()) strerr_diefu1sys(111, "create socket") ;
+  {
+    mode_t m = umask(0) ;
+    if ((flagreuse ? ipc_bind_reuse(0, argv[0]) : ipc_bind(0, argv[0])) < 0)
+      strerr_diefu2sys(111, "bind to ", argv[0]) ;
+    umask(m) ;
+  }
+  if (ipc_listen(0, backlog) < 0) strerr_diefu2sys(111, "listen to ", argv[0]) ;
+
+  pathexec_run(argv[1], argv + 1, envp) ;
+  strerr_dieexec(111, argv[1]) ;
+}
-- 
cgit v1.3.1