io_operation.hpp

Go to the documentation of this file.

 
#ifndef JOIN_CORE_IO_OPERATION_HPP
#define JOIN_CORE_IO_OPERATION_HPP
 
// C.
#include <sys/socket.h>
#include <cstdint>
 
namespace join
{
    // forward declaration.
    class CompletionHandler;
 
    struct alignas (64) IoOperation
    {
        enum class State : uint8_t
        {
            Idle,       
            Submitted,  
            Cancelling, 
        };
 
        enum class Opcode : uint8_t
        {
            Accept,     
            Connect,    
            Read,       
            Write,      
            ReadFixed,  
            WriteFixed, 
            RecvMsg,    
            SendMsg,    
            Recv,       
            Send,       
        };
 
        struct AcceptData
        {
            int fd;
 
            sockaddr* addr;
 
            socklen_t* addrlen;
 
            int flags;
        };
 
        static IoOperation makeAccept (int fd, sockaddr* addr, socklen_t* addrlen, int flags,
                                       CompletionHandler* handler) noexcept;
 
        struct ConnectData
        {
            int fd;
 
            const sockaddr* addr;
 
            socklen_t addrlen;
        };
 
        static IoOperation makeConnect (int fd, const sockaddr* addr, socklen_t addrlen,
                                        CompletionHandler* handler) noexcept;
 
        struct RwData
        {
            int fd;
 
            void* buf;
 
            unsigned long len;
 
            uint16_t index;
 
            bool fixed;
        };
 
        static IoOperation makeRead (int fd, void* buf, uint32_t len, CompletionHandler* handler,
                                     bool linked = false) noexcept;
 
        static IoOperation makeWrite (int fd, const void* buf, uint32_t len, CompletionHandler* handler,
                                      bool linked = false) noexcept;
 
        static IoOperation makeReadFixed (int fd, void* buf, uint32_t len, uint16_t index, CompletionHandler* handler,
                                          bool linked = false) noexcept;
 
        static IoOperation makeWriteFixed (int fd, const void* buf, uint32_t len, uint16_t index,
                                           CompletionHandler* handler, bool linked = false) noexcept;
 
        struct MsgData
        {
            int fd;
 
            msghdr* msg;
 
            int flags;
        };
 
        static IoOperation makeRecvmsg (int fd, msghdr* msg, int flags, CompletionHandler* handler,
                                        bool linked = false) noexcept;
 
        static IoOperation makeSendmsg (int fd, const msghdr* msg, int flags, CompletionHandler* handler,
                                        bool linked = false) noexcept;
 
        struct StreamData
        {
            int fd;
 
            void* buf;
 
            unsigned long len;
 
            int flags;
        };
 
        static IoOperation makeRecv (int fd, void* buf, uint32_t len, int flags, CompletionHandler* handler,
                                     bool linked = false) noexcept;
 
        static IoOperation makeSend (int fd, const void* buf, uint32_t len, int flags, CompletionHandler* handler,
                                     bool linked = false) noexcept;
 
        union Data
        {
            AcceptData accept;
            ConnectData connect;
            RwData rw;
            MsgData msg;
            StreamData stream;
        };
 
        int fd () const noexcept;
 
        uint8_t code = 0;
 
        State state = State::Idle;
 
        uint32_t index = 0;
 
        bool linked = false;
 
        CompletionHandler* handler = nullptr;
 
        Data data = {};
    };
}
 
#endif