Method pollSubmitted

modules/engine/runtime/src/io/ram/ram_readers.cpp:296–326

}

void DStorageRAMReader::pollSubmitted(SkrAsyncServicePriority priority) SKR_NOEXCEPT
{
    SkrZoneScopedN("DStorage::PollSubmitted");

    auto instance = skr_get_dstorage_instnace();
    for (auto& e : submitted[priority])
    {
        if (e->okay() || e->batches.empty())
        {
            for (auto batch : e->batches)
            {
                for (auto request : batch->get_requests())
                {
                    auto pFile = io_component<FileComponent>(request.get());
                    auto pStatus = io_component<IOStatusComponent>(request.get());
                    pStatus->setStatus(SKR_IO_STAGE_LOADED);
                    skr_dstorage_close_file(instance, pFile->dfile);
                    pFile->dfile = nullptr;
                }
                processed_batches[priority].enqueue(batch);
                dec_processing(priority);
                inc_processed(priority);
            }
            e.reset();
        }
    }

    // remove empty events
    auto cleaner = std::remove_if(submitted[priority].begin(), submitted[priority].end(), [](const auto& e) { return !e; });
    submitted[priority].erase(cleaner, submitted[priority].end());
}

void DStorageRAMReader::dispatch(SkrAsyncServicePriority priority) SKR_NOEXCEPT
{