CConnectorSocket.hpp

Go to the documentation of this file.

#ifndef LIBS_COMM_CCONNECTORSOCKET_HPP_
#define LIBS_COMM_CCONNECTORSOCKET_HPP_
 
#include "comms/socket/CStreamSocket.hpp"
 
class CConnectorSocket : public CStreamSocket
{
public:
    CConnectorSocket() = default;
    CConnectorSocket(const CConnectorSocket &) = delete;
    CConnectorSocket &operator=(const CConnectorSocket &) = delete;
 
    explicit CConnectorSocket(const CSocketAddress &address)
    {
        connect(address);
    }
 
    CConnectorSocket(CConnectorSocket &&conn) noexcept : CStreamSocket(std::move(conn))
    {
    }
 
    CConnectorSocket &operator=(CConnectorSocket &&rhs) noexcept
    {
        CStreamSocket::operator=(std::move(rhs));
 
        return *this;
    }
 
    bool connect(const CSocketAddress &address, int32_t milliseconds = defaultConnectionTimeoutMs);
 
    bool isConnected() const
    {
        return isOpen();
    }
 
private:
    static constexpr int32_t defaultConnectionTimeoutMs = 1000;
    bool prv_setTimeOut(socket_t fd, int32_t milliseconds);
};
 
template<typename STREAM_SOCK, typename ADDR = typename STREAM_SOCK::addr_t>
class CConnectorSocketTmpl final : public CConnectorSocket
{
public:
    using stream_sock_t = STREAM_SOCK;
    using addr_t = ADDR;
 
    CConnectorSocketTmpl() = default;
    CConnectorSocketTmpl(const CConnectorSocketTmpl &) = delete;
    CConnectorSocketTmpl &operator=(const CConnectorSocketTmpl &) = delete;
 
    explicit CConnectorSocketTmpl(const addr_t &address) : CConnectorSocket(address)
    {
    }
 
    CConnectorSocketTmpl &operator=(CConnectorSocketTmpl &&rhs) noexcept
    {
        CConnectorSocket::operator=(std::move(rhs));
 
        return *this;
    }
 
    bool connect(const addr_t &address)
    {
        return CConnectorSocket::connect(address);
    }
 
    addr_t getOwnAddress() const
    {
        return addr_t(CConnectorSocket::getAddress());
    }
 
    addr_t getPeerAddr() const
    {
        return addr_t(CConnectorSocket::getPeerAddress());
    }
};
 
#endif /* LIBS_COMM_CCONNECTORSOCKET_HPP_ */