extract_multiple_samples()

std::vector< double > MayaFlux::Buffers::extract_multiple_samples	(	const std::shared_ptr< Nodes::Node > &	node,
		size_t	num_samples
	)

Extract multiple samples from a node into a vector.

Definition at line 184 of file BufferUtils.cpp.

{
    std::vector<double> output(num_samples);
 
    if (!node) {
        MF_RT_ERROR(Journal::Component::Buffers, Journal::Context::BufferProcessing,
            "extract_multiple_samples: null node");
        return output;
    }
 
    static std::atomic<uint64_t> s_context_counter { 1 };
    uint64_t my_context_id = s_context_counter.fetch_add(1, std::memory_order_relaxed);
 
    const auto state = node->m_state.load(std::memory_order_acquire);
 
    // Fast path: inactive node
    if (state == Utils::NodeState::INACTIVE && !node->is_buffer_processed()) {
        for (size_t i = 0; i < num_samples; i++) {
            output[i] = node->process_sample(0.F);
        }
        node->mark_buffer_processed();
        return output;
    }
 
    bool claimed = node->try_claim_snapshot_context(my_context_id);
 
    if (claimed) {
        try {
            node->save_state();
 
            for (size_t i = 0; i < num_samples; i++) {
                output[i] = node->process_sample(0.F);
            }
 
            node->restore_state();
 
            if (node->is_buffer_processed()) {
                node->request_buffer_reset();
            }
 
            node->release_snapshot_context(my_context_id);
 
        } catch (const std::exception& e) {
            node->release_snapshot_context(my_context_id);
            MF_RT_ERROR(Journal::Component::Buffers, Journal::Context::BufferProcessing,
                "Error processing node: {}", e.what());
            output.clear();
        }
    } else {
        uint64_t active_context = node->get_active_snapshot_context();
 
        if (!wait_for_snapshot_completion(node, active_context)) {
            output.clear();
            return output;
        }
 
        node->save_state();
        for (size_t i = 0; i < num_samples; i++) {
            output[i] = node->process_sample(0.F);
        }
        node->restore_state();
 
        if (node->is_buffer_processed()) {
            node->request_buffer_reset();
        }
    }
 
    return output;
}

References MayaFlux::Journal::BufferProcessing, MayaFlux::Journal::Buffers, MayaFlux::Utils::INACTIVE, MF_RT_ERROR, and wait_for_snapshot_completion().

Referenced by MayaFlux::Buffers::NodeSourceProcessor::get_node_data().

Here is the call graph for this function:

Here is the caller graph for this function: