include pipe2/socketpair compat for macOS

1 files changed, 56 insertions, 0 deletions

diff --git a/tests/compat/pipe2.c b/tests/compat/pipe2.c
new file mode 100644
index 0000000..e2aaa28
--- /dev/null
+++ b/tests/compat/pipe2.c
@@ -0,0 +1,56 @@
+/*
+ * Public domain
+ */
+
+#include <fcntl.h>
+#include <unistd.h>
+#include <sys/socket.h>
+#undef socketpair
+
+static int setfd(int fd, int flag)
+{
+        int flags = fcntl(fd, F_GETFD);
+        flags |= flag;
+        return fcntl(fd, F_SETFD, flags);
+}
+
+static int setfl(int fd, int flag)
+{
+        int flags = fcntl(fd, F_GETFL);
+        flags |= flag;
+        return fcntl(fd, F_SETFL, flags);
+}
+
+int pipe2(int fildes[2], int flags)
+{
+        int rc = pipe(fildes);
+        if (rc == 0) {
+                if (flags & O_NONBLOCK) {
+                        setfl(fildes[0], O_NONBLOCK);
+                        setfl(fildes[1], O_NONBLOCK);
+                }
+                if (flags & O_CLOEXEC) {
+                        setfd(fildes[0], FD_CLOEXEC);
+                        setfd(fildes[1], FD_CLOEXEC);
+                }
+        }
+        return rc;
+}
+
+int bsd_socketpair(int domain, int type, int protocol, int socket_vector[2])
+{
+        int flags = type & ~0xf;
+        type &= 0xf;
+        int rc = socketpair(domain, type, protocol, socket_vector);
+        if (rc == 0) {
+                if (flags & SOCK_NONBLOCK) {
+                        setfl(socket_vector[0], O_NONBLOCK);
+                        setfl(socket_vector[1], O_NONBLOCK);
+                }
+                if (flags & SOCK_CLOEXEC) {
+                        setfd(socket_vector[0], FD_CLOEXEC);
+                        setfd(socket_vector[1], FD_CLOEXEC);
+                }
+        }
+        return rc;
+}