process_route()

void MayaFlux::Kriya::BufferPipeline::process_route ( BufferOperation &  op )

private

Definition at line 146 of file BufferPipelineOperations.cpp.

{
    if (!op.m_source_images.empty()) {
        uint32_t layer = 0;
        for (const auto& image : op.m_source_images) {
            detail::write_layer(op.m_target_graphics_buffer, layer++, image);
        }
        return;
    }
 
    if (op.m_source_graphics_buffer) {
        auto frame = read_graphics_buffer(op, op.m_source_graphics_buffer);
        if (!frame) {
            return;
        }
 
        detail::write_to_container(op.m_target_graphics_stream, *frame);
        m_operation_data[&op] = std::move(*frame);
        return;
    }
 
    const auto selected = select_operation_data(m_operation_data, op, !m_readers.empty());
    if (!selected) {
        return;
    }
    const auto& data_to_route = *selected;
 
    if (op.m_target_audio_buffer) {
        if (!m_buffer_manager) {
            error<std::invalid_argument>(Journal::Component::Kriya,
                Journal::Context::CoroutineScheduling,
                std::source_location::current(),
                "BufferPipeline has no BufferManager for ROUTE-to-buffer operation");
        }
 
        if (!op.m_attached_processor) {
            auto writer = std::make_shared<Buffers::AudioWriteProcessor>();
            m_buffer_manager->add_processor(writer, op.m_target_audio_buffer,
                Buffers::ProcessingToken::AUDIO_BACKEND);
            op.m_attached_processor = writer;
        }
 
        std::static_pointer_cast<Buffers::AudioWriteProcessor>(op.m_attached_processor)
            ->set_data(data_to_route);
 
    } else if (op.m_target_graphics_buffer) {
        queue_graphics_write(op, op.m_target_graphics_buffer, data_to_route);
 
    } else if (op.m_target_audio_stream) {
        detail::write_to_container(op.m_target_audio_stream, data_to_route, op.m_target_audio_channel);
 
    } else if (op.m_target_graphics_stream) {
        detail::write_to_container(op.m_target_graphics_stream, data_to_route);
    }
}

References MayaFlux::Buffers::AUDIO_BACKEND, MayaFlux::Journal::CoroutineScheduling, image, MayaFlux::Journal::Kriya, MayaFlux::Kriya::BufferOperation::m_attached_processor, m_buffer_manager, m_operation_data, m_readers, MayaFlux::Kriya::BufferOperation::m_source_graphics_buffer, MayaFlux::Kriya::BufferOperation::m_source_images, 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, queue_graphics_write(), read_graphics_buffer(), MayaFlux::Kriya::detail::write_layer(), 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: