process_fuse()

void MayaFlux::Kriya::BufferPipeline::process_fuse ( BufferOperation &  op, uint64_t  cycle  )

private

Definition at line 217 of file BufferPipelineOperations.cpp.

{
    std::vector<Kakshya::DataVariant> fusion_inputs;
 
    for (auto& source_buffer : op.m_source_audio_buffers) {
        bool should_process = op.m_capture.get_processing_control() == BufferCapture::ProcessingControl::ON_CAPTURE;
        auto buffer_data = detail::extract_buffer_data(source_buffer, should_process);
        fusion_inputs.push_back(buffer_data);
    }
 
    for (auto& source_container : op.m_source_audio_streams) {
        auto container_data = detail::read_from_container(source_container, 0, 0);
        fusion_inputs.push_back(container_data);
    }
 
    bool graphics_ready = true;
    for (auto& source_buffer : op.m_source_graphics_buffers) {
        if (auto buffer_data = read_graphics_buffer(op, source_buffer)) {
            fusion_inputs.push_back(std::move(*buffer_data));
        } else {
            graphics_ready = false;
        }
    }
 
    if (!graphics_ready) {
        return;
    }
 
    for (auto& source_container : op.m_source_graphics_streams) {
        fusion_inputs.push_back(detail::read_from_container(source_container, 0, 0));
    }
 
    if (op.m_fusion_function && !fusion_inputs.empty()) {
        auto fused_data = op.m_fusion_function(fusion_inputs, cycle);
 
        if (op.m_target_audio_buffer) {
            detail::write_to_buffer(op.m_target_audio_buffer, fused_data);
        } else if (op.m_target_graphics_buffer) {
            queue_graphics_write(op, op.m_target_graphics_buffer, fused_data);
        } else if (op.m_target_audio_stream) {
            detail::write_to_container(op.m_target_audio_stream, fused_data, op.m_target_audio_channel);
        } else if (op.m_target_graphics_stream) {
            detail::write_to_container(op.m_target_graphics_stream, fused_data);
        }
 
        m_operation_data[&op] = fused_data;
    }
}

References MayaFlux::Kriya::detail::extract_buffer_data(), MayaFlux::Kriya::BufferCapture::get_processing_control(), MayaFlux::Kriya::BufferOperation::m_capture, MayaFlux::Kriya::BufferOperation::m_fusion_function, m_operation_data, MayaFlux::Kriya::BufferOperation::m_source_audio_buffers, MayaFlux::Kriya::BufferOperation::m_source_audio_streams, MayaFlux::Kriya::BufferOperation::m_source_graphics_buffers, MayaFlux::Kriya::BufferOperation::m_source_graphics_streams, MayaFlux::Kriya::BufferOperation::m_target_audio_buffer, MayaFlux::Kriya::BufferOperation::m_target_audio_channel, MayaFlux::Kriya::BufferOperation::m_target_audio_stream, MayaFlux::Kriya::BufferOperation::m_target_graphics_buffer, MayaFlux::Kriya::BufferOperation::m_target_graphics_stream, MayaFlux::Kriya::BufferCapture::ON_CAPTURE, queue_graphics_write(), MayaFlux::Kriya::detail::read_from_container(), read_graphics_buffer(), MayaFlux::Kriya::detail::write_to_buffer(), and MayaFlux::Kriya::detail::write_to_container().

Referenced by process_operation().

Here is the call graph for this function:

Here is the caller graph for this function: