processing_function()

void MayaFlux::Buffers::AggregateBindingsProcessor::processing_function ( std::shared_ptr< Buffer >  buffer )

overridevirtual

BufferProcessor interface - uploads all aggregates.

Parameters

buffer

The buffer this processor is attached to

Implements MayaFlux::Buffers::BufferProcessor.

Definition at line 136 of file AggregateBindingsProcessor.cpp.

{
    if (m_aggregates.empty()) {
        return;
    }
 
    auto vk_buffer = std::dynamic_pointer_cast<VKBuffer>(buffer);
    if (!vk_buffer) {
        MF_RT_ERROR(Journal::Component::Buffers, Journal::Context::BufferProcessing,
            "AggregateBindingsProcessor requires VKBuffer, got different buffer type");
        return;
    }
 
    for (auto& [aggregate_name, aggregate] : m_aggregates) {
        if (aggregate.nodes.empty()) {
            continue;
        }
 
        for (size_t i = 0; i < aggregate.nodes.size(); i++) {
            aggregate.staging_data[i] = static_cast<float>(
                aggregate.nodes[i]->get_last_output());
        }
 
        upload_to_gpu(
            aggregate.staging_data.data(),
            aggregate.staging_data.size() * sizeof(float),
            aggregate.target_buffer);
    }
 
    bool attached_is_target = false;
    for (const auto& [name, aggregate] : m_aggregates) {
        if (aggregate.target_buffer == vk_buffer) {
            attached_is_target = true;
            break;
        }
    }
 
    if (!attached_is_target && !m_aggregates.empty()) {
        auto& first_aggregate = m_aggregates.begin()->second;
 
        if (!first_aggregate.nodes.empty()) {
            upload_to_gpu(
                first_aggregate.staging_data.data(),
                first_aggregate.staging_data.size() * sizeof(float),
                vk_buffer);
        }
    }
}

References MayaFlux::Journal::BufferProcessing, MayaFlux::Journal::Buffers, m_aggregates, MF_RT_ERROR, and MayaFlux::Buffers::upload_to_gpu().

Here is the call graph for this function: