process_transform()

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

private

Definition at line 98 of file BufferPipelineOperations.cpp.

{
    auto selected = select_operation_data(m_operation_data, op, !m_readers.empty());
    if (!selected) {
        return;
    }
    auto input_data = std::move(*selected);
 
    if (op.m_transformer) {
        auto transformed = op.m_transformer(input_data, cycle);
        m_operation_data[&op] = transformed;
 
        const bool has_downstream_route = std::ranges::any_of(
            m_operations,
            [](const BufferOperation& o) {
                return o.get_type() == BufferOperation::OpType::ROUTE;
            });
 
        if (!has_downstream_route) {
            for (auto& candidate : std::ranges::reverse_view(m_operations)) {
                if (&candidate == &op)
                    continue;
                if (candidate.get_type() != BufferOperation::OpType::CAPTURE) {
                    continue;
                }
 
                if (const auto buf = candidate.m_capture.get_audio_buffer()) {
                    if (std::holds_alternative<std::vector<double>>(transformed)
                        && std::get<std::vector<double>>(transformed).size() == buf->get_data().size()) {
                        detail::write_to_buffer(buf, transformed);
                    }
                    break;
                }
 
                if (const auto target = candidate.m_capture.get_graphics_buffer()) {
                    const auto captured = m_operation_data.find(&candidate);
                    if (captured != m_operation_data.end()
                        && detail::accepts_raw_write(target)
                        && same_extent(captured->second, transformed)) {
                        queue_graphics_write(op, target, transformed);
                    }
                    break;
                }
            }
        }
    }
}

References MayaFlux::Kriya::detail::accepts_raw_write(), MayaFlux::Kriya::BufferOperation::CAPTURE, MayaFlux::Kriya::BufferOperation::get_type(), m_operation_data, m_operations, m_readers, MayaFlux::Kriya::BufferOperation::m_transformer, queue_graphics_write(), MayaFlux::Kriya::BufferOperation::ROUTE, size, and MayaFlux::Kriya::detail::write_to_buffer().

Referenced by process_operation().

Here is the call graph for this function:

Here is the caller graph for this function: