processing_function()

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

overridevirtual

Extract the current frame from the container into the TextureBuffer.

Triggers the container's default processor if needed, extracts the processed uint8_t RGBA data, and copies it into the TextureBuffer's pixel storage via set_pixel_data().

Parameters

buffer

The TextureBuffer to write pixels into.

Implements MayaFlux::Buffers::BufferProcessor.

Definition at line 71 of file VideoContainerBuffer.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(0)) {
                    m_container->process_default();
                }
            }
        }
 
        auto texture_buffer = std::dynamic_pointer_cast<TextureBuffer>(buffer);
        if (!texture_buffer) {
            return;
        }
 
        extract_frame_data(texture_buffer);
 
        if (m_update_flags) {
            buffer->mark_for_processing(true);
        }
 
        m_container->mark_dimension_consumed(0, m_reader_id);
 
        if (m_container->all_dimensions_consumed()) {
            m_container->update_processing_state(Kakshya::ProcessingState::READY);
            m_container->reset_processing_token();
        }
 
    } catch (const std::exception& e) {
        MF_ERROR(Journal::Component::Buffers, Journal::Context::BufferProcessing,
            "VideoStreamReader: Error during processing: {}", e.what());
    }
}

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

Here is the call graph for this function: