process()

void MayaFlux::Buffers::BufferProcessor::process

(

const std::shared_ptr< Buffer > &

buffer

)

Applies a computational transformation to the data in the provided buffer.

Parameters

buffer

Buffer to transform

This is the main transformation method that must be implemented by all concrete processor classes. It applies the processor's algorithm to the data in the buffer, potentially modifying it in-place or generating derived information. The processor has full agency over how the transformation is executed, including:

• Backend Selection: Choosing between CPU, GPU, or specialized hardware backends
• Execution Strategy: Sequential vs parallel processing based on data characteristics
• Memory Management: Optimizing data layout and access patterns for performance
• Resource Utilization: Leveraging available hardware acceleration when beneficial

The method works seamlessly with any data type supported by the buffer interface, automatically adapting to audio samples, video frames, texture data, or other specialized buffer contents while maintaining type safety through the buffer abstraction. This method calls the core processing function defined in derived classes, with atomic thread-safe management of processing state to ensure that concurrent access does not lead to race conditions or data corruption.

Definition at line 8 of file BufferProcessor.cpp.

{
    if (!buffer->try_acquire_processing()) {
        MF_RT_ERROR(Journal::Component::Buffers, Journal::Context::BufferProcessing,
            "Buffer is already being processed, skipping processor");
        return;
    }
 
    m_active_processing.fetch_add(1, std::memory_order_acquire);
 
    try {
        processing_function(buffer);
    } catch (...) {
        buffer->release_processing();
        m_active_processing.fetch_sub(1, std::memory_order_release);
        throw;
    }
 
    buffer->release_processing();
    m_active_processing.fetch_sub(1, std::memory_order_release);
}

References MayaFlux::Journal::BufferProcessing, MayaFlux::Journal::Buffers, m_active_processing, MF_RT_ERROR, and processing_function().

Here is the call graph for this function: