Lines Matching refs:reader_
248 CuckooTableReader* reader_; member in ROCKSDB_NAMESPACE::CuckooTableIterator
261 reader_(reader), in CuckooTableIterator()
273 sorted_bucket_ids_.reserve(static_cast<size_t>(reader_->GetTableProperties()->num_entries)); in InitIfNeeded()
274 uint64_t num_buckets = reader_->table_size_ + reader_->cuckoo_block_size_ - 1; in InitIfNeeded()
276 const char* bucket = reader_->file_data_.data(); in InitIfNeeded()
278 if (Slice(bucket, reader_->key_length_) != Slice(reader_->unused_key_)) { in InitIfNeeded()
281 bucket += reader_->bucket_length_; in InitIfNeeded()
284 reader_->GetTableProperties()->num_entries); in InitIfNeeded()
306 reader_->file_data_, reader_->ucomp_, in Seek()
307 reader_->bucket_length_, reader_->user_key_length_, in Seek()
334 const char* offset = reader_->file_data_.data() + in PrepareKVAtCurrIdx()
335 id * reader_->bucket_length_; in PrepareKVAtCurrIdx()
336 if (reader_->is_last_level_) { in PrepareKVAtCurrIdx()
338 curr_key_.SetInternalKey(Slice(offset, reader_->user_key_length_), in PrepareKVAtCurrIdx()
341 curr_key_.SetInternalKey(Slice(offset, reader_->key_length_)); in PrepareKVAtCurrIdx()
343 curr_value_ = Slice(offset + reader_->key_length_, reader_->value_length_); in PrepareKVAtCurrIdx()