msg/simple: port to osx

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/msg/simple/Accepter.cc b/src/msg/simple/Accepter.cc
index 5779cc7abec69b8d52c66962e1092d56dbb6799e..6e188c47bc2a5443f0c3fcde773658396d2e1c9d 100644 (file)
--- a/src/msg/simple/Accepter.cc
+++ b/src/msg/simple/Accepter.cc
@@ -54,7 +54,17 @@ static int set_close_on_exec(int fd)
 
 int Accepter::create_selfpipe(int *pipe_rd, int *pipe_wr) {
   int selfpipe[2];
+#ifdef HAVE_PIPE2
   int ret = ::pipe2(selfpipe, (O_CLOEXEC|O_NONBLOCK));
+#else
+  int ret = ::pipe(selfpipe);
+  if (ret == 0) {
+    for (int i = 0; i < ceph::size(selfpipe); i++) {
+      int f = fcntl(selfpipe[i], F_GETFD);
+      fcntl(selfpipe[i], F_SETFD, f | FD_CLOEXEC | O_NONBLOCK);
+    }
+  }
+#endif
   if (ret < 0 ) {
     lderr(msgr->cct) << __func__ << " unable to create the selfpipe: "
                     << cpp_strerror(errno) << dendl;