summaryrefslogtreecommitdiff
path: root/sysdep/unix/io.c
diff options
context:
space:
mode:
Diffstat (limited to 'sysdep/unix/io.c')
-rw-r--r--sysdep/unix/io.c32
1 files changed, 30 insertions, 2 deletions
diff --git a/sysdep/unix/io.c b/sysdep/unix/io.c
index 22c96d63..295bee16 100644
--- a/sysdep/unix/io.c
+++ b/sysdep/unix/io.c
@@ -797,6 +797,8 @@ sk_free(resource *r)
{
sock *s = (sock *) r;
+ log(L_TRACE "sk_free %d %d", s->fd, s->type);
+
sk_free_bufs(s);
#ifdef HAVE_LIBSSH
@@ -1520,29 +1522,50 @@ sk_open_unix(sock *s, char *name)
return 0;
}
+static void hexdump(const char *data, socklen_t size)
+{
+ char buf[1024]="";
+
+ for (unsigned int i = 0; i < size; i++)
+ {
+ sprintf(buf + i*3, "%02x ", data[i]);
+ }
+ log(L_TRACE "sk_connect_unix: %s", buf);
+}
+
int
sk_connect_unix(sock *s, char *name, socklen_t namelen)
{
struct sockaddr_un sa;
int fd;
+ log(L_TRACE "sk_connect_unix %d %s", name[0], name + 1);
+
if (namelen > sizeof(sa.sun_path))
return -1;
+ log(L_TRACE "sk_connect_unix 2");
+
/* We are sloppy during error (leak fd and not set s->err), but we die anyway */
fd = socket(AF_UNIX, SOCK_STREAM, 0);
if (fd < 0)
- return -1;
+ return -2;
+
+ log(L_TRACE "sk_connect_unix 3");
if (fcntl(fd, F_SETFL, O_NONBLOCK) < 0)
- return -1;
+ return -3;
+
+ log(L_TRACE "sk_connect_unix 4");
/* Path length checked in test_old_bird() */
memset(&sa, 0, sizeof(sa));
sa.sun_family = AF_UNIX;
memcpy(sa.sun_path, name, namelen);
+ hexdump((const char*)&sa, sizeof(sa.sun_family) + namelen);
+
s->fd = fd;
s->type = SK_UNIX_ACTIVE;
s->ttx = ""; /* Force s->ttx != s->tpos */
@@ -1555,6 +1578,8 @@ sk_connect_unix(sock *s, char *name, socklen_t namelen)
ERR2("connect");
}
+ log(L_TRACE "sk_connect_unix 5");
+
sk_insert(s);
/* sk_alloc_bufs(s); Shouldn't be needed with SK_UNIX_ACTIVE */
return 0;
@@ -1930,7 +1955,10 @@ sk_read(sock *s, int revents)
}
}
else if (!c)
+ {
+ if (s->type == SK_UNIX) log(L_TRACE "Unix socket nothing to read");
s->err_hook(s, 0);
+ }
else
{
s->rpos += c;