process()

void MayaFlux::Kakshya::VisionProcessor::process ( const std::shared_ptr< SignalSourceContainer > &  container )

overridevirtual

Execute the VisionSequence on processed_data[0].

No-op when processed_data is empty, the pixel span normalises to empty, or geometry was not cached at on_attach time.

Parameters

container

The container to read processed_data[0] from.

Implements MayaFlux::Kakshya::DataProcessor.

Definition at line 74 of file VisionProcessor.cpp.

{
    if (m_width == 0 || m_height == 0 || !container)
        return;
 
    m_is_processing.store(true, std::memory_order_release);
 
    if (m_sequence.backend == Kinesis::Vision::VisionBackend::CPU) {
        std::span<const float> frame;
        if (auto vc = std::dynamic_pointer_cast<VideoStreamContainer>(container)) {
            frame = vc->processed_frame_as_float(0);
            vc->invalidate_float_frame_cache(0);
        } else if (auto wc = std::dynamic_pointer_cast<WindowContainer>(container)) {
            frame = wc->processed_frame_as_float(0);
            wc->invalidate_float_frame_cache(0);
        } else if (auto tc = std::dynamic_pointer_cast<TextureContainer>(container)) {
            frame = tc->as_normalised_float(0);
        }
 
        if (!frame.empty())
            m_result = m_cpu_executor.run(m_sequence, frame, m_width, m_height);
    } else if (m_gpu_frame) {
        if (m_executor->is_suspended()) {
            auto poll = m_executor->run(m_sequence, m_gpu_frame, m_width, m_height);
            if (!poll.is_ready()) {
                m_is_processing.store(false, std::memory_order_release);
                return;
            }
            m_result = std::move(poll);
        } else if (const void* raw = container->get_raw_data()) {
            auto& loom = Portal::Graphics::TextureLoom::instance();
            loom.upload_data(m_gpu_frame, raw, m_gpu_frame->get_size_bytes(), m_upload_staging);
 
            auto pass = m_executor->run(m_sequence, m_gpu_frame, m_width, m_height);
            if (!pass.is_ready()) {
                m_is_processing.store(false, std::memory_order_release);
                return;
            }
            m_result = std::move(pass);
        }
    }
 
    if (m_result_source)
        m_result_source->signal(m_result);
 
    m_is_processing.store(false, std::memory_order_release);
}

References MayaFlux::Kinesis::Vision::VisionSequence::backend, MayaFlux::Kinesis::Vision::CPU, MayaFlux::Portal::Graphics::TextureLoom::instance(), m_cpu_executor, m_executor, m_gpu_frame, m_height, m_is_processing, m_result, m_result_source, m_sequence, m_upload_staging, m_width, and MayaFlux::Kinesis::Vision::VisionExecutor::run().

Here is the call graph for this function: