async_operations.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "condy/awaiter_operations.hpp"
#include "condy/concepts.hpp"
#include "condy/condy_uring.hpp"
#include "condy/detail/async_operations.hpp"
#include "condy/detail/helpers.hpp"
#include "condy/zcrx.hpp"
 
namespace condy {
 
class ProvidedBufferQueue;
class ProvidedBufferPool;
 
namespace detail {
 
class BundledProvidedBufferQueue;
class BundledProvidedBufferPool;
 
} // namespace detail

template <FdLike Fd1, FdLike Fd2>
inline auto async_splice(Fd1 fd_in, int64_t off_in, Fd2 fd_out, int64_t off_out,
                         unsigned int nbytes, unsigned int splice_flags) {
    if constexpr (detail::is_fixed_fd_v<Fd1>) {
        splice_flags |= SPLICE_F_FD_IN_FIXED;
    }
    auto op = detail::make_op_awaiter(io_uring_prep_splice, fd_in, off_in,
                                      fd_out, off_out, nbytes, splice_flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd_out);
}

template <FdLike Fd1, FdLike Fd2>
inline auto async_tee(Fd1 fd_in, Fd2 fd_out, unsigned int nbytes,
                      unsigned int splice_flags) {
    if constexpr (detail::is_fixed_fd_v<Fd1>) {
        splice_flags |= SPLICE_F_FD_IN_FIXED;
    }
    auto op = detail::make_op_awaiter(io_uring_prep_tee, fd_in, fd_out, nbytes,
                                      splice_flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd_out);
}

template <FdLike Fd>
inline auto async_readv(Fd fd, const struct iovec *iovecs, unsigned nr_vecs,
                        __u64 offset, int flags) {
    auto op = detail::make_op_awaiter(io_uring_prep_readv2, fd, iovecs, nr_vecs,
                                      offset, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
 
#if !IO_URING_CHECK_VERSION(2, 10) // >= 2.10
template <FdLike Fd>
inline auto async_readv(Fd fd, detail::FixedBuffer<const iovec *> iovecs,
                        unsigned nr_vecs, __u64 offset, int flags) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_readv_fixed, fd, iovecs.value,
                                nr_vecs, offset, flags, iovecs.buf_index);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif
 
template <FdLike Fd>
inline auto async_writev(Fd fd, const struct iovec *iovecs,
                         unsigned int nr_vecs, __u64 offset, int flags) {
    auto op = detail::make_op_awaiter(io_uring_prep_writev2, fd, iovecs,
                                      nr_vecs, offset, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
 
#if !IO_URING_CHECK_VERSION(2, 10) // >= 2.10
template <FdLike Fd>
inline auto async_writev(Fd fd, detail::FixedBuffer<const iovec *> iovecs,
                         unsigned int nr_vecs, __u64 offset, int flags) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_writev_fixed, fd, iovecs.value,
                                nr_vecs, offset, flags, iovecs.buf_index);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif

template <FdLike Fd>
inline auto async_recvmsg(Fd fd, struct msghdr *msg, unsigned flags) {
    auto op = detail::make_op_awaiter(io_uring_prep_recvmsg, fd, msg, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd, typename MultiShotFunc,
          AnySameAs<ProvidedBufferQueue, ProvidedBufferPool> Buffer>
inline auto async_recvmsg_multishot(Fd fd, struct msghdr *msg, unsigned flags,
                                    Buffer &buf, MultiShotFunc &&func) {
    auto op = detail::make_multishot_select_buffer_op_awaiter(
        std::forward<MultiShotFunc>(func), &buf,
        io_uring_prep_recvmsg_multishot, fd, msg, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd>
inline auto async_sendmsg(Fd fd, const struct msghdr *msg, unsigned flags) {
    auto op = detail::make_op_awaiter(io_uring_prep_sendmsg, fd, msg, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd, typename FreeFunc>
inline auto async_sendmsg_zc(Fd fd, const struct msghdr *msg, unsigned flags,
                             FreeFunc &&func) {
    auto op = detail::make_zero_copy_op_awaiter(
        std::forward<FreeFunc>(func), io_uring_prep_sendmsg_zc, fd, msg, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
 
#if !IO_URING_CHECK_VERSION(2, 10) // >= 2.10
template <FdLike Fd, typename FreeFunc>
inline auto async_sendmsg_zc(Fd fd, detail::FixedBuffer<const msghdr *> msg,
                             unsigned flags, FreeFunc &&func) {
    auto op = detail::make_zero_copy_op_awaiter(
        std::forward<FreeFunc>(func), io_uring_prep_sendmsg_zc_fixed, fd,
        msg.value, flags, msg.buf_index);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif

template <FdLike Fd> inline auto async_fsync(Fd fd, unsigned fsync_flags) {
    auto op = detail::make_op_awaiter(io_uring_prep_fsync, fd, fsync_flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

inline auto async_nop() { return detail::make_op_awaiter(io_uring_prep_nop); }
 
#if !IO_URING_CHECK_VERSION(2, 13) // >= 2.13
inline auto async_nop128() {
    return detail::make_op_awaiter128(io_uring_prep_nop128);
}
#endif

inline auto async_timeout(struct __kernel_timespec *ts, unsigned count,
                          unsigned flags) {
    return detail::make_op_awaiter(io_uring_prep_timeout, ts, count, flags);
}
 
#if !IO_URING_CHECK_VERSION(2, 4) // >= 2.4

template <typename MultiShotFunc>
inline auto async_timeout_multishot(struct __kernel_timespec *ts,
                                    unsigned count, unsigned flags,
                                    MultiShotFunc &&func) {
    return detail::make_multishot_op_awaiter(std::forward<MultiShotFunc>(func),
                                             io_uring_prep_timeout, ts, count,
                                             flags | IORING_TIMEOUT_MULTISHOT);
}
#endif

template <FdLike Fd>
inline auto async_accept(Fd fd, struct sockaddr *addr, socklen_t *addrlen,
                         int flags) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_accept, fd, addr, addrlen, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd>
inline auto async_accept_direct(Fd fd, struct sockaddr *addr,
                                socklen_t *addrlen, int flags,
                                unsigned int file_index) {
    auto op = detail::make_op_awaiter(io_uring_prep_accept_direct, fd, addr,
                                      addrlen, flags, file_index);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd, typename MultiShotFunc>
inline auto async_multishot_accept(Fd fd, struct sockaddr *addr,
                                   socklen_t *addrlen, int flags,
                                   MultiShotFunc &&func) {
    auto op = detail::make_multishot_op_awaiter(
        std::forward<MultiShotFunc>(func), io_uring_prep_multishot_accept, fd,
        addr, addrlen, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd, typename MultiShotFunc>
inline auto async_multishot_accept_direct(Fd fd, struct sockaddr *addr,
                                          socklen_t *addrlen, int flags,
                                          MultiShotFunc &&func) {
    auto op = detail::make_multishot_op_awaiter(
        std::forward<MultiShotFunc>(func),
        io_uring_prep_multishot_accept_direct, fd, addr, addrlen, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd> inline auto async_cancel_fd(Fd fd, unsigned int flags) {
    if constexpr (detail::is_fixed_fd_v<Fd>) {
        flags |= IORING_ASYNC_CANCEL_FD_FIXED;
    }
    return detail::make_op_awaiter(io_uring_prep_cancel_fd, fd, flags);
}

inline auto async_link_timeout(struct __kernel_timespec *ts, unsigned flags) {
    return detail::make_op_awaiter(io_uring_prep_link_timeout, ts, flags);
}

template <FdLike Fd>
inline auto async_connect(Fd fd, const struct sockaddr *addr,
                          socklen_t addrlen) {
    auto op = detail::make_op_awaiter(io_uring_prep_connect, fd, addr, addrlen);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

inline auto async_files_update(int *fds, unsigned nr_fds, int offset) {
    return detail::make_op_awaiter(io_uring_prep_files_update, fds, nr_fds,
                                   offset);
}

template <FdLike Fd>
inline auto async_fallocate(Fd fd, int mode, __u64 offset, __u64 len) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_fallocate, fd, mode, offset, len);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

inline auto async_openat(int dfd, const char *path, int flags, mode_t mode) {
    return detail::make_op_awaiter(io_uring_prep_openat, dfd, path, flags,
                                   mode);
}

inline auto async_openat_direct(int dfd, const char *path, int flags,
                                mode_t mode, unsigned file_index) {
    return detail::make_op_awaiter(io_uring_prep_openat_direct, dfd, path,
                                   flags, mode, file_index);
}

inline auto async_open(const char *path, int flags, mode_t mode) {
    return async_openat(AT_FDCWD, path, flags, mode);
}

inline auto async_open_direct(const char *path, int flags, mode_t mode,
                              unsigned file_index) {
    return async_openat_direct(AT_FDCWD, path, flags, mode, file_index);
}

inline auto async_close(int fd) {
    return detail::make_op_awaiter(io_uring_prep_close, fd);
}

inline auto async_close(detail::FixedFd fd) {
    return detail::make_op_awaiter(io_uring_prep_close_direct, fd);
}

template <FdLike Fd, BufferLike Buffer>
inline auto async_read(Fd fd, const Buffer &buf, __u64 offset) {
    auto op = detail::make_op_awaiter(io_uring_prep_read, fd, buf.data(),
                                      buf.size(), offset);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd, BufferLike Buffer>
inline auto async_read(Fd fd, detail::FixedBuffer<Buffer> buf, __u64 offset) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_read_fixed, fd, buf.value.data(),
                                buf.value.size(), offset, buf.buf_index);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd, AnySameAs<ProvidedBufferQueue, ProvidedBufferPool> Buffer>
inline auto async_read(Fd fd, Buffer &buf, __u64 offset) {
    auto op = detail::make_select_buffer_op_awaiter(&buf, io_uring_prep_read,
                                                    fd, nullptr, 0, offset);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
 
#if !IO_URING_CHECK_VERSION(2, 6) // >= 2.6
template <FdLike Fd, AnySameAs<ProvidedBufferQueue, ProvidedBufferPool> Buffer,
          typename MultiShotFunc>
inline auto async_read_multishot(Fd fd, Buffer &buf, __u64 offset,
                                 MultiShotFunc &&func) {
    auto op = detail::make_multishot_select_buffer_op_awaiter(
        std::forward<MultiShotFunc>(func), &buf, io_uring_prep_read_multishot,
        fd, 0, offset, buf.bgid());
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif

template <FdLike Fd, BufferLike Buffer>
inline auto async_write(Fd fd, const Buffer &buf, __u64 offset) {
    auto op = detail::make_op_awaiter(io_uring_prep_write, fd, buf.data(),
                                      buf.size(), offset);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <FdLike Fd, BufferLike Buffer>
inline auto async_write(Fd fd, detail::FixedBuffer<Buffer> buf, __u64 offset) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_write_fixed, fd, buf.value.data(),
                                buf.value.size(), offset, buf.buf_index);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

inline auto async_statx(int dfd, const char *path, int flags, unsigned mask,
                        struct statx *statxbuf) {
    return detail::make_op_awaiter(io_uring_prep_statx, dfd, path, flags, mask,
                                   statxbuf);
}

template <FdLike Fd>
inline auto async_fadvise(Fd fd, __u64 offset, off_t len, int advice) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_fadvise, fd, offset, len, advice);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
 
#if !IO_URING_CHECK_VERSION(2, 7) // >= 2.7
template <FdLike Fd>
inline auto async_fadvise64(Fd fd, __u64 offset, off_t len, int advice) {
    auto op = detail::make_op_awaiter(io_uring_prep_fadvise64, fd, offset, len,
                                      advice);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif

inline auto async_madvise(void *addr, __u32 length, int advice) {
    return detail::make_op_awaiter(io_uring_prep_madvise, addr, length, advice);
}
 
#if !IO_URING_CHECK_VERSION(2, 7) // >= 2.7
inline auto async_madvise64(void *addr, off_t length, int advice) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_madvise64, addr, length, advice);
    return op;
}
#endif

template <FdLike Fd, BufferLike Buffer>
inline auto async_send(Fd sockfd, const Buffer &buf, int flags) {
    auto op = detail::make_op_awaiter(io_uring_prep_send, sockfd, buf.data(),
                                      buf.size(), flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}

template <FdLike Fd>
inline auto async_send(Fd sockfd, ProvidedBufferQueue &buf, int flags) {
    auto op = detail::make_select_buffer_op_awaiter(&buf, io_uring_prep_send,
                                                    sockfd, nullptr, 0, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
 
#if !IO_URING_CHECK_VERSION(2, 7) // >= 2.7
template <FdLike Fd>
inline auto async_send(Fd sockfd, detail::BundledProvidedBufferQueue &buf,
                       int flags) {
    auto op = detail::make_bundle_select_buffer_op_awaiter(
        &buf, io_uring_prep_send, sockfd, nullptr, 0, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
#endif

template <FdLike Fd, BufferLike Buffer>
inline auto async_sendto(Fd sockfd, const Buffer &buf, int flags,
                         const struct sockaddr *addr, socklen_t addrlen) {
    auto op = detail::make_op_awaiter(detail::prep_sendto, sockfd, buf.data(),
                                      buf.size(), flags, addr, addrlen);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}

template <FdLike Fd>
inline auto async_sendto(Fd sockfd, ProvidedBufferQueue &buf, int flags,
                         const struct sockaddr *addr, socklen_t addrlen) {
    auto op = detail::make_select_buffer_op_awaiter(
        &buf, detail::prep_sendto, sockfd, nullptr, 0, flags, addr, addrlen);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
 
#if !IO_URING_CHECK_VERSION(2, 7) // >= 2.7
template <FdLike Fd>
inline auto async_sendto(Fd sockfd, detail::BundledProvidedBufferQueue &buf,
                         int flags, const struct sockaddr *addr,
                         socklen_t addrlen) {
    auto op = detail::make_bundle_select_buffer_op_awaiter(
        &buf, detail::prep_sendto, sockfd, nullptr, 0, flags, addr, addrlen);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
#endif

template <FdLike Fd, typename Buffer, typename FreeFunc>
inline auto async_send_zc(Fd sockfd, const Buffer &buf, int flags,
                          unsigned zc_flags, FreeFunc &&func) {
    auto op = detail::make_zero_copy_op_awaiter(
        std::forward<FreeFunc>(func), io_uring_prep_send_zc, sockfd, buf.data(),
        buf.size(), flags, zc_flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}

template <FdLike Fd, BufferLike Buffer, typename FreeFunc>
inline auto async_send_zc(Fd sockfd, detail::FixedBuffer<Buffer> buf, int flags,
                          unsigned zc_flags, FreeFunc &&func) {
    auto op = detail::make_zero_copy_op_awaiter(
        std::forward<FreeFunc>(func), io_uring_prep_send_zc_fixed, sockfd,
        buf.value.data(), buf.value.size(), flags, zc_flags, buf.buf_index);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}

template <FdLike Fd, BufferLike Buffer, typename FreeFunc>
inline auto async_sendto_zc(Fd sockfd, const Buffer &buf, int flags,
                            const struct sockaddr *addr, socklen_t addrlen,
                            unsigned zc_flags, FreeFunc &&func) {
    auto op = detail::make_zero_copy_op_awaiter(
        std::forward<FreeFunc>(func), detail::prep_sendto_zc, sockfd,
        buf.data(), buf.size(), flags, addr, addrlen, zc_flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}

template <FdLike Fd, BufferLike Buffer, typename FreeFunc>
inline auto async_sendto_zc(Fd sockfd, detail::FixedBuffer<Buffer> buf,
                            int flags, const struct sockaddr *addr,
                            socklen_t addrlen, unsigned zc_flags,
                            FreeFunc &&func) {
    auto op = detail::make_zero_copy_op_awaiter(
        std::forward<FreeFunc>(func), detail::prep_sendto_zc_fixed, sockfd,
        buf.value.data(), buf.value.size(), flags, addr, addrlen, zc_flags,
        buf.buf_index);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}

template <FdLike Fd, BufferLike Buffer>
inline auto async_recv(Fd sockfd, const Buffer &buf, int flags) {
    auto op = detail::make_op_awaiter(io_uring_prep_recv, sockfd, buf.data(),
                                      buf.size(), flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}

template <FdLike Fd, AnySameAs<ProvidedBufferQueue, ProvidedBufferPool> Buffer>
inline auto async_recv(Fd sockfd, Buffer &buf, int flags) {
    auto op = detail::make_select_buffer_op_awaiter(&buf, io_uring_prep_recv,
                                                    sockfd, nullptr, 0, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
 
#if !IO_URING_CHECK_VERSION(2, 7) // >= 2.7
template <FdLike Fd, AnySameAs<detail::BundledProvidedBufferQueue,
                               detail::BundledProvidedBufferPool>
                         Buffer>
inline auto async_recv(Fd sockfd, Buffer &buf, int flags) {
    auto op = detail::make_bundle_select_buffer_op_awaiter(
        &buf, io_uring_prep_recv, sockfd, nullptr, 0, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
#endif

template <FdLike Fd, AnySameAs<ProvidedBufferQueue, ProvidedBufferPool> Buffer,
          typename MultiShotFunc>
inline auto async_recv_multishot(Fd sockfd, Buffer &buf, int flags,
                                 MultiShotFunc &&func) {
    auto op = detail::make_multishot_select_buffer_op_awaiter(
        std::forward<MultiShotFunc>(func), &buf, io_uring_prep_recv_multishot,
        sockfd, nullptr, 0, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
 
#if !IO_URING_CHECK_VERSION(2, 7) // >= 2.7
template <FdLike Fd,
          AnySameAs<detail::BundledProvidedBufferQueue,
                    detail::BundledProvidedBufferPool>
              Buffer,
          typename MultiShotFunc>
inline auto async_recv_multishot(Fd sockfd, Buffer &buf, int flags,
                                 MultiShotFunc &&func) {
    auto op = detail::make_multishot_bundle_select_buffer_op_awaiter(
        std::forward<MultiShotFunc>(func), &buf, io_uring_prep_recv_multishot,
        sockfd, nullptr, 0, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 15) // >= 2.15
template <FdLike Fd, typename MultiShotFunc>
inline auto async_recv_multishot(Fd sockfd, ZeroCopyRxBufferPool &pool,
                                 [[maybe_unused]] int flags,
                                 MultiShotFunc &&func) {
    auto zcrx_id = pool.zcrx_id();
    auto prep_func = [=](detail::Ring *ring) {
        auto *sqe = ring->get_sqe();
        detail::prep_recv_zc_multishot(sqe, sockfd, zcrx_id);
        return sqe;
    };
    auto op = build_multishot_op_awaiter<
        SelectBufferCQEHandler<ZeroCopyRxBufferPool>>(
        std::move(prep_func), std::forward<MultiShotFunc>(func), &pool);
    return detail::maybe_flag_fixed_fd(std::move(op), sockfd);
}
#endif

inline auto async_openat2(int dfd, const char *path, struct open_how *how) {
    return detail::make_op_awaiter(io_uring_prep_openat2, dfd, path, how);
}

inline auto async_openat2_direct(int dfd, const char *path,
                                 struct open_how *how, unsigned file_index) {
    return detail::make_op_awaiter(io_uring_prep_openat2_direct, dfd, path, how,
                                   file_index);
}

template <FdLike Fd> inline auto async_shutdown(Fd fd, int how) {
    auto op = detail::make_op_awaiter(io_uring_prep_shutdown, fd, how);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

inline auto async_unlinkat(int dfd, const char *path, int flags) {
    return detail::make_op_awaiter(io_uring_prep_unlinkat, dfd, path, flags);
}

inline auto async_unlink(const char *path, int flags) {
    return async_unlinkat(AT_FDCWD, path, flags);
}

inline auto async_renameat(int olddfd, const char *oldpath, int newdfd,
                           const char *newpath, unsigned int flags) {
    return detail::make_op_awaiter(io_uring_prep_renameat, olddfd, oldpath,
                                   newdfd, newpath, flags);
}

inline auto async_rename(const char *oldpath, const char *newpath) {
    return async_renameat(AT_FDCWD, oldpath, AT_FDCWD, newpath, 0);
}

template <FdLike Fd>
inline auto async_sync_file_range(Fd fd, unsigned len, __u64 offset,
                                  int flags) {
    auto op = detail::make_op_awaiter(io_uring_prep_sync_file_range, fd, len,
                                      offset, flags);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

inline auto async_mkdirat(int dfd, const char *path, mode_t mode) {
    return detail::make_op_awaiter(io_uring_prep_mkdirat, dfd, path, mode);
}

inline auto async_mkdir(const char *path, mode_t mode) {
    return async_mkdirat(AT_FDCWD, path, mode);
}

inline auto async_symlinkat(const char *target, int newdirfd,
                            const char *linkpath) {
    return detail::make_op_awaiter(io_uring_prep_symlinkat, target, newdirfd,
                                   linkpath);
}

inline auto async_symlink(const char *target, const char *linkpath) {
    return async_symlinkat(target, AT_FDCWD, linkpath);
}

inline auto async_linkat(int olddfd, const char *oldpath, int newdfd,
                         const char *newpath, int flags) {
    return detail::make_op_awaiter(io_uring_prep_linkat, olddfd, oldpath,
                                   newdfd, newpath, flags);
}

inline auto async_link(const char *oldpath, const char *newpath, int flags) {
    return async_linkat(AT_FDCWD, oldpath, AT_FDCWD, newpath, flags);
}

inline auto async_getxattr(const char *name, char *value, const char *path,
                           unsigned int len) {
    return detail::make_op_awaiter(io_uring_prep_getxattr, name, value, path,
                                   len);
}

inline auto async_setxattr(const char *name, const char *value,
                           const char *path, int flags, unsigned int len) {
    return detail::make_op_awaiter(io_uring_prep_setxattr, name, value, path,
                                   flags, len);
}

inline auto async_fgetxattr(int fd, const char *name, char *value,
                            unsigned int len) {
    return detail::make_op_awaiter(io_uring_prep_fgetxattr, fd, name, value,
                                   len);
}

inline auto async_fsetxattr(int fd, const char *name, const char *value,
                            int flags, unsigned int len) {
    return detail::make_op_awaiter(io_uring_prep_fsetxattr, fd, name, value,
                                   flags, len);
}

inline auto async_socket(int domain, int type, int protocol,
                         unsigned int flags) {
    return detail::make_op_awaiter(io_uring_prep_socket, domain, type, protocol,
                                   flags);
}

inline auto async_socket_direct(int domain, int type, int protocol,
                                unsigned file_index, unsigned int flags) {
    return detail::make_op_awaiter(io_uring_prep_socket_direct, domain, type,
                                   protocol, file_index, flags);
}

template <CQEHandlerLike CQEHandler = SimpleCQEHandler, FdLike Fd,
          typename CmdFunc>
inline auto async_uring_cmd(int cmd_op, Fd fd, CmdFunc &&cmd_func) {
    auto prep_func = [cmd_op, fd, cmd_func = std::forward<CmdFunc>(cmd_func)](
                         detail::Ring *ring) {
        auto *sqe = ring->get_sqe();
        io_uring_prep_uring_cmd(sqe, cmd_op, fd);
        cmd_func(sqe);
        return sqe;
    };
    auto op = build_op_awaiter<CQEHandler>(std::move(prep_func));
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}

template <CQEHandlerLike CQEHandler = SimpleCQEHandler, FdLike Fd,
          typename CmdFunc, typename MultiShotFunc>
inline auto async_uring_cmd_multishot(int cmd_op, Fd fd, CmdFunc &&cmd_func,
                                      MultiShotFunc &&func) {
    auto prep_func = [cmd_op, fd, cmd_func = std::forward<CmdFunc>(cmd_func)](
                         detail::Ring *ring) {
        auto *sqe = ring->get_sqe();
        io_uring_prep_uring_cmd(sqe, cmd_op, fd);
        cmd_func(sqe);
        return sqe;
    };
    auto op = build_multishot_op_awaiter<CQEHandler>(
        std::move(prep_func), std::forward<MultiShotFunc>(func));
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
 
#if !IO_URING_CHECK_VERSION(2, 13) // >= 2.13
template <CQEHandlerLike CQEHandler = SimpleCQEHandler, FdLike Fd,
          typename CmdFunc>
inline auto async_uring_cmd128(int cmd_op, Fd fd, CmdFunc &&cmd_func) {
    auto prep_func = [cmd_op, fd, cmd_func = std::forward<CmdFunc>(cmd_func)](
                         detail::Ring *ring) {
        auto *sqe = ring->get_sqe128();
        if (!sqe) {
            detail::panic_on("SQE128 not enabled in the ring");
        }
        io_uring_prep_uring_cmd128(sqe, cmd_op, fd);
        cmd_func(sqe);
        return sqe;
    };
    auto op = build_op_awaiter<CQEHandler>(std::move(prep_func));
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 5) // >= 2.5
template <FdLike Fd>
inline auto async_cmd_sock(int cmd_op, Fd fd, int level, int optname,
                           void *optval, int optlen) {
    auto op = detail::make_op_awaiter(io_uring_prep_cmd_sock, cmd_op, fd, level,
                                      optname, optval, optlen);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 13) // >= 2.13
template <FdLike Fd>
inline auto async_cmd_getsockname(Fd fd, struct sockaddr *sockaddr,
                                  socklen_t *sockaddr_len, int peer) {
    auto op = detail::make_op_awaiter(io_uring_prep_cmd_getsockname, fd,
                                      sockaddr, sockaddr_len, peer);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 6) // >= 2.6
inline auto async_waitid(idtype_t idtype, id_t id, siginfo_t *infop,
                         int options, unsigned int flags) {
    return detail::make_op_awaiter(io_uring_prep_waitid, idtype, id, infop,
                                   options, flags);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 6) // >= 2.6
inline auto async_futex_wake(uint32_t *futex, uint64_t val, uint64_t mask,
                             uint32_t futex_flags, unsigned int flags) {
    return detail::make_op_awaiter(io_uring_prep_futex_wake, futex, val, mask,
                                   futex_flags, flags);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 6) // >= 2.6
inline auto async_futex_wait(uint32_t *futex, uint64_t val, uint64_t mask,
                             uint32_t futex_flags, unsigned int flags) {
    return detail::make_op_awaiter(io_uring_prep_futex_wait, futex, val, mask,
                                   futex_flags, flags);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 6) // >= 2.6
inline auto async_futex_waitv(struct futex_waitv *futex, uint32_t nr_futex,
                              unsigned int flags) {
    return detail::make_op_awaiter(io_uring_prep_futex_waitv, futex, nr_futex,
                                   flags);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 6) // >= 2.6
inline auto async_fixed_fd_install(int fixed_fd, unsigned int flags) {
    return detail::make_op_awaiter(io_uring_prep_fixed_fd_install, fixed_fd,
                                   flags);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 6) // >= 2.6
template <FdLike Fd> inline auto async_ftruncate(Fd fd, loff_t len) {
    auto op = detail::make_op_awaiter(io_uring_prep_ftruncate, fd, len);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 8) // >= 2.8
template <FdLike Fd>
inline auto async_cmd_discard(Fd fd, uint64_t offset, uint64_t nbytes) {
    auto op =
        detail::make_op_awaiter(io_uring_prep_cmd_discard, fd, offset, nbytes);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 7) // >= 2.7
template <FdLike Fd>
inline auto async_bind(Fd fd, struct sockaddr *addr, socklen_t addrlen) {
    auto op = detail::make_op_awaiter(io_uring_prep_bind, fd, addr, addrlen);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 7) // >= 2.7
template <FdLike Fd> inline auto async_listen(Fd fd, int backlog) {
    auto op = detail::make_op_awaiter(io_uring_prep_listen, fd, backlog);
    return detail::maybe_flag_fixed_fd(std::move(op), fd);
}
#endif

inline auto async_epoll_ctl(int epfd, int fd, int op, struct epoll_event *ev) {
    return detail::make_op_awaiter(io_uring_prep_epoll_ctl, epfd, fd, op, ev);
}
 
#if !IO_URING_CHECK_VERSION(2, 10) // >= 2.10
inline auto async_epoll_wait(int fd, struct epoll_event *events, int maxevents,
                             unsigned flags) {
    return detail::make_op_awaiter(io_uring_prep_epoll_wait, fd, events,
                                   maxevents, flags);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 12) // >= 2.12
inline auto async_pipe(int *fds, int pipe_flags) {
    return detail::make_op_awaiter(io_uring_prep_pipe, fds, pipe_flags);
}
#endif
 
#if !IO_URING_CHECK_VERSION(2, 12) // >= 2.12
inline auto async_pipe_direct(int *fds, int pipe_flags,
                              unsigned int file_index) {
    return detail::make_op_awaiter(io_uring_prep_pipe_direct, fds, pipe_flags,
                                   file_index);
}
#endif
 
} // namespace condy