| 542 | LogType /*logType*/) const { |
| 543 | BOLT_CHECK_LE(offset + length, fileSize_); |
| 544 | return std::make_unique<CacheInputStream>( |
| 545 | const_cast<CachedBufferedInput*>(this), |
| 546 | ioStats_.get(), |
| 547 | Region{offset, length}, |
| 548 | input_, |
| 549 | fileNum_, |
| 550 | cacheable_, |
| 551 | columnCacheBlackList_, |
| 552 | nullptr, |
| 553 | TrackingId(), |
| 554 | 0, |
| 555 | options_.loadQuantum()); |
| 556 | } |
| 557 | |
| 558 | bool CachedBufferedInput::prefetch(Region region) { |
| 559 | int32_t numPages = memory::AllocationTraits::numPages(region.length); |
| 560 | if (!shouldPreload(numPages)) { |
| 561 | return false; |
| 562 | } |
| 563 | auto stream = enqueue(region, nullptr); |
| 564 | load(LogType::FILE); |
no test coverage detected