compute_frame()

void MayaFlux::Nodes::GpuSync::GpuComputeNode::compute_frame ( )

overridevirtual

Drive the async dispatch lifecycle.

If dirty and no dispatch is pending: arms a new dispatch via dispatch_core_async, clears dirty, clears ready. If a dispatch is pending: polls the fence. On signal, collects the result, fires on_complete callbacks, sets ready. If continuous, arms the next dispatch immediately.

Implements MayaFlux::Nodes::GpuSync::GpuSync.

Definition at line 26 of file GpuComputeNode.cpp.

{
    auto& foundry = Portal::Graphics::get_shader_foundry();
 
    if (m_pending_fence != Portal::Graphics::INVALID_FENCE) {
        if (!foundry.is_fence_signaled(m_pending_fence))
            return;
 
        const auto result = m_executor->collect_result();
 
        m_pending_fence = Portal::Graphics::INVALID_FENCE;
        m_ready = true;
 
        m_last_result = result;
        notify_tick(0.0);
 
        if (m_continuous)
            m_dirty = true;
 
        return;
    }
 
    if (!m_dirty)
        return;
 
    m_dirty = false;
    m_ready = false;
 
    Yantra::Datum<std::vector<Kakshya::DataVariant>> input;
    m_pending_fence = m_executor->dispatch_async(input);
 
    if (m_pending_fence == Portal::Graphics::INVALID_FENCE) {
        MF_ERROR(Journal::Component::Nodes, Journal::Context::NodeProcessing,
            "GpuComputeNode: dispatch_async returned INVALID_FENCE");
        m_dirty = true;
    }
}

References MayaFlux::Portal::Graphics::get_shader_foundry(), input, MayaFlux::Portal::Graphics::INVALID_FENCE, m_continuous, m_dirty, m_executor, m_last_result, m_pending_fence, m_ready, MF_ERROR, MayaFlux::Journal::NodeProcessing, MayaFlux::Journal::Nodes, and notify_tick().

Here is the call graph for this function: