queue_pending_processor_op()

bool MayaFlux::Buffers::BufferProcessingChain::queue_pending_processor_op ( const std::shared_ptr< BufferProcessor > &  processor, const std::shared_ptr< Buffer > &  buffer, bool  is_addition, std::string *  rejection_reason = nullptr  )

private

Definition at line 345 of file BufferProcessingChain.cpp.

{
    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.processor = processor;
            m_pending_op.buffer = buffer;
            m_pending_op.is_addition = is_addition;
            m_pending_count.fetch_add(1, std::memory_order_relaxed);
            return true;
        }
    }
 
    // Queue full - drop operation (true lock-free behavior)
    if (rejection_reason && is_addition) {
        *rejection_reason = "Processor operation queue full";
    }
    return false;
}

References m_pending_count, and m_pending_ops.

Referenced by add_processor(), and remove_processor().

Here is the caller graph for this function: