remove_processor_direct()

void MayaFlux::Kakshya::DataProcessingChain::remove_processor_direct ( const std::shared_ptr< DataProcessor > &  processor, const std::shared_ptr< SignalSourceContainer > &  container  )

private

Performs immediate removal of a processor from the chain.

Parameters

processor	The processor to remove.
container	The container whose chain is modified.

Definition at line 45 of file DataProcessingChain.cpp.

{
    auto it = m_container_processors.find(container);
    if (it == m_container_processors.end()) {
        return;
    }
 
    auto& processors = it->second;
    auto proc_it = std::ranges::find(processors, processor);
 
    if (proc_it != processors.end()) {
        processor->on_detach(container);
        processors.erase(proc_it);
        m_processor_tags.erase(processor);
 
        if (processors.empty()) {
            m_container_processors.erase(it);
        }
    }
}

References m_container_processors, and m_processor_tags.

Referenced by drain_pending_removals(), and remove_processor().

Here is the caller graph for this function: