process_tagged()

void MayaFlux::Kakshya::DataProcessingChain::process_tagged	(	const std::shared_ptr< SignalSourceContainer > &	container,
		const std::string &	tag
	)

Processes a container with only the processors carrying a specific tag.

Parameters

container	The signal container to process.
tag	Tag string to match against registered processor tags.

Definition at line 118 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) {
            auto tag_it = m_processor_tags.find(processor);
            if (tag_it != m_processor_tags.end() && tag_it->second == tag) {
                processor->process(container);
            }
        }
    }
 
    m_is_processing.store(false, std::memory_order_release);
    drain_pending_removals();
}

References drain_pending_removals(), m_container_processors, m_is_processing, and m_processor_tags.

Here is the call graph for this function: