| 156 | } |
| 157 | |
| 158 | void RAMService::Runner::enqueueBatch(const IOBatchId& batch) SKR_NOEXCEPT |
| 159 | { |
| 160 | const auto priority = batch->get_priority(); |
| 161 | for (auto&& request : batch->get_requests()) |
| 162 | { |
| 163 | if (auto pStatus = io_component<IOStatusComponent>(request.get())) |
| 164 | { |
| 165 | auto status = pStatus->getStatus(); |
| 166 | SKR_ASSERT(status == SKR_IO_STAGE_NONE); |
| 167 | pStatus->setStatus(SKR_IO_STAGE_ENQUEUED); |
| 168 | } |
| 169 | } |
| 170 | batch_buffer->fetch(priority, batch); |
| 171 | skr_atomic64_add_relaxed(&processing_request_counts[priority], 1); |
| 172 | } |
| 173 | |
| 174 | void RAMService::Runner::set_resolvers() SKR_NOEXCEPT |
| 175 | { |