UnixClientSocket.hxx

#pragma once
 
// cosmos
#include <cosmos/net/UnixConnection.hxx>
#include <cosmos/net/UnixOptions.hxx>
 
namespace cosmos {
 
 
class COSMOS_API UnixClientSocket :
                public Socket {
public: // types
 
        using Connection = UnixConnection;
 
public: // functions
 
        explicit UnixClientSocket(const SocketType type, const SocketFlags flags = SocketFlags{SocketFlag::CLOEXEC});
 
        auto unixOptions() {
                return UnixOptions{this->m_fd};
        }
 
        auto unixOptions() const {
                return UnixOptions{this->m_fd};
        }
 
        void getSockName(UnixAddress &addr) {
                Socket::getSockName(addr);
        }
 
 
        void bind(const UnixAddress &addr) {
                return Socket::bind(addr);
        }
 
 
        UnixConnection connect(const UnixAddress &addr) {
                Socket::connect(addr);
                auto ret = UnixConnection{this->m_fd};
                this->m_fd.reset();
                return ret;
        }
 
protected:
 
        using StreamIO::read;
        using StreamIO::readAll;
        using StreamIO::write;
        using StreamIO::writeAll;
};
 
class UnixStreamClientSocket :
                public UnixClientSocket {
public: // types
 
        static inline constexpr auto TYPE = SocketType::STREAM;
 
public: // functions
 
        explicit UnixStreamClientSocket(const SocketFlags flags = SocketFlags{SocketFlag::CLOEXEC}) :
                        UnixClientSocket{TYPE, flags} {}
};
 
class UnixSeqPacketClientSocket :
                public UnixClientSocket {
public: // types
 
        static inline constexpr auto TYPE = SocketType::SEQPACKET;
 
public: // functions
 
        explicit UnixSeqPacketClientSocket(const SocketFlags flags = SocketFlags{SocketFlag::CLOEXEC}) :
                        UnixClientSocket{TYPE, flags} {}
};
 
} // end ns