process()

void MayaFlux::Kakshya::DataProcessingChain::process

(

const std::shared_ptr< SignalSourceContainer > &

container

)

Processes a container with all its associated processors in sequence.

Parameters

container

The signal container to process.

Definition at line 76 of file DataProcessingChain.cpp.

{
    bool expected = false;
    if (!m_is_processing.compare_exchange_strong(expected, true,
            std::memory_order_acquire, std::memory_order_relaxed)) {
        return;
    }
 
    auto it = m_container_processors.find(container);
    if (it != m_container_processors.end()) {
        for (auto& processor : it->second) {
            processor->process(container);
        }
    }
 
    m_is_processing.store(false, std::memory_order_release);
    drain_pending_removals();
}

References drain_pending_removals(), m_container_processors, and m_is_processing.

Here is the call graph for this function: