processing_function()

void MayaFlux::Buffers::NodeSourceProcessor::processing_function ( std::shared_ptr< Buffer >  buffer )

overridevirtual

Captures node computation output into a buffer.

Parameters

buffer

Buffer to store the processed data

This method implements a configurable data flow pattern:

1. Optionally resets the buffer if clear_before_process is true
2. Generates sequential values from the computational node
3. Applies the specified interpolation between existing and incoming data

Implements MayaFlux::Buffers::BufferProcessor.

Definition at line 14 of file NodeBuffer.cpp.

{
    if (!m_node) {
        MF_RT_ERROR(Journal::Component::Buffers, Journal::Context::BufferProcessing, "NodeSourceProcessor has null node. Skipping processing.");
        return;
    }
 
    try {
        auto& buffer_data = std::dynamic_pointer_cast<AudioBuffer>(buffer)->get_data();
 
        bool should_clear = m_clear_before_process;
        if (auto node_buffer = std::dynamic_pointer_cast<NodeBuffer>(buffer)) {
            should_clear = node_buffer->get_clear_before_process();
        }
 
        if (should_clear) {
            buffer->clear();
        }
 
        update_buffer(buffer_data);
 
    } catch (const std::exception& e) {
        error_rethrow(Journal::Component::Buffers, Journal::Context::BufferProcessing, std::source_location::current(), "Error processing node: {}", e.what());
    }
}

References MayaFlux::Journal::BufferProcessing, MayaFlux::Journal::Buffers, m_clear_before_process, m_node, MF_RT_ERROR, and update_buffer().

Here is the call graph for this function: