Method LoadDataBlock

storage/sstable/reader/sstable_reader_impl.cpp:173–200

}

bool SSTableReader::Impl::LoadDataBlock(int block_id, hfile::DataBlock *block) {
    CHECK(block_id >= 0 && block_id < data_index_->GetBlockSize())
                    << "invalid block_id: " << block_id;

    //  Get length for this block
    int64_t next_offset = 0;
    if (block_id + 1 < data_index_->GetBlockSize()) {
        next_offset = data_index_->GetOffset(block_id + 1);
    } else {
        next_offset = file_trailer_->file_info_offset();
    }
    int64_t cur_offset = data_index_->GetOffset(block_id);
    int length = next_offset - cur_offset;

    std::string buffer;
    {
        MutexLocker l(&mutex_);
        if (!file_base_->Seek(cur_offset, SEEK_SET)) {
            return false;
        }
        buffer.resize(length);
        int64_t size = file_base_->Read((void*) buffer.c_str(), length);
        if (size != length) {
            return false;
        }
    }
    return block->DecodeFromString(buffer);
}

}  // namespace toft