| 375 | } |
| 376 | |
| 377 | void waitForWrite() { |
| 378 | auto ssd = cache_->ssdCache(); |
| 379 | if (ssd) { |
| 380 | while (ssd->writeInProgress()) { |
| 381 | std::this_thread::sleep_for(std::chrono::milliseconds(50)); // NOLINT |
| 382 | } |
| 383 | } |
| 384 | } |
| 385 | |
| 386 | // Serializes 'pathToInput_' and 'fileIds_' in multithread test. |
| 387 | std::mutex mutex_; |
nothing calls this directly
no test coverage detected