processing_function()

void MayaFlux::Buffers::AggregateBindingsProcessor::processing_function ( const 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 138 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;
        }
 
        auto& target = aggregate.target_buffer ? aggregate.target_buffer : vk_buffer;
 
        ProcessingMode mode = aggregate.processing_mode.load(std::memory_order_acquire);
 
        for (size_t i = 0; i < aggregate.nodes.size(); ++i) {
            if (!aggregate.nodes[i]) {
                MF_RT_ERROR(Journal::Component::Buffers, Journal::Context::BufferProcessing,
                    "Aggregate '{}' node at index {} is null", aggregate_name, i);
                aggregate.staging_data[i] = 0.0F;
                continue;
            }
 
            double value = (mode == ProcessingMode::INTERNAL)
                ? Buffers::extract_single_sample(aggregate.nodes[i])
                : aggregate.nodes[i]->get_last_output();
 
            aggregate.staging_data[i] = static_cast<float>(value);
        }
 
        upload_to_gpu(
            aggregate.staging_data.data(),
            aggregate.staging_data.size() * sizeof(float),
            target);
    }
}

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

Here is the call graph for this function: