1 files changed, 59 insertions, 0 deletions
diff --git a/sysdep/unix/io.c b/sysdep/unix/io.c
index 3d67d0a7..9b6111d6 100644
--- a/sysdep/unix/io.c
+++ b/sysdep/unix/io.c
@@ -1050,6 +1050,14 @@ sk_tcp_connected(sock *s)
   s->tx_hook(s);
 }
 
+static void
+sk_unix_connected(sock *s)
+{
+  sk_alloc_bufs(s);
+  s->type = SK_UNIX;
+  s->tx_hook(s);
+}
+
 #ifdef HAVE_LIBSSH
 static void
 sk_ssh_connected(sock *s)
@@ -1512,6 +1520,51 @@ sk_open_unix(sock *s, char *name)
   return 0;
 }
 
+int
+sk_connect_unix(sock *s, char *name, socklen_t namelen)
+{
+  struct sockaddr_un sa;
+  int fd;
+
+  if (namelen > sizeof(sa.sun_path))
+    return -1;
+
+  fd = socket(AF_UNIX, SOCK_STREAM, 0);
+  if (fd < 0)
+    return -1;
+
+  if (fcntl(fd, F_SETFL, O_NONBLOCK) < 0)
+    {
+      close(fd);
+      return -3;
+    }
+
+  /* Path length checked in test_old_bird() */
+  memset(&sa, 0, sizeof(sa));
+  sa.sun_family = AF_UNIX;
+  memcpy(sa.sun_path, name, namelen);
+
+  s->fd = fd;
+  s->type = SK_UNIX_ACTIVE;
+  s->ttx = "";			/* Force s->ttx != s->tpos */
+
+  if (connect(fd, (struct sockaddr *) &sa, sizeof(sa.sun_family) + namelen) >= 0)
+    sk_unix_connected(s);
+  else if (errno != EINTR && errno != EAGAIN && errno != EINPROGRESS &&
+	   errno != ECONNREFUSED && errno != EHOSTUNREACH && errno != ENETUNREACH)
+  {
+    ERR2("connect");
+  }
+
+  sk_insert(s);
+  return 0;
+
+ err:
+  close(fd);
+  s->fd = -1;
+  return -1;
+}
+
 
 #define CMSG_RX_SPACE MAX(CMSG4_SPACE_PKTINFO+CMSG4_SPACE_TTL, \
 			  CMSG6_SPACE_PKTINFO+CMSG6_SPACE_TTL)
@@ -1930,6 +1983,12 @@ sk_write(sock *s)
       return 0;
     }
 
+  case SK_UNIX_ACTIVE:
+    {
+      sk_unix_connected(s);
+      return 0;
+    }
+
 #ifdef HAVE_LIBSSH
   case SK_SSH_ACTIVE:
     {