on_attach()

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

overridevirtual

Cache frame geometry from get_structure().

Resets executor state.

Called automatically by DataProcessingChain::add_processor.

Parameters

container

The SignalSourceContainer to attach to.

Implements MayaFlux::Kakshya::DataProcessor.

Definition at line 20 of file VisionProcessor.cpp.

{
    if (!container)
        return;
 
    const bool valid = std::dynamic_pointer_cast<VideoStreamContainer>(container)
        || std::dynamic_pointer_cast<WindowContainer>(container)
        || std::dynamic_pointer_cast<TextureContainer>(container);
 
    if (!valid) {
        error<std::invalid_argument>(
            Journal::Component::Kakshya,
            Journal::Context::ContainerProcessing,
            std::source_location::current(),
            "VisionProcessor requires a VideoStreamContainer, WindowContainer, "
            "or TextureContainer; got {}",
            typeid(*container).name());
    }
 
    const auto& structure = container->get_structure();
    m_width = static_cast<uint32_t>(structure.get_width());
    m_height = static_cast<uint32_t>(structure.get_height());
 
    if (m_sequence.backend == Kinesis::Vision::VisionBackend::CPU) {
        m_cpu_executor.reset();
    } else if (m_width > 0 && m_height > 0) {
        if (!m_executor)
            m_executor = std::make_unique<Yantra::VisionGpuExecutor>();
 
        auto& loom = Portal::Graphics::TextureLoom::instance();
        m_gpu_frame = loom.create_2d(m_width, m_height, ImageFormat::RGBA8, nullptr);
        m_upload_staging = Buffers::create_image_staging_buffer(m_gpu_frame->get_size_bytes());
    }
 
    if (m_width == 0 || m_height == 0) {
        MF_WARN(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "VisionProcessor attached to container with zero spatial dimensions");
    } else {
        MF_INFO(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "VisionProcessor attached: {}x{}", m_width, m_height);
    }
}

References MayaFlux::Kinesis::Vision::VisionSequence::backend, MayaFlux::Journal::ContainerProcessing, MayaFlux::Kinesis::Vision::CPU, MayaFlux::Buffers::create_image_staging_buffer(), MayaFlux::Portal::Graphics::TextureLoom::instance(), MayaFlux::Journal::Kakshya, m_cpu_executor, m_executor, m_gpu_frame, m_height, m_sequence, m_upload_staging, m_width, MF_INFO, MF_WARN, MayaFlux::Kinesis::Vision::VisionExecutor::reset(), and MayaFlux::Kakshya::RGBA8.

Here is the call graph for this function: