udpsockettransport.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <promeki/namespace.h>
#include <promeki/packettransport.h>
#include <promeki/socketaddress.h>
#include <promeki/string.h>
#include <promeki/udpsocket.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class UdpSocketTransport : public PacketTransport {
        public:
                using UPtr = UniquePtr<UdpSocketTransport>;
 
                UdpSocketTransport();
 
                ~UdpSocketTransport() override;
 
                void setLocalAddress(const SocketAddress &addr) { _localAddress = addr; }
 
                const SocketAddress &localAddress() const { return _localAddress; }
 
                void setIpv6(bool enable) { _ipv6 = enable; }
 
                bool isIpv6() const { return _ipv6; }
 
                void setDscp(uint8_t dscp) { _dscp = dscp; }
 
                uint8_t dscp() const { return _dscp; }
 
                void setMulticastTTL(int ttl) { _multicastTTL = ttl; }
 
                int multicastTTL() const { return _multicastTTL; }
 
                void setMulticastInterface(const String &iface) { _multicastInterface = iface; }
 
                const String &multicastInterface() const { return _multicastInterface; }
 
                void setBindInterface(const String &iface) { _bindInterface = iface; }
 
                const String &bindInterface() const { return _bindInterface; }
 
                void setMulticastLoopback(bool enable) { _multicastLoopback = enable; }
 
                bool multicastLoopback() const { return _multicastLoopback; }
 
                void setReuseAddress(bool enable) { _reuseAddress = enable; }
 
                bool reuseAddress() const { return _reuseAddress; }
 
                void setDontFragment(bool enable) { _dontFragment = enable; }
 
                bool dontFragment() const { return _dontFragment; }
 
                void setReceiveBufferSize(int bytes) { _recvBufferSize = bytes; }
 
                int receiveBufferSize() const { return _recvBufferSize; }
 
                void setSendBufferSize(int bytes) { _sendBufferSize = bytes; }
 
                int sendBufferSize() const { return _sendBufferSize; }
 
                UdpSocket *socket() const { return _socket.get(); }
 
                Error open() override;
 
                void close() override;
 
                bool isOpen() const override;
 
                ssize_t sendPacket(const void *data, size_t size, const SocketAddress &dest) override;
 
                int sendPackets(const DatagramList &datagrams) override;
 
                ssize_t receivePacket(void *data, size_t maxSize, SocketAddress *sender = nullptr) override;
 
                Error setPacingRate(uint64_t bytesPerSec) override;
 
                Error setTxTime(bool enable) override;
 
        private:
                UdpSocket::UPtr _socket;
                SocketAddress   _localAddress;
                String          _multicastInterface;
                String          _bindInterface;
                int             _recvBufferSize = 0;
                int             _sendBufferSize = 0;
                uint8_t         _dscp = 0;
                int             _multicastTTL = 0;
                bool            _ipv6 = false;
                bool            _reuseAddress = false;
                bool            _multicastLoopback = false;
                bool            _dontFragment = false;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK