serial::vita49::UdpSender Class Reference

#include "udp_sender.h"

Inheritance diagram for serial::vita49::UdpSender:

Collaboration diagram for serial::vita49::UdpSender:

Public Member Functions
	UdpSender ()=default
	~UdpSender () override
	UdpSender (const UdpSender &)=delete
UdpSender &	operator= (const UdpSender &)=delete
	UdpSender (UdpSender &&other) noexcept
UdpSender &	operator= (UdpSender &&other) noexcept
void	open (const std::string &host, std::uint16_t port) override
void	send (std::span< const std::uint8_t > bytes) override
void	close () noexcept override

Detailed Description

Definition at line 26 of file udp_sender.h.

Constructor & Destructor Documentation

UdpSender() [1/3]

serial::vita49::UdpSender::UdpSender ( )

default

~UdpSender()

serial::vita49::UdpSender::~UdpSender ( )

override

Definition at line 42 of file udp_sender.cpp.

{ close(); }

References close().

Here is the call graph for this function:

UdpSender() [2/3]

serial::vita49::UdpSender::UdpSender ( const UdpSender &  )

delete

UdpSender() [3/3]

serial::vita49::UdpSender::UdpSender ( UdpSender &&  other )

noexcept

Definition at line 44 of file udp_sender.cpp.

                                                   :
        _socket(other._socket), _address(std::move(other._address)), _address_size(other._address_size)
    {
        other._socket = -1;
        other._address_size = 0;
    }

References max.

Member Function Documentation

close()

void serial::vita49::UdpSender::close ( )

overridevirtualnoexcept

Implements serial::vita49::DatagramSender.

Definition at line 147 of file udp_sender.cpp.

    {
        if (_socket >= 0)
        {
#ifdef _WIN32
            ::closesocket(_socket);
            WSACleanup();
#else
            ::close(_socket);
#endif
            _socket = -1;
        }
        _address.reset();
        _address_size = 0;
    }

References close(), and max.

Referenced by close(), open(), and ~UdpSender().

Here is the call graph for this function:

Here is the caller graph for this function:

open()

void serial::vita49::UdpSender::open ( const std::string &  host, std::uint16_t  port  )

overridevirtual

Implements serial::vita49::DatagramSender.

Definition at line 65 of file udp_sender.cpp.

    {
        close();
        if (host.empty() || port == 0)
        {
            throw std::invalid_argument("VITA UDP destination requires non-empty host and non-zero port");
        }
 
#ifdef _WIN32
        WSADATA wsa_data;
        if (WSAStartup(MAKEWORD(2, 2), &wsa_data) != 0)
        {
            throw std::runtime_error("WSAStartup failed for VITA UDP sender");
        }
#endif
 
        addrinfo hints{};
        hints.ai_family = AF_UNSPEC;
        hints.ai_socktype = SOCK_DGRAM;
        hints.ai_protocol = IPPROTO_UDP;
 
        addrinfo* result = nullptr;
        const auto port_string = std::to_string(port);
        const int gai = getaddrinfo(host.c_str(), port_string.c_str(), &hints, &result);
        if (gai != 0)
        {
            throw std::runtime_error("VITA UDP destination resolution failed: " + host + ":" + port_string);
        }
        std::unique_ptr<addrinfo, decltype(&freeaddrinfo)> const result_guard(result, freeaddrinfo);
 
        for (auto* candidate = result; candidate != nullptr; candidate = candidate->ai_next)
        {
#ifdef _WIN32
            const int fd =
                static_cast<int>(::socket(candidate->ai_family, candidate->ai_socktype, candidate->ai_protocol));
#else
            const int fd = ::socket(candidate->ai_family, candidate->ai_socktype, candidate->ai_protocol);
#endif
            if (fd < 0)
            {
                continue;
            }
 
            tuneSendBuffer(fd);
            _socket = fd;
            _address_size = candidate->ai_addrlen;
            auto storage = std::make_unique<std::byte[]>(_address_size);
            std::memcpy(storage.get(), candidate->ai_addr, _address_size);
            _address = std::move(storage);
            return;
        }
 
        throw std::runtime_error("VITA UDP socket creation failed");
    }

References close(), and max.

Here is the call graph for this function:

operator=() [1/2]

UdpSender & serial::vita49::UdpSender::operator= ( const UdpSender &  )

delete

operator=() [2/2]

UdpSender & serial::vita49::UdpSender::operator= ( UdpSender &&  other )

noexcept

Definition at line 51 of file udp_sender.cpp.

    {
        if (this != &other)
        {
            close();
            _socket = other._socket;
            _address = std::move(other._address);
            _address_size = other._address_size;
            other._socket = -1;
            other._address_size = 0;
        }
        return *this;
    }

References max.

send()

void serial::vita49::UdpSender::send ( std::span< const std::uint8_t >  bytes )

overridevirtual

Implements serial::vita49::DatagramSender.

Definition at line 120 of file udp_sender.cpp.

    {
        if (_socket < 0 || _address == nullptr)
        {
            throw std::runtime_error("VITA UDP sender is not open");
        }
        if (bytes.empty())
        {
            return;
        }
 
#ifdef _WIN32
        const auto* payload = std::bit_cast<const char*>(bytes.data());
        const auto sent = ::sendto(_socket, payload, static_cast<int>(bytes.size()), 0,
                                   static_cast<const sockaddr*>(static_cast<const void*>(_address.get())),
                                   static_cast<int>(_address_size));
#else
        const auto sent = ::sendto(_socket, bytes.data(), bytes.size(), 0,
                                   static_cast<const sockaddr*>(static_cast<const void*>(_address.get())),
                                   static_cast<socklen_t>(_address_size));
#endif
        if (sent < 0 || static_cast<std::size_t>(sent) != bytes.size())
        {
            throw std::runtime_error("VITA UDP send failed");
        }
    }

References max.

---

The documentation for this class was generated from the following files:

• packages/libfers/src/serial/vita49/udp_sender.h
• packages/libfers/src/serial/vita49/udp_sender.cpp