process_filtered()

void MayaFlux::Kakshya::DataProcessingChain::process_filtered	(	const std::shared_ptr< SignalSourceContainer > &	container,
		const std::function< bool(const std::shared_ptr< DataProcessor > &)> &	filter
	)

Processes a container with only the processors matching a filter predicate.

Parameters

container	The signal container to process.
filter	Predicate returning true for processors that should run.

Definition at line 95 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) {
            if (filter(processor)) {
                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: