register_node()

void MayaFlux::Nodes::RootNode::register_node

(

const std::shared_ptr< Node > &

node

)

Adds a node to this root node.

Parameters

node	The node to register

Registered nodes will be processed when the root node's process() method is called, and their outputs will be combined together. If called during processing, the operation is deferred until safe.

Definition at line 16 of file RootNode.cpp.

{
    if (m_is_processing.load(std::memory_order_acquire)) {
        if (m_Nodes.end() != std::ranges::find(m_Nodes, node)) {
            uint32_t state = node->m_state.load();
            if (state & Utils::NodeState::INACTIVE) {
                atomic_remove_flag(node->m_state, Utils::NodeState::INACTIVE);
                atomic_add_flag(node->m_state, Utils::NodeState::ACTIVE);
            }
            return;
        }
 
        for (auto& m_pending_op : m_pending_ops) {
            bool expected = false;
            if (m_pending_op.active.compare_exchange_strong(
                    expected, true,
                    std::memory_order_acquire,
                    std::memory_order_relaxed)) {
                m_pending_op.node = node;
                atomic_remove_flag(node->m_state, Utils::NodeState::ACTIVE);
                atomic_add_flag(node->m_state, Utils::NodeState::INACTIVE);
                m_pending_count.fetch_add(1, std::memory_order_relaxed);
                return;
            }
        }
 
        while (m_is_processing.load(std::memory_order_acquire)) {
            m_is_processing.wait(true, std::memory_order_acquire);
        }
    }
 
    m_Nodes.push_back(node);
    uint32_t state = node->m_state.load();
    atomic_add_flag(node->m_state, Utils::NodeState::ACTIVE);
}

References MayaFlux::Utils::ACTIVE, MayaFlux::Nodes::atomic_add_flag(), MayaFlux::Nodes::atomic_remove_flag(), MayaFlux::Utils::INACTIVE, m_is_processing, m_Nodes, m_pending_count, and m_pending_ops.

Here is the call graph for this function: