start_receive_chain()

void MayaFlux::Core::TCPBackend::start_receive_chain ( ConnectionState &  conn )

private

Start the framed message receive chain on a connection.

Posts async_read for 4-byte header. Completion parses length, posts async_read for payload. Completion fires receive callback, then resubmits header read.

Definition at line 468 of file TCPBackend.cpp.

{
    asio::async_read(
        conn.socket,
        asio::buffer(conn.header_buf),
        [this, ep_id = conn.info.id](const asio::error_code& 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_header_received(*it->second, ec, bytes);
        });
}

References MayaFlux::Core::TCPBackend::ConnectionState::header_buf, MayaFlux::Core::EndpointInfo::id, MayaFlux::Core::TCPBackend::ConnectionState::info, and MayaFlux::Core::TCPBackend::ConnectionState::socket.