| 178 | } |
| 179 | |
| 180 | void VRAMService::Runner::enqueueBatch(const IOBatchId& batch) SKR_NOEXCEPT |
| 181 | { |
| 182 | const auto priority = batch->get_priority(); |
| 183 | for (auto&& request : batch->get_requests()) |
| 184 | { |
| 185 | if (auto pStatus = io_component<IOStatusComponent>(request.get())) |
| 186 | { |
| 187 | auto status = pStatus->getStatus(); |
| 188 | SKR_ASSERT(status == SKR_IO_STAGE_NONE); |
| 189 | pStatus->setStatus(SKR_IO_STAGE_ENQUEUED); |
| 190 | } |
| 191 | } |
| 192 | batch_buffer->fetch(priority, batch); |
| 193 | skr_atomic64_add_relaxed(&processing_request_counts[priority], 1); |
| 194 | } |
| 195 | |
| 196 | void VRAMService::Runner::set_resolvers() SKR_NOEXCEPT |
| 197 | { |