on_header_received()

void MayaFlux::Core::TCPBackend::on_header_received ( ConnectionState &  conn, const asio::error_code &  ec, size_t  bytes  )

private

Header read completion handler.

Definition at line 479 of file TCPBackend.cpp.

{
    if (ec) {
        on_connection_error(conn, ec);
        return;
    }
 
    uint32_t net_len {};
    std::memcpy(&net_len, conn.header_buf.data(), sizeof(uint32_t));
    uint32_t payload_size = ntohl(net_len);
 
    if (payload_size == 0 || payload_size > 64 * 1024 * 1024) {
        MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
            "TCP endpoint {} received invalid frame length: {}",
            conn.info.id, payload_size);
        on_connection_error(conn, asio::error::message_size);
        return;
    }
 
    conn.payload_buf.resize(payload_size);
 
    asio::async_read(
        conn.socket,
        asio::buffer(conn.payload_buf),
        [this, ep_id = conn.info.id](const asio::error_code& read_ec, size_t bytes) {
            std::shared_lock lock(m_connections_mutex);
            auto it = m_connections.find(ep_id);
            if (it == m_connections.end()) {
                return;
            }
            on_payload_received(*it->second, read_ec, bytes);
        });
}

References MayaFlux::Journal::Core, MayaFlux::Core::TCPBackend::ConnectionState::header_buf, MayaFlux::Core::EndpointInfo::id, MayaFlux::Core::TCPBackend::ConnectionState::info, MF_WARN, MayaFlux::Journal::NetworkBackend, MayaFlux::Core::TCPBackend::ConnectionState::payload_buf, and MayaFlux::Core::TCPBackend::ConnectionState::socket.