From 96ed44c31b92f1492be68c084e8b18972d549743 Mon Sep 17 00:00:00 2001
From: crupest <crupest@outlook.com>
Date: Mon, 12 Feb 2024 15:47:31 +0800
Subject: WORKING: add unix pipe.

---
 src/common/platform/unix/UnixPipe.cpp | 38 +++++++++++++++++++++++++++++++++++
 1 file changed, 38 insertions(+)
 create mode 100644 src/common/platform/unix/UnixPipe.cpp

(limited to 'src/common/platform/unix/UnixPipe.cpp')

diff --git a/src/common/platform/unix/UnixPipe.cpp b/src/common/platform/unix/UnixPipe.cpp
new file mode 100644
index 00000000..8393f022
--- /dev/null
+++ b/src/common/platform/unix/UnixPipe.cpp
@@ -0,0 +1,38 @@
+#include "cru/common/platform/unix/UnixPipe.h"
+#include "cru/common/Exception.h"
+#include "cru/common/log/Logger.h"
+
+#include <unistd.h>
+
+namespace cru::platform::unix {
+UnixPipe::UnixPipe(Usage usage) : usage_(usage) {
+  int fds[2];
+  if (pipe(fds) != 0) {
+    throw ErrnoException(u"Failed to create unix pipe.");
+  }
+  read_fd_ = fds[0];
+  write_fd_ = fds[1];
+}
+
+int UnixPipe::GetSelfFileDescriptor() {
+  if (usage_ == Usage::Send) {
+    return write_fd_;
+  } else {
+    return read_fd_;
+  }
+}
+
+int UnixPipe::GetOtherFileDescriptor() {
+  if (usage_ == Usage::Send) {
+    return read_fd_;
+  } else {
+    return write_fd_;
+  }
+}
+
+UnixPipe::~UnixPipe() {
+  if (close(GetSelfFileDescriptor()) != 0) {
+    CRU_LOG_ERROR(u"Failed to close unix pipe file descriptor.");
+  }
+}
+}  // namespace cru::platform::unix
-- 
cgit v1.2.3