add_node()

void MayaFlux::Buffers::AggregateBindingsProcessor::add_node	(	const std::string &	aggregate_name,
		const std::shared_ptr< Nodes::Node > &	node,
		const std::shared_ptr< VKBuffer > &	target,
		ProcessingMode	mode = ProcessingMode::INTERNAL
	)

Add a node to a named aggregate.

Parameters

aggregate_name	Name of the aggregate group
node	Node to add
target	Target buffer for this aggregate
mode	Processing mode for this aggregate (default: INTERNAL)

Nodes with the same aggregate_name are grouped together and uploaded to the same target buffer. Nodes are ordered by insertion.

Definition at line 9 of file AggregateBindingsProcessor.cpp.

{
    if (!node) {
        MF_WARN(Journal::Component::Buffers, Journal::Context::BufferProcessing,
            "Attempted to add null node to aggregate '{}'", aggregate_name);
        return;
    }
 
    if (!target) {
        error<std::invalid_argument>(
            Journal::Component::Buffers,
            Journal::Context::BufferProcessing,
            std::source_location::current(),
            "Cannot add node to aggregate '{}' with null target buffer", aggregate_name);
    }
 
    auto& aggregate = m_aggregates[aggregate_name];
 
    if (aggregate.nodes.empty()) {
        aggregate.target_buffer = target;
        aggregate.processing_mode.store(mode, std::memory_order_release);
    } else if (aggregate.target_buffer != target) {
        MF_WARN(Journal::Component::Buffers, Journal::Context::BufferProcessing,
            "Aggregate '{}' already has a different target buffer. Ignoring new target.",
            aggregate_name);
    }
 
    aggregate.nodes.push_back(node);
    aggregate.staging_data.resize(aggregate.nodes.size());
 
    size_t required_size = aggregate.nodes.size() * sizeof(float);
    if (aggregate.target_buffer->get_size_bytes() < required_size) {
        MF_WARN(Journal::Component::Buffers, Journal::Context::BufferProcessing,
            "Target buffer for aggregate '{}' may be too small: {} nodes require {} bytes, buffer has {} bytes",
            aggregate_name, aggregate.nodes.size(), required_size,
            aggregate.target_buffer->get_size_bytes());
    }
 
    MF_DEBUG(Journal::Component::Buffers, Journal::Context::BufferProcessing,
        "Added node to aggregate '{}' (total: {})", aggregate_name, aggregate.nodes.size());
}

References MayaFlux::Journal::BufferProcessing, MayaFlux::Journal::Buffers, m_aggregates, MF_DEBUG, and MF_WARN.