From 15eda3d33f9e1160d438d370acd442ef3dbba63f Mon Sep 17 00:00:00 2001 From: Laurent Bercot Date: Tue, 19 Feb 2019 14:54:44 +0000 Subject: Add DragonFly macro; remove nbwaitall and ancilautoclose --- src/include/skalibs/nonposix.h | 2 +- .../textclient_server_init_fromsocket.c | 3 - src/libunixonacid/unixmessage_put.c | 22 ---- src/libunixonacid/unixmessage_receive.c | 6 - src/libunixonacid/unixmessage_sender_flush.c | 3 - src/libunixonacid/unixmessage_sender_free.c | 4 - src/sysdeps/tryancilautoclose.c | 12 -- src/sysdeps/trynbwaitall.c | 121 --------------------- 8 files changed, 1 insertion(+), 172 deletions(-) delete mode 100644 src/sysdeps/tryancilautoclose.c delete mode 100644 src/sysdeps/trynbwaitall.c (limited to 'src') diff --git a/src/include/skalibs/nonposix.h b/src/include/skalibs/nonposix.h index 25af4bd..4ce165c 100644 --- a/src/include/skalibs/nonposix.h +++ b/src/include/skalibs/nonposix.h @@ -61,7 +61,7 @@ because the BSDs are bloody snowflakes. See: setgroups(). */ #undef SKALIBS_BSD_SUCKS -#if defined(__FreeBSD__) || defined(__OpenBSD__) || defined(__NetBSD__) || defined(__bsdi__) +#if defined(__FreeBSD__) || defined(__OpenBSD__) || defined(__NetBSD__) || defined(__bsdi__) || defined(__DragonFly__) # define SKALIBS_BSD_SUCKS #endif diff --git a/src/libunixonacid/textclient_server_init_fromsocket.c b/src/libunixonacid/textclient_server_init_fromsocket.c index 5b71463..e58df2b 100644 --- a/src/libunixonacid/textclient_server_init_fromsocket.c +++ b/src/libunixonacid/textclient_server_init_fromsocket.c @@ -1,6 +1,5 @@ /* ISC license. */ -#include #include #include #include @@ -60,9 +59,7 @@ static int sendit (void *p) do r = sendmsg(fd[0], &hdr, MSG_NOSIGNAL) ; while (r < 0 && errno == EINTR) ; if (r <= 0) return 0 ; -#ifndef SKALIBS_HASANCILAUTOCLOSE fd_close(fd[1]) ; -#endif return 1 ; } diff --git a/src/libunixonacid/unixmessage_put.c b/src/libunixonacid/unixmessage_put.c index 528c3b8..a8701ee 100644 --- a/src/libunixonacid/unixmessage_put.c +++ b/src/libunixonacid/unixmessage_put.c @@ -1,9 +1,5 @@ /* ISC license. */ -#include -#ifdef SKALIBS_HASANCILAUTOCLOSE -#include -#endif #include #include #include @@ -22,24 +18,6 @@ static inline int copyfds (char *s, int const *fds, unsigned int n, unsigned cha int fd = fds[i] ; if (fd < 0) return (errno = EINVAL, -1) ; if (bitarray_peek(bits, i)) fd = - fd - 1 ; -#ifdef SKALIBS_HASANCILAUTOCLOSE - else - { - fd = dup(fd) ; - if (fd < 0) - { - int e = errno ; - while (i--) - { - s -= sizeof(int) ; - memcpy((char *)fd, s, sizeof(int)) ; - if (fd >= 0) (*closecb)(fd, closecbdata) ; - } - errno = e ; - return 0 ; - } - } -#endif memcpy(s, (char const *)&fd, sizeof(int)) ; s += sizeof(int) ; } diff --git a/src/libunixonacid/unixmessage_receive.c b/src/libunixonacid/unixmessage_receive.c index ec12e09..15d08ae 100644 --- a/src/libunixonacid/unixmessage_receive.c +++ b/src/libunixonacid/unixmessage_receive.c @@ -27,12 +27,6 @@ static int const awesomeflags = 0 #endif | -#ifdef SKALIBS_HASNBWAITALL - MSG_WAITALL -#else - 0 -#endif - | #ifdef SKALIBS_HASCMSGCLOEXEC MSG_CMSG_CLOEXEC #else diff --git a/src/libunixonacid/unixmessage_sender_flush.c b/src/libunixonacid/unixmessage_sender_flush.c index eb2645c..fa1438f 100644 --- a/src/libunixonacid/unixmessage_sender_flush.c +++ b/src/libunixonacid/unixmessage_sender_flush.c @@ -1,6 +1,5 @@ /* ISC license. */ -#include #include #include #include @@ -104,7 +103,6 @@ int unixmessage_sender_flush (unixmessage_sender_t *b) do r = sendmsg(b->fd, &hdr, MSG_NOSIGNAL) ; while (r < 0 && errno == EINTR) ; if (r <= 0) return 0 ; -#ifndef SKALIBS_HASANCILAUTOCLOSE if (nfds) { size_t i = 0 ; @@ -114,7 +112,6 @@ int unixmessage_sender_flush (unixmessage_sender_t *b) if (fd < 0) (*b->closecb)(-(fd+1), b->closecbdata) ; } } -#endif if ((size_t)r < 6 + len) { b->shorty = 6 + len - r ; diff --git a/src/libunixonacid/unixmessage_sender_free.c b/src/libunixonacid/unixmessage_sender_free.c index da127c2..4c07952 100644 --- a/src/libunixonacid/unixmessage_sender_free.c +++ b/src/libunixonacid/unixmessage_sender_free.c @@ -1,6 +1,5 @@ /* ISC license. */ -#include #include #include #include @@ -18,9 +17,6 @@ void unixmessage_sender_free (unixmessage_sender_t *b) { int fd = genalloc_s(int, &b->fds)[i] ; if (fd < 0) (*b->closecb)(-(fd+1), b->closecbdata) ; -#ifdef SKALIBS_HASANCILAUTOCLOSE - else (*b->closecb)(fd, b->closecbdata) ; -#endif } } genalloc_free(disize, &b->offsets) ; diff --git a/src/sysdeps/tryancilautoclose.c b/src/sysdeps/tryancilautoclose.c deleted file mode 100644 index 4cb08b3..0000000 --- a/src/sysdeps/tryancilautoclose.c +++ /dev/null @@ -1,12 +0,0 @@ -/* ISC license. */ - - /* - * It's actually false everywhere. - * Not removing the test for now because it would mean editing all the - * places where the test happens. Will remove it later. - */ - -int main (void) -{ - return 1 ; -} diff --git a/src/sysdeps/trynbwaitall.c b/src/sysdeps/trynbwaitall.c deleted file mode 100644 index 48f6b89..0000000 --- a/src/sysdeps/trynbwaitall.c +++ /dev/null @@ -1,121 +0,0 @@ -/* ISC license. */ - -#undef _POSIX_C_SOURCE -#undef _XOPEN_SOURCE - -#ifndef _XPG4_2 -#define _XPG4_2 -#endif - -#ifndef _BSD_SOURCE -#define _BSD_SOURCE -#endif -#ifndef _GNU_SOURCE -#define _GNU_SOURCE -#endif - -#include -#include -#include -#include -#include -#include -#include - -#ifndef MSG_NOSIGNAL -#define MSG_NOSIGNAL 0 -#endif - -#ifndef MSG_DONTWAIT -#define MSG_DONTWAIT 0 -#endif - - -static int ndelay_on (int fd) -{ - int got = fcntl(fd, F_GETFL) ; - return (got == -1) ? -1 : fcntl(fd, F_SETFL, got | O_NONBLOCK) ; -} - -static int child (int p, int fd) -{ - char buf[8] ; - struct iovec v = { .iov_base = buf, .iov_len = 8 } ; - struct msghdr msg = - { - .msg_name = 0, - .msg_namelen = 0, - .msg_iov = &v, - .msg_iovlen = 1, - .msg_control = 0, - .msg_controllen = 0 - } ; - fd_set rfds ; - if (ndelay_on(fd) < 0) return 111 ; - FD_ZERO(&rfds) ; - FD_SET(fd, &rfds) ; - if (write(p, "", 1) < 1) return 111 ; /* sync with the parent */ - if (select(fd+1, &rfds, 0, 0, 0) < 1) return 111 ; - - /* The following recvmsg may block, despite setting the fd - non-blocking. That is what we're testing. */ - - if (recvmsg(fd, &msg, MSG_WAITALL | MSG_DONTWAIT) < 1) return 111 ; - if (write(p, "", 1) < 1) return 111 ; - return 0 ; -} - -static int parent (pid_t pid, int p, int fd) -{ - char c ; - struct iovec v = { .iov_base = &c, .iov_len = 1 } ; - struct msghdr msg = - { - .msg_name = 0, - .msg_namelen = 0, - .msg_iov = &v, - .msg_iovlen = 1, - .msg_control = 0, - .msg_controllen = 0 - } ; - struct timeval tv = { .tv_sec = 2, .tv_usec = 0 } ; - fd_set rfds ; - unsigned int n = p > fd ? p : fd ; - int r ; - FD_ZERO(&rfds) ; - FD_SET(p, &rfds) ; - if (read(p, &c, 1) < 1) return 111 ; - if (sendmsg(fd, &msg, MSG_NOSIGNAL) < 1) return 111 ; - for (;;) - { - r = select(n+1, &rfds, 0, 0, &tv) ; - if (r >= 0 || errno != EINTR) break ; - } - if (!r) /* child is still blocking on recvmsg() after 2 seconds */ - { - kill(pid, SIGTERM) ; - return 1 ; - } - if (read(p, &c, 1) < 1) return 111 ; - return 0 ; -} - -int main (void) -{ - pid_t pid ; - int fd[2] ; - int p[2] ; - if (pipe(p) < 0) return 111 ; - if (socketpair(AF_UNIX, SOCK_STREAM, 0, fd) < 0) return 111 ; - pid = fork() ; - if (pid < 0) return 111 ; - if (!pid) - { - close(p[0]) ; - close(fd[0]) ; - return child(p[1], fd[1]) ; - } - close(p[1]) ; - close(fd[1]) ; - return parent(pid, p[0], fd[0]) ; -} -- cgit v1.2.3