native_aio.hxx

Go to the documentation of this file.

 
#pragma once
#include <ice/string.hxx>
 
namespace ice::native_aio
{
 
    using AIOPort = struct AIOPortInternal*;
 
    struct AIOPortInfo
    {
        ice::u32 worker_limit = 1;
        ice::String debug_name;
    };
 
    struct AIOStatusInfo
    {
    };
 
    enum class AIORequestResult : ice::u8
    {
        Error,
        Success,
        Timeout,
    };
 
    using AIORequestCallback = void(*)(
        ice::native_aio::AIORequestResult result,
        ice::usize bytes_read,
        void* userdata
    ) noexcept;
 
    struct alignas(8) AIORequest
    {
        using enum AIORequestResult;

        char _internal[40];
 
        ice::native_aio::AIOPort _port;

        ice::native_aio::AIORequestCallback _callback = nullptr;

        void* _userdata = nullptr;
    };
 
    auto aio_open(
        ice::Allocator& alloc,
        ice::native_aio::AIOPortInfo const& info
    ) noexcept -> ice::native_aio::AIOPort;
 
    void aio_close(ice::native_aio::AIOPort port) noexcept;
    auto aio_status(ice::native_aio::AIOPort port) noexcept -> ice::native_aio::AIOStatusInfo;
    auto aio_native_handle(ice::native_aio::AIOPort port) noexcept -> void*;
    auto aio_worker_limit(ice::native_aio::AIOPort port) noexcept -> ice::u32;
 
    struct AIOProcessLimits
    {
        ice::u32 timeout_ms = ice::u32_max;
        ice::u32 events_max = ice::u32_max;
    };
 
    auto aio_process_events(
        ice::native_aio::AIOPort port,
        ice::native_aio::AIOProcessLimits limits = {}
    ) noexcept -> ice::u32;
 
} // namespace ice::native_aio