Home
last modified time | relevance | path

Searched refs:reader_ (Results 1 – 7 of 7) sorted by relevance

/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader.cc248 CuckooTableReader* reader_; member in ROCKSDB_NAMESPACE::CuckooTableIterator
261 reader_(reader), in CuckooTableIterator()
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()
336 if (reader_->is_last_level_) { in PrepareKVAtCurrIdx()
[all …]
/rocksdb-6.9/db/
Dlog_test.cc156 auto src = GetStringSourceFromLegacyReader(reader_->file()); in reset_source_contents()
166 std::unique_ptr<Reader> reader_; member in ROCKSDB_NAMESPACE::log::LogTest
182 reader_.reset(new FragmentBufferedReader( in LogTest()
238 auto src = GetStringSourceFromLegacyReader(reader_->file()); in ForceError()
252 auto src = GetStringSourceFromLegacyReader(reader_->file()); in ForceEOF()
260 reader_->UnmarkEOF(); in UnmarkEOF()
263 bool IsEOF() { return reader_->IsEOF(); } in IsEOF()
730 std::unique_ptr<SequentialFileReader> reader_; member in ROCKSDB_NAMESPACE::log::RetriableLogTest
743 reader_(nullptr), in RetriableLogTest()
770 reader_.reset(new SequentialFileReader( in SetupTestEnv()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.h20 : reader_(nullptr), reporter_(nullptr), status_(nullptr) {} in LogReaderContainer()
36 reader_ = new log::FragmentBufferedReader(info_log, std::move(file_reader), in LogReaderContainer()
40 log::FragmentBufferedReader* reader_; variable
44 delete reader_; in ~LogReaderContainer() local
Ddb_impl_secondary.cc132 iter->second->reader_->GetLogNumber() != log_number) { in MaybeInitLogReader()
168 *log_reader = iter->second->reader_; in MaybeInitLogReader()
193 log::FragmentBufferedReader* reader = it->second->reader_; in RecoverLogFiles()
/rocksdb-6.9/util/
Dfilter_bench.cc192 std::unique_ptr<FilterBitsReader> reader_; member
395 info.reader_.reset( in Go()
443 info.reader_->MayMatch(kms_[0].Get(info.filter_id_, j))); in Go()
452 fps += info.reader_->MayMatch( in Go()
610 info.reader_->MayMatch(batch_size, batch_slice_ptrs.get(), in RandomQueryTest()
649 may_match = info.reader_->MayMatch(batch_slices[i]); in RandomQueryTest()
/rocksdb-6.9/utilities/blob_db/
Dblob_dump_tool.cc27 : reader_(nullptr), buffer_(nullptr), buffer_size_(0) {} in BlobDumpTool()
54 reader_.reset(new RandomAccessFileReader( in Run()
104 Status s = reader_->Read(offset, size, result, buffer_.get(), nullptr); in Read()
Dblob_dump_tool.h35 std::unique_ptr<RandomAccessFileReader> reader_;