processing_function()

template<GpuImageSource T>

void MayaFlux::Buffers::ImageCVProcessor< T >::processing_function ( const std::shared_ptr< Buffer > &  )

inlineoverridevirtual

Download the current GPU image, run the VisionSequence, store the result.

No-op if the buffer has expired or the image is unavailable.

Parameters

buffer

The GpuImageSource buffer to read from.

Implements MayaFlux::Buffers::BufferProcessor.

Definition at line 108 of file ImageCVProcessor.hpp.

    {
        if (m_skipped_frames < m_eval_delta - 1) {
            m_skipped_frames++;
            return;
        }
        m_skipped_frames = 0;
 
        auto typed = m_buffer.lock();
        if (!typed)
            return;
 
        auto image = resolve_gpu_image(*typed);
        if (!image || !image->is_initialized())
            return;
 
        m_is_processing.store(true, std::memory_order_release);
 
        if (m_sequence.backend == Kinesis::Vision::VisionBackend::CPU) {
            auto frame = download_and_normalise(image, m_raw_staging, m_float_work, m_gpu_staging);
            if (!frame.empty()) {
                m_result = m_cpu_executor.run(
                    m_sequence, frame,
                    image->get_width(), image->get_height());
            }
        } else {
            auto pass = m_executor->run(
                m_sequence, image,
                image->get_width(), image->get_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::Buffers::download_and_normalise(), image, MayaFlux::Buffers::ImageCVProcessor< T >::m_buffer, MayaFlux::Buffers::ImageCVProcessor< T >::m_cpu_executor, MayaFlux::Buffers::ImageCVProcessor< T >::m_eval_delta, MayaFlux::Buffers::ImageCVProcessor< T >::m_executor, MayaFlux::Buffers::ImageCVProcessor< T >::m_float_work, MayaFlux::Buffers::ImageCVProcessor< T >::m_gpu_staging, MayaFlux::Buffers::ImageCVProcessor< T >::m_is_processing, MayaFlux::Buffers::ImageCVProcessor< T >::m_raw_staging, MayaFlux::Buffers::ImageCVProcessor< T >::m_result, MayaFlux::Buffers::ImageCVProcessor< T >::m_result_source, MayaFlux::Buffers::ImageCVProcessor< T >::m_sequence, MayaFlux::Buffers::ImageCVProcessor< T >::m_skipped_frames, MayaFlux::Buffers::resolve_gpu_image(), and MayaFlux::Kinesis::Vision::VisionExecutor::run().

Here is the call graph for this function: