新增跨平台异步IO模块

bee/async/async.cpp

@@ -0,0 +1,28 @@
+#include <bee/async/async.h>
+
+#if defined(__linux__)
+#    include <bee/async/async_epoll_linux.h>
+#    if !defined(BEE_ASYNC_BACKEND_EPOLL)
+#        include <bee/async/async_uring_linux.h>
+#    endif
+#endif
+
+namespace bee::async {
+
+    std::unique_ptr<async> create() {
+#if defined(__linux__)
+#    if defined(BEE_ASYNC_BACKEND_EPOLL)
+        return std::make_unique<async_epoll>();
+#    else
+        auto uring = std::make_unique<async_uring>();
+        if (uring->valid()) {
+            return uring;
+        }
+        return std::make_unique<async_epoll>();
+#    endif
+#else
+        return std::make_unique<async>();
+#endif
+    }
+
+}  // namespace bee::async

bee/async/async.h

@@ -0,0 +1,53 @@
+#pragma once
+
+#include <bee/async/async_types.h>
+#include <bee/net/endpoint.h>
+#include <bee/net/fd.h>
+#include <bee/net/socket.h>
+#include <bee/sys/file_handle.h>
+#include <bee/utility/span.h>
+
+#include <cstddef>
+#include <cstdint>
+#include <memory>
+
+#if defined(_WIN32)
+#    include <bee/async/async_win.h>
+#elif defined(__APPLE__)
+#    if defined(BEE_ASYNC_BACKEND_KQUEUE)
+#        include <bee/async/async_bsd.h>
+#    else
+#        include <bee/async/async_osx.h>
+#    endif
+#elif defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__)
+#    include <bee/async/async_bsd.h>
+#endif
+
+namespace bee::async {
+
+#if defined(__linux__)
+
+    class async {
+    public:
+        virtual ~async()                                                                                                                = default;
+        virtual bool submit_read(net::fd_t fd, void* buffer, size_t len, uint64_t request_id)                                           = 0;
+        virtual bool submit_readv(net::fd_t fd, span<const net::socket::iobuf> bufs, uint64_t request_id)                              = 0;
+        virtual bool submit_write(net::fd_t fd, const void* buffer, size_t len, uint64_t request_id)                                    = 0;
+        virtual bool submit_writev(net::fd_t fd, span<const net::socket::iobuf> bufs, uint64_t request_id)                              = 0;
+        virtual bool submit_accept(net::fd_t listen_fd, uint64_t request_id)                                                            = 0;
+        virtual bool submit_connect(net::fd_t fd, const net::endpoint& ep, uint64_t request_id)                                         = 0;
+        virtual bool submit_file_read(file_handle::value_type fd, void* buffer, size_t len, int64_t offset, uint64_t request_id)        = 0;
+        virtual bool submit_file_write(file_handle::value_type fd, const void* buffer, size_t len, int64_t offset, uint64_t request_id) = 0;
+        virtual bool submit_poll(net::fd_t fd, uint64_t request_id)                                                                     = 0;
+        virtual int poll(const span<io_completion>& completions)                                                                        = 0;
+        virtual int wait(const span<io_completion>& completions, int timeout)                                                           = 0;
+        virtual void stop()                                                                                                             = 0;
+        virtual void cancel(net::fd_t fd)                                                                                               = 0;
+    };
+
+#endif
+
+    // Factory function: create the async backend for the current platform.
+    std::unique_ptr<async> create();
+
+}  // namespace bee::async