on_receive()

void MayaFlux::Core::UDPBackend::on_receive ( SocketState &  state, const asio::error_code &  ec, size_t  bytes_received  )

private

Completion handler for async_receive_from.

Fires the receive callback with the endpoint id resolved from the sender address, then resubmits async_receive_from.

Definition at line 363 of file UDPBackend.cpp.

{
    if (ec) {
        if (ec == asio::error::operation_aborted) {
            return;
        }
        MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
            "UDP receive error on port {}: {}", state.local_port, ec.message());
        start_receive_loop(state);
        return;
    }
 
    if (m_receive_callback && bytes_received > 0) {
        std::string sender_str = state.sender_endpoint.address().to_string()
            + ":" + std::to_string(state.sender_endpoint.port());
 
        std::shared_lock lock(m_endpoints_mutex);
        for (const auto& [id, record] : m_endpoints) {
            if (record.socket_state->local_port == state.local_port
                && record.info.role != EndpointRole::SEND) {
                m_receive_callback(id, state.recv_buffer.data(), bytes_received, sender_str);
            }
        }
    }
 
    start_receive_loop(state);
}

References MayaFlux::Journal::Core, MayaFlux::Core::UDPBackend::SocketState::local_port, m_endpoints, m_endpoints_mutex, m_receive_callback, MF_WARN, MayaFlux::Journal::NetworkBackend, MayaFlux::Core::UDPBackend::SocketState::recv_buffer, MayaFlux::Core::SEND, MayaFlux::Core::UDPBackend::SocketState::sender_endpoint, and start_receive_loop().

Here is the call graph for this function: