enqueue_operation()

void MayaFlux::Nodes::RootNode::enqueue_operation ( PendingOp &&  op )

private

Queues an operation, draining on the caller's behalf when the queue is full.

Parameters

op	The operation to queue

A full queue is drained here if no processing cycle is in flight, otherwise the caller yields until the processing thread drains it.

Definition at line 15 of file RootNode.cpp.

{
    while (!m_pending_ops.push(std::move(op))) {
        bool expected = false;
        if (m_is_processing.compare_exchange_strong(expected, true,
                std::memory_order_acquire, std::memory_order_relaxed)) {
            process_pending_operations();
            m_is_processing.store(false, std::memory_order_release);
            m_is_processing.notify_all();
        } else {
            std::this_thread::yield();
        }
    }
}

References m_is_processing, m_pending_ops, and process_pending_operations().

Referenced by register_node(), and unregister_node().

Here is the call graph for this function:

Here is the caller graph for this function: