processing_function()

void MayaFlux::Buffers::SoundStreamReader::processing_function ( const std::shared_ptr< Buffer > &  buffer )

overridevirtual

Extracts and processes data from the container into the target AudioBuffer.

Handles dimension mapping, position tracking, and state synchronization.

Parameters

buffer

The AudioBuffer to fill.

Implements MayaFlux::Buffers::BufferProcessor.

Definition at line 25 of file SoundContainerBuffer.cpp.

{
    if (!m_container || !buffer) {
        return;
    }
 
    if (m_container->is_at_end()) {
        buffer->mark_for_removal();
        return;
    }
 
    try {
        auto state = m_container->get_processing_state();
 
        if (state == Kakshya::ProcessingState::NEEDS_REMOVAL) {
            if (m_update_flags) {
                buffer->mark_for_removal();
            }
            return;
        }
 
        if (state != Kakshya::ProcessingState::PROCESSED) {
            if (state == Kakshya::ProcessingState::READY) {
                if (m_container->try_acquire_processing_token(m_source_channel)) {
                    m_container->process_default();
                }
            }
        }
 
        auto audio_buffer = std::dynamic_pointer_cast<AudioBuffer>(buffer);
        auto& buffer_data = audio_buffer->get_data();
        uint32_t buffer_size = audio_buffer->get_num_samples();
 
        auto read_positions = m_container->get_read_position();
        uint64_t current_pos = (m_source_channel < read_positions.size())
            ? read_positions[m_source_channel]
            : 0;
 
        if (buffer_data.size() != buffer_size) {
            buffer_data.resize(buffer_size);
        }
 
        extract_channel_data(buffer_data);
 
        if (m_auto_advance) {
            m_container->update_read_position_for_channel(m_source_channel, current_pos + buffer_size);
        }
 
        if (m_update_flags) {
            buffer->mark_for_processing(true);
        }
 
        m_container->mark_dimension_consumed(m_source_channel, m_reader_id);
 
        if (m_container->all_dimensions_consumed()) {
            m_container->update_processing_state(Kakshya::ProcessingState::READY);
            std::dynamic_pointer_cast<Kakshya::SoundFileContainer>(m_container)->clear_all_consumption();
            m_container->reset_processing_token();
        }
 
    } catch (const std::exception& e) {
        MF_ERROR(Journal::Component::Buffers, Journal::Context::BufferProcessing,
            "SoundStreamReader: Error during processing: {}", e.what());
    }
}

References MayaFlux::Journal::BufferProcessing, MayaFlux::Journal::Buffers, extract_channel_data(), m_auto_advance, m_container, m_reader_id, m_source_channel, m_update_flags, MF_ERROR, MayaFlux::Kakshya::NEEDS_REMOVAL, MayaFlux::Kakshya::PROCESSED, and MayaFlux::Kakshya::READY.

Here is the call graph for this function: