ensure_staging_buffer()

void MayaFlux::Buffers::BufferDownloadProcessor::ensure_staging_buffer ( const std::shared_ptr< VKBuffer > &  source )

private

Definition at line 78 of file BufferDownloadProcessor.cpp.

{
    auto it = m_staging_buffers.find(source);
    if (it != m_staging_buffers.end() && it->second->get_size_bytes() >= source->get_size_bytes() && it->second->is_initialized()) {
        return;
    }
 
    auto staging_buffer = std::make_shared<VKBuffer>(
        source->get_size_bytes(),
        VKBuffer::Usage::STAGING,
        Kakshya::DataModality::UNKNOWN);
 
    if (!m_buffer_service) {
        error<std::runtime_error>(
            Journal::Component::Buffers,
            Journal::Context::BufferProcessing,
            std::source_location::current(),
            "No processing context available for staging buffer initialization");
    }
 
    if (!staging_buffer->is_initialized()) {
        try {
            m_buffer_service->initialize_buffer(staging_buffer);
        } catch (const std::exception& e) {
            error_rethrow(
                Journal::Component::Buffers,
                Journal::Context::BufferProcessing,
                std::source_location::current(),
                "Failed to initialize staging buffer: {}", e.what());
        }
    }
 
    m_staging_buffers[source] = staging_buffer;
 
    MF_INFO(Journal::Component::Buffers, Journal::Context::BufferProcessing,
        "Created staging buffer for download: {} bytes", staging_buffer->get_size_bytes());
}

References MayaFlux::Journal::BufferProcessing, MayaFlux::Journal::Buffers, MayaFlux::Registry::Service::BufferService::initialize_buffer, MayaFlux::Buffers::VKBufferProcessor::m_buffer_service, m_staging_buffers, MF_INFO, MayaFlux::Buffers::VKBuffer::STAGING, and MayaFlux::Kakshya::UNKNOWN.

Referenced by download_device_local().

Here is the caller graph for this function: