processing_function()

void MayaFlux::Buffers::ClaimAccumulateProcessor::processing_function ( const std::shared_ptr< Buffer > &  buffer )

overrideprotectedvirtual

Dispatch as usual, then conditionally read back the result.

Implements MayaFlux::Buffers::BufferProcessor.

Definition at line 407 of file MutationClaimProcessor.cpp.

{
    NetworkStateFieldProcessor::processing_function(buffer);
 
    auto network_buffer = get_network_buffer();
    if (!network_buffer || !m_physics_op) {
        return;
    }
 
    uint32_t claim_events = 0;
    download_back_buffer(
        network_buffer->read_state_slot("mutation_claim_events"),
        &claim_events, sizeof(claim_events), m_readback_staging);
 
    if (claim_events == 0u) {
        m_physics_op->clear_bonds();
    } else {
        m_claimed_by_readback.resize(m_params.particle_count);
        download_back_buffer(
            network_buffer->read_state_slot("mutation_claimed_by"),
            m_claimed_by_readback.data(),
            m_claimed_by_readback.size() * sizeof(uint32_t),
            m_readback_staging);
 
        m_physics_op->sync_bonds_from_claims(
            std::span<const uint32_t>(m_claimed_by_readback).first(m_live_count));
    }
 
    auto accreted_mass = m_physics_op->get_accreted_mass_span();
    if (!accreted_mass.empty()) {
        if (m_live_count == m_params.particle_count) {
            upload_back_buffer(
                network_buffer->write_state_slot("mutation_accreted_mass"),
                accreted_mass.data(),
                accreted_mass.size() * sizeof(float),
                m_upload_staging);
        } else {
            m_accreted_mass_padded.assign(m_params.particle_count, 0.0F);
            std::copy_n(accreted_mass.begin(),
                std::min<size_t>(accreted_mass.size(), m_live_count),
                m_accreted_mass_padded.begin());
            upload_back_buffer(
                network_buffer->write_state_slot("mutation_accreted_mass"),
                m_accreted_mass_padded.data(),
                m_accreted_mass_padded.size() * sizeof(float),
                m_upload_staging);
        }
    }
}

References MayaFlux::Nodes::Network::PhysicsOperator::clear_bonds(), MayaFlux::Buffers::download_back_buffer(), MayaFlux::Nodes::Network::PhysicsOperator::get_accreted_mass_span(), MayaFlux::Buffers::NetworkStateFieldProcessor::get_network_buffer(), m_accreted_mass_padded, m_claimed_by_readback, m_live_count, m_params, m_physics_op, m_readback_staging, m_upload_staging, MayaFlux::Buffers::ClaimAccumulateProcessor::Params::particle_count, MayaFlux::Buffers::NetworkStateFieldProcessor::processing_function(), MayaFlux::Nodes::Network::PhysicsOperator::sync_bonds_from_claims(), and MayaFlux::Buffers::upload_back_buffer().

Here is the call graph for this function: