| 340 | } |
| 341 | |
| 342 | DataPacket *CompressedVectorReaderImpl::dataPacket( uint64_t inLogicalOffset ) const |
| 343 | { |
| 344 | char *packet = nullptr; |
| 345 | |
| 346 | std::unique_ptr<PacketLock> packetLock = cache_->lock( inLogicalOffset, packet ); |
| 347 | |
| 348 | return reinterpret_cast<DataPacket *>( packet ); |
| 349 | } |
| 350 | |
| 351 | inline bool _alreadyReadPacket( const DecodeChannel &channel, |
| 352 | uint64_t currentPacketLogicalOffset ) |