| 387 | } |
| 388 | |
| 389 | void ConsumerWait() { |
| 390 | DomainTimeRange tr("[DALI][DataReader] ConsumerWait #" + to_string(curr_batch_consumer_), |
| 391 | DomainTimeRange::kMagenta); |
| 392 | std::unique_lock<std::mutex> prefetch_lock(prefetch_access_mutex_); |
| 393 | consumer_.wait(prefetch_lock, [this]() { return finished_ || !IsPrefetchQueueEmpty(); }); |
| 394 | if (prefetch_error_) std::rethrow_exception(prefetch_error_); |
| 395 | } |
| 396 | |
| 397 | void ConsumerAdvanceQueue() { |
| 398 | { |
nothing calls this directly
no test coverage detected