send_to()

bool MayaFlux::Core::UDPBackend::send_to ( uint64_t  endpoint_id, const uint8_t *  data, size_t  size, const std::string &  address, uint16_t  port  )

overridevirtual

Send data to a specific address through an endpoint.

Parameters

endpoint_id	Source endpoint (must be open).
data	Pointer to payload bytes.
size	Payload size in bytes.
address	Target address string.
port	Target port.

Returns

true if the send was accepted.

Primary use: UDP (send to arbitrary peer via bound socket). TCP: ignored, uses connected peer. SHM: ignored.

Implements MayaFlux::Core::INetworkBackend.

Definition at line 217 of file UDPBackend.cpp.

{
    std::shared_lock lock(m_endpoints_mutex);
    auto it = m_endpoints.find(endpoint_id);
    if (it == m_endpoints.end()) {
        return false;
    }
 
    asio::error_code ec;
    auto addr = asio::ip::make_address(address, ec);
    if (ec) {
        MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
            "Invalid send_to address '{}': {}", address, ec.message());
        return false;
    }
 
    asio::ip::udp::endpoint target(addr, port);
    auto buf = std::make_shared<std::vector<uint8_t>>(data, data + size);
    auto& socket = it->second.socket_state->socket;
 
    socket.async_send_to(
        asio::buffer(*buf), target,
        [buf, endpoint_id](const asio::error_code& send_ec, size_t) {
            if (send_ec) {
                MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                    "UDP send_to failed on endpoint {}: {}", endpoint_id, send_ec.message());
            }
        });
 
    return true;
}

References MayaFlux::Journal::Core, m_endpoints, m_endpoints_mutex, MF_WARN, MayaFlux::Journal::NetworkBackend, and size.