send()

bool MayaFlux::Core::UDPBackend::send ( uint64_t  endpoint_id, const uint8_t *  data, size_t  size  )

overridevirtual

Send data through an endpoint.

Parameters

endpoint_id	Target endpoint.
data	Pointer to payload bytes.
size	Payload size in bytes.

Returns

true if the send was accepted (queued or completed).

For UDP: sends a single datagram via sendto(). Non-blocking. For TCP: writes framed message. May block briefly if kernel send buffer is full. For SHM: writes into the shared segment.

Implements MayaFlux::Core::INetworkBackend.

Definition at line 186 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;
    }
 
    auto& record = it->second;
    if (!record.has_default_remote) {
        MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
            "UDP endpoint {} has no default remote target", endpoint_id);
        return false;
    }
 
    auto buf = std::make_shared<std::vector<uint8_t>>(data, data + size);
    auto remote = record.default_remote;
    auto& socket = record.socket_state->socket;
 
    socket.async_send_to(
        asio::buffer(*buf), remote,
        [buf, endpoint_id](const asio::error_code& ec, size_t /*bytes_sent*/) {
            if (ec) {
                MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                    "UDP send failed on endpoint {}: {}", endpoint_id, ec.message());
            }
        });
 
    return true;
}

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