Home
last modified time | relevance | path

Searched refs:table_ (Results 1 – 25 of 27) sorted by relevance

12

/rocksdb-6.9/table/block_based/
Dindex_reader_common.h25 assert(table_ != nullptr); in IndexReaderCommon()
39 assert(table_ != nullptr); in internal_comparator()
40 assert(table_->get_rep() != nullptr); in internal_comparator()
46 assert(table_ != nullptr); in index_has_first_key()
47 assert(table_->get_rep() != nullptr); in index_has_first_key()
52 assert(table_ != nullptr); in index_key_includes_seq()
53 assert(table_->get_rep() != nullptr); in index_key_includes_seq()
58 assert(table_ != nullptr); in index_value_is_full()
59 assert(table_->get_rep() != nullptr); in index_value_is_full()
64 assert(table_ != nullptr); in cache_index_blocks()
[all …]
Dfilter_block_reader_common.cc41 assert(table_); in table_prefix_extractor()
43 const BlockBasedTable::Rep* const rep = table_->get_rep(); in table_prefix_extractor()
51 assert(table_); in whole_key_filtering()
52 assert(table_->get_rep()); in whole_key_filtering()
54 return table_->get_rep()->whole_key_filtering; in whole_key_filtering()
59 assert(table_); in cache_filter_blocks()
60 assert(table_->get_rep()); in cache_filter_blocks()
62 return table_->get_rep()->table_options.cache_index_and_filter_blocks; in cache_filter_blocks()
82 return ReadFilterBlock(table_, nullptr /* prefetch_buffer */, read_options, in GetOrReadFilterBlock()
Dfilter_block_reader_common.h27 : table_(t), filter_block_(std::move(filter_block)) { in FilterBlockReaderCommon()
28 assert(table_); in FilterBlockReaderCommon()
39 const BlockBasedTable* table() const { return table_; } in table()
51 const BlockBasedTable* table_;
Duncompression_dict_reader.cc92 return ReadUncompressionDictionary(table_, prefetch_buffer, read_options, in GetOrReadUncompressionDictionary()
114 assert(table_); in cache_dictionary_blocks()
115 assert(table_->get_rep()); in cache_dictionary_blocks()
117 return table_->get_rep()->table_options.cache_index_and_filter_blocks; in cache_dictionary_blocks()
Duncompression_dict_reader.h43 : table_(t), uncompression_dict_(std::move(uncompression_dict)) { in UncompressionDictReader()
44 assert(table_); in UncompressionDictReader()
55 const BlockBasedTable* table_; variable
Dblock_based_filter_block_test.cc66 BlockBasedFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F()
95 BlockBasedFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F()
157 BlockBasedFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F()
257 new BlockBasedFilterBlockReader(table_.get(), std::move(block)); in TEST_F()
289 new BlockBasedFilterBlockReader(table_.get(), std::move(block)); in TEST_F()
351 new BlockBasedFilterBlockReader(table_.get(), std::move(block)); in TEST_F()
Dpartitioned_index_iterator.cc43 assert(!Valid() || (table_->get_rep()->index_key_includes_seq in SeekImpl()
84 auto* rep = table_->get_rep(); in InitPartitionedIndexBlock()
97 table_->NewDataBlockIterator<IndexBlockIter>( in InitPartitionedIndexBlock()
Dblock_based_table_iterator.h29 : table_(table), in table_() function
149 const BlockBasedTable* table_; variable
200 !table_->PrefixMayMatch(ikey, read_options_, prefix_extractor_, in CheckPrefixMayMatch()
Dfull_filter_block_test.cc122 FullFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F()
145 FullFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F()
198 FullFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F()
292 FullFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F()
Dmock_block_based_table.h30 std::unique_ptr<BlockBasedTable> table_; variable
40 table_.reset(new MockBlockBasedTable(new BlockBasedTable::Rep( in MockBlockBasedTableTester()
Dpartitioned_index_iterator.h30 : table_(table), in table_() function
125 const BlockBasedTable* table_;
Dblock_based_table_iterator.cc226 auto* rep = table_->get_rep(); in InitDataBlock()
240 table_->NewDataBlockIterator<DataBlockIter>( in InitDataBlock()
Dpartitioned_filter_block_test.cc66 std::unique_ptr<BlockBasedTable> table_; member in ROCKSDB_NAMESPACE::PartitionedFilterBlockTest
148 table_.reset(new MockedBlockBasedTable( in NewReader()
157 new MyPartitionedFilterBlockReader(table_.get(), std::move(block)); in NewReader()
Dindex_reader_common.cc50 return ReadIndexBlock(table_, /*prefetch_buffer=*/nullptr, read_options, in GetOrReadIndexBlock()
Dblock_based_table_reader.h468 const BlockBasedTable* table_;
/rocksdb-6.9/table/
Dmock_table.h72 const stl_wrappers::KVMap& table_;
78 itr_ = table_.end(); in MockTableIterator()
86 itr_ = table_.end(); in SeekToLast()
92 itr_ = table_.lower_bound(str_target); in Seek()
97 itr_ = table_.upper_bound(str_target); in SeekForPrev()
104 if (itr_ == table_.begin()) { in Prev()
105 itr_ = table_.end(); in Prev()
118 const stl_wrappers::KVMap& table_;
126 table_ = MakeMockFile({}); in MockTableBuilder()
147 file_system_->files.insert({id_, table_}); in Finish()
[all …]
Dmock_table.cc34 return new MockTableIterator(table_); in NewIterator()
41 std::unique_ptr<MockTableIterator> iter(new MockTableIterator(table_)); in Get()
/rocksdb-6.9/table/plain/
Dplain_table_reader.cc84 PlainTableReader* table_; member in ROCKSDB_NAMESPACE::PlainTableIterator
636 : table_(table), in PlainTableIterator()
637 decoder_(&table_->file_info_, table_->encoding_type_, in PlainTableIterator()
638 table_->user_key_len_, table_->prefix_extractor_), in PlainTableIterator()
648 offset_ >= table_->data_start_offset_; in Valid()
653 next_offset_ = table_->data_start_offset_; in SeekToFirst()
683 if (table_->IsTotalOrderMode()) { in Seek()
684 if (table_->full_scan_mode_) { in Seek()
689 } else if (table_->GetIndexSize() > 1) { in Seek()
702 if (!table_->IsTotalOrderMode()) { in Seek()
[all …]
/rocksdb-6.9/memtable/
Dmemtablerep_bench.cc206 : table_(table), in BenchmarkThread()
218 MemTableRep* table_; member in ROCKSDB_NAMESPACE::BenchmarkThread
241 KeyHandle handle = table_->Allocate(encoded_len, &buf); in FillOne()
253 table_->Insert(handle); in FillOne()
319 verify_args.table = table_; in ReadOne()
321 table_->Get(lookup_key, &verify_args, callback); in ReadOne()
344 std::unique_ptr<MemTableRep::Iterator> iter(table_->GetIterator()); in ReadOneSeq()
409 : table_(table), in Benchmark()
453 MemTableRep* table_; member in ROCKSDB_NAMESPACE::Benchmark
514 table_, key_gen_, bytes_written, bytes_read, sequence_, in RunThreads()
[all …]
/rocksdb-6.9/util/
Dhash_map.h28 std::array<autovector<std::pair<K, V>, 1>, size> table_; variable
32 auto& bucket = table_[key % size]; in Contains()
40 auto& bucket = table_[key % size]; in Insert()
45 auto& bucket = table_[key % size]; in Delete()
59 auto& bucket = table_[key % size]; in Get()
/rocksdb-6.9/cache/
Dclock_cache.cc380 HashTable table_; member in ROCKSDB_NAMESPACE::__anon9da5ff120111::ClockCacheShard
514 table_.erase(CacheKey(handle->key, handle->hash)); in TryEvict()
599 if (table_.find(accessor, CacheKey(key, hash))) { in Insert()
601 table_.erase(accessor); in Insert()
604 table_.insert(HashTable::value_type(CacheKey(key, hash), handle)); in Insert()
637 if (!table_.find(accessor, CacheKey(key, hash))) { in Lookup()
682 if (table_.find(accessor, CacheKey(key, hash))) { in EraseAndConfirm()
684 table_.erase(accessor); in EraseAndConfirm()
694 table_.clear(); in EraseUnRefEntries()
Dlru_cache.cc127 table_.Remove(old->key(), old->hash); in EraseUnRefEntries()
144 table_.ApplyToAllCacheEntries( in ApplyToAllCacheEntries()
242 table_.Remove(old->key(), old->hash); in EvictFromLRU()
273 LRUHandle* e = table_.Lookup(key, hash); in Lookup()
317 table_.Remove(e->key(), e->hash); in Release()
385 LRUHandle* old = table_.Insert(e); in Insert()
422 e = table_.Remove(key, hash); in Erase()
Dlru_cache.h294 LRUHandleTable table_; in ALIGN_AS() local
/rocksdb-6.9/db/
Dmemtable.h377 table_->MarkReadOnly(); in MarkImmutable()
386 table_->MarkFlushed(); in MarkFlushed()
391 return table_->IsMergeOperatorSupported(); in IsMergeOperatorSupported()
397 return table_->IsSnapshotSupported() && !moptions_.inplace_update_support; in IsSnapshotSupported()
461 std::unique_ptr<MemTableRep> table_; variable
Dmemtable.cc80 table_(ioptions.memtable_factory->CreateMemTableRep( in MemTable()
131 arena_.ApproximateMemoryUsage(), table_->ApproximateMemoryUsage(), in ApproximateMemoryUsage()
160 auto allocated_memory = table_->ApproximateMemoryUsage() + in ShouldFlushNow()
295 iter_ = mem.table_->GetDynamicPrefixIterator(arena); in MemTableIterator()
297 iter_ = mem.table_->GetIterator(arena); in MemTableIterator()
452 uint64_t entry_count = table_->ApproximateNumEntries(start_ikey, end_ikey); in ApproximateStats()
488 type == kTypeRangeDeletion ? range_del_table_ : table_; in Add()
866 table_->Get(key, &saver, SaveValue); in GetFromTable()
946 table_->GetDynamicPrefixIterator()); in Update()
1005 table_->GetDynamicPrefixIterator()); in UpdateCallback()
[all …]

12