Home
last modified time | relevance | path

Searched refs:rep (Results 1 – 25 of 31) sorted by relevance

12

/rocksdb-6.9/db/
Dc.cc829 db->rep->Put(options->rep, column_family->rep, in rocksdb_put_cf()
880 db->rep->Merge(options->rep, column_family->rep, in rocksdb_merge_cf()
889 SaveError(errptr, db->rep->Write(options->rep, &batch->rep)); in rocksdb_write()
922 Status s = db->rep->Get(options->rep, column_family->rep, in rocksdb_get_cf()
1003 result->rep = db->rep->NewIterator(options->rep); in rocksdb_create_iterator()
1060 result->rep = db->rep->NewIterator(options->rep, column_family->rep); in rocksdb_create_iterator_cf()
1931 Status s = wbwi->rep->GetFromBatchAndDB(db->rep, options->rep, column_family->rep, in rocksdb_writebatch_wi_get_from_batch_and_db_cf()
4179 result->rep = txn->rep->GetIterator(options->rep); in rocksdb_transaction_create_iterator()
4188 result->rep = txn->rep->GetIterator(options->rep, column_family->rep); in rocksdb_transaction_create_iterator_cf()
4196 result->rep = txn_db->rep->NewIterator(options->rep); in rocksdb_transactiondb_create_iterator()
[all …]
Ddb_memtable_test.cc92 MockMemTableRep* rep() { return mock_rep_; } in rep() function in ROCKSDB_NAMESPACE::MockMemTableRepFactory
286 MockMemTableRep* rep = in TEST_F() local
288 ->rep(); in TEST_F()
290 ASSERT_EQ(nullptr, rep->last_hint_in()); in TEST_F()
291 void* hint_foo = rep->last_hint_out(); in TEST_F()
293 ASSERT_EQ(hint_foo, rep->last_hint_in()); in TEST_F()
294 ASSERT_EQ(hint_foo, rep->last_hint_out()); in TEST_F()
296 ASSERT_EQ(hint_foo, rep->last_hint_in()); in TEST_F()
299 ASSERT_EQ(nullptr, rep->last_hint_in()); in TEST_F()
300 void* hint_bar = rep->last_hint_out(); in TEST_F()
[all …]
Drange_del_aggregator.h408 for (auto& rep : reps_) { in InvalidateRangeDelMapPositions()
409 rep.second.Invalidate(); in InvalidateRangeDelMapPositions()
414 for (const auto& rep : reps_) { in IsEmpty() local
415 if (!rep.second.IsEmpty()) { in IsEmpty()
Dmerge_helper.cc401 &compaction_filter_value_, compaction_filter_skip_until_.rep()); in FilterMerge()
403 if (user_comparator_->Compare(*compaction_filter_skip_until_.rep(), in FilterMerge()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index.cc651 return new WBWIIteratorImpl(0, &(rep->skip_list), &rep->write_batch); in NewIterator()
657 &(rep->skip_list), &rep->write_batch); in NewIterator()
684 rep->SetLastEntryOffset(); in Put()
693 rep->SetLastEntryOffset(); in Put()
703 rep->SetLastEntryOffset(); in Delete()
712 rep->SetLastEntryOffset(); in Delete()
722 rep->SetLastEntryOffset(); in SingleDelete()
774 &rep->comparator, value, rep->overwrite_key, &s); in GetFromBatch()
859 &rep->comparator, &batch_value, rep->overwrite_key, &s); in GetFromBatchAndDB()
961 &rep->comparator, &batch_value, rep->overwrite_key, s); in MultiGetFromBatchAndDB()
[all …]
/rocksdb-6.9/table/block_based/
Dhash_index_reader.cc25 const BlockBasedTable::Rep* rep = table->get_rep(); in Create() local
26 assert(rep != nullptr); in Create()
66 RandomAccessFileReader* const file = rep->file.get(); in Create()
67 const Footer& footer = rep->footer; in Create()
68 const ImmutableCFOptions& ioptions = rep->ioptions; in Create()
69 const PersistentCacheOptions& cache_options = rep->persistent_cache_options; in Create()
71 GetMemoryAllocator(rep->table_options); in Create()
97 assert(rep->internal_prefix_transform.get() != nullptr); in Create()
98 s = BlockPrefixIndex::Create(rep->internal_prefix_transform.get(), in Create()
115 const BlockBasedTable::Rep* rep = table()->get_rep(); in NewIterator() local
[all …]
Dblock_prefetcher.cc12 void BlockPrefetcher::PrefetchIfNeeded(const BlockBasedTable::Rep* rep, in PrefetchIfNeeded() argument
22 if (!rep->file->use_direct_io() && in PrefetchIfNeeded()
28 rep->file->Prefetch(handle.offset(), readahead_size_); in PrefetchIfNeeded()
35 } else if (rep->file->use_direct_io() && !prefetch_buffer_) { in PrefetchIfNeeded()
38 rep->CreateFilePrefetchBuffer(BlockBasedTable::kInitAutoReadaheadSize, in PrefetchIfNeeded()
47 rep->CreateFilePrefetchBuffer(readahead_size, readahead_size, in PrefetchIfNeeded()
51 rep->CreateFilePrefetchBuffer(compaction_readahead_size_, in PrefetchIfNeeded()
Dfilter_block_reader_common.cc26 const BlockBasedTable::Rep* const rep = table->get_rep(); in ReadFilterBlock() local
27 assert(rep); in ReadFilterBlock()
30 table->RetrieveBlock(prefetch_buffer, read_options, rep->filter_handle, in ReadFilterBlock()
43 const BlockBasedTable::Rep* const rep = table_->get_rep(); in table_prefix_extractor() local
44 assert(rep); in table_prefix_extractor()
46 return rep->prefix_filtering ? rep->table_prefix_extractor.get() : nullptr; in table_prefix_extractor()
Dpartitioned_index_reader.cc61 const BlockBasedTable::Rep* rep = table()->rep_; in NewIterator() local
74 rep->get_global_seqno(BlockType::kIndex), nullptr, kNullStats, true, in NewIterator()
85 rep->get_global_seqno(BlockType::kIndex), nullptr, kNullStats, true, in NewIterator()
108 const BlockBasedTable::Rep* rep = table()->rep_; in CacheDependencies() local
117 ROCKS_LOG_WARN(rep->ioptions.info_log, in CacheDependencies()
128 rep->get_global_seqno(BlockType::kIndex), &biter, kNullStats, true, in CacheDependencies()
150 rep->CreateFilePrefetchBuffer(0, 0, &prefetch_buffer); in CacheDependencies()
151 s = prefetch_buffer->Prefetch(rep->file.get(), prefetch_off, in CacheDependencies()
Dpartitioned_filter_block_test.cc27 MockedBlockBasedTable(Rep* rep, PartitionedIndexBuilder* pib) in MockedBlockBasedTable() argument
28 : BlockBasedTable(rep, /*block_cache_tracer=*/nullptr) { in MockedBlockBasedTable()
30 rep->index_key_includes_seq = pib->seperator_is_key_plus_seq(); in MockedBlockBasedTable()
31 rep->index_value_is_full = !pib->get_use_value_delta_encoding(); in MockedBlockBasedTable()
170 const Slice ikey_slice = Slice(*ikey.rep()); in VerifyReader()
178 const Slice ikey_slice = Slice(*ikey.rep()); in VerifyReader()
186 const Slice ikey_slice = Slice(*ikey.rep()); in VerifyReader()
274 *InternalKey(next_user_key, 0, ValueType::kTypeValue).rep()); in CutABlock()
342 const Slice ikey_slice = Slice(*ikey.rep()); in TEST_P()
352 const Slice ikey_slice = Slice(*ikey.rep()); in TEST_P()
[all …]
Dblock_based_table_reader.cc415 GenerateCachePrefix(rep->table_options.block_cache.get(), rep->file->file(), in SetupCacheKeyPrefix()
416 &rep->cache_key_prefix[0], &rep->cache_key_prefix_size); in SetupCacheKeyPrefix()
425 rep->file->file(), &rep->compressed_cache_key_prefix[0], in SetupCacheKeyPrefix()
620 rep->footer = footer; in Open()
1295 auto& rep = rep_; in CreateFilterBlockReader() local
1346 &rep->internal_comparator, rep->internal_comparator.user_comparator(), in InitBlockIterator()
1347 rep->get_global_seqno(block_type), input_iter, rep->ioptions.statistics, in InitBlockIterator()
1356 &rep->internal_comparator, rep->internal_comparator.user_comparator(), in InitBlockIterator()
1359 rep->index_key_includes_seq, rep->index_value_is_full, in InitBlockIterator()
1880 assert(rep); in NewSecondaryIterator()
[all …]
Duncompression_dict_reader.cc55 const BlockBasedTable::Rep* const rep = table->get_rep(); in ReadUncompressionDictionary() local
56 assert(rep); in ReadUncompressionDictionary()
57 assert(!rep->compression_dict_handle.IsNull()); in ReadUncompressionDictionary()
60 prefetch_buffer, read_options, rep->compression_dict_handle, in ReadUncompressionDictionary()
67 rep->ioptions.info_log, in ReadUncompressionDictionary()
Dindex_reader_common.cc23 const Rep* const rep = table->get_rep(); in ReadIndexBlock() local
24 assert(rep != nullptr); in ReadIndexBlock()
27 prefetch_buffer, read_options, rep->footer.index_handle(), in ReadIndexBlock()
Dpartitioned_filter_block.cc299 const BlockBasedTable::Rep* const rep = table()->get_rep(); in CacheDependencies() local
300 assert(rep); in CacheDependencies()
309 ROCKS_LOG_WARN(rep->ioptions.info_log, in CacheDependencies()
324 rep->get_global_seqno(BlockType::kFilter), &biter, kNullStats, in CacheDependencies()
341 s = prefetch_buffer->Prefetch(rep->file.get(), prefetch_off, in CacheDependencies()
Dmock_block_based_table.h17 explicit MockBlockBasedTable(Rep* rep) in MockBlockBasedTable() argument
18 : BlockBasedTable(rep, nullptr /* block_cache_tracer */) {} in MockBlockBasedTable()
Dbinary_search_index_reader.cc46 const BlockBasedTable::Rep* rep = table()->get_rep(); in NewIterator() local
65 rep->get_global_seqno(BlockType::kIndex), iter, kNullStats, true, in NewIterator()
Dpartitioned_index_iterator.cc84 auto* rep = table_->get_rep(); in InitPartitionedIndexBlock() local
92 block_prefetcher_.PrefetchIfNeeded(rep, partitioned_index_handle, in InitPartitionedIndexBlock()
Dblock_based_table_reader.h246 explicit BlockBasedTable(Rep* rep, BlockCacheTracer* const block_cache_tracer) in BlockBasedTable() argument
247 : rep_(rep), block_cache_tracer_(block_cache_tracer) {} in BlockBasedTable()
269 static TBlockIter* InitBlockIterator(const Rep* rep, Block* block,
429 static void SetupCacheKeyPrefix(Rep* rep);
Dblock_based_table_iterator.cc226 auto* rep = table_->get_rep(); in InitDataBlock() local
235 block_prefetcher_.PrefetchIfNeeded(rep, data_block_handle, in InitDataBlock()
Dfull_filter_block_test.cc48 explicit MockBlockBasedTable(Rep* rep) in MockBlockBasedTable() argument
49 : BlockBasedTable(rep, nullptr /* block_cache_tracer */) {} in MockBlockBasedTable()
Dblock_prefetcher.h17 void PrefetchIfNeeded(const BlockBasedTable::Rep* rep,
Dblock_based_filter_block_test.cc47 explicit MockBlockBasedTable(Rep* rep) in MockBlockBasedTable() argument
48 : BlockBasedTable(rep, nullptr /* block_cache_tracer */) {} in MockBlockBasedTable()
/rocksdb-6.9/memtable/
Dskiplistrep.cc164 explicit LookaheadIterator(const SkipListRep& rep) : in LookaheadIterator() argument
165 rep_(rep), iter_(&rep_.skip_list_), prev_(iter_) {} in LookaheadIterator()
/rocksdb-6.9/include/rocksdb/
Dwrite_batch.h326 explicit WriteBatch(const std::string& rep);
327 explicit WriteBatch(std::string&& rep);
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc206 &compaction_filter_value_, compaction_filter_skip_until_.rep()); in InvokeFilterIfNeeded()
212 cmp_->Compare(*compaction_filter_skip_until_.rep(), ikey_.user_key) <= in InvokeFilterIfNeeded()

12