Function CreatePipe

cpp/src/arrow/util/io_util.cc:1174–1213

}

Result<Pipe> CreatePipe() {
  bool ok;
  int fds[2];
  Pipe pipe;

#if defined(_WIN32)
  ok = _pipe(fds, 4096, _O_BINARY) >= 0;
  if (ok) {
    pipe = {FileDescriptor(fds[0]), FileDescriptor(fds[1])};
  }
#elif defined(__linux__) && defined(__GLIBC__)
  // On Unix, we don't want the file descriptors to survive after an exec() call
  ok = pipe2(fds, O_CLOEXEC) >= 0;
  if (ok) {
    pipe = {FileDescriptor(fds[0]), FileDescriptor(fds[1])};
  }
#else
  auto set_cloexec = [](int fd) -> bool {
    int flags = fcntl(fd, F_GETFD);
    if (flags >= 0) {
      flags = fcntl(fd, F_SETFD, flags | FD_CLOEXEC);
    }
    return flags >= 0;
  };

  ok = ::pipe(fds) >= 0;
  if (ok) {
    pipe = {FileDescriptor(fds[0]), FileDescriptor(fds[1])};
    ok &= set_cloexec(fds[0]);
    if (ok) {
      ok &= set_cloexec(fds[1]);
    }
  }
#endif
  if (!ok) {
    return IOErrorFromErrno(errno, "Error creating pipe");
  }

  return pipe;
}

Status SetPipeFileDescriptorNonBlocking(int fd) {
#if defined(_WIN32)