Home
last modified time | relevance | path

Searched refs:range_del_iter (Results 1 – 15 of 15) sorted by relevance

/rocksdb-6.9/db/
Drange_tombstone_fragmenter_test.cc145 auto range_del_iter = MakeRangeDelIter( in TEST_F() local
161 auto range_del_iter = in TEST_F() local
176 auto range_del_iter = in TEST_F() local
196 auto range_del_iter = MakeRangeDelIter({{"a", "c", 30}, in TEST_F() local
223 auto range_del_iter = MakeRangeDelIter({{"a", "e", 10}, in TEST_F() local
299 auto range_del_iter = MakeRangeDelIter({{"a", "e", 10}, in TEST_F() local
326 auto range_del_iter = MakeRangeDelIter({{"a", "e", 10}, in TEST_F() local
347 auto range_del_iter = MakeRangeDelIter({{"a", "e", 10}, in TEST_F() local
368 auto range_del_iter = MakeRangeDelIter({{"a", "e", 10}, in TEST_F() local
394 auto range_del_iter = MakeRangeDelIter({{"a", "e", 10}, in TEST_F() local
[all …]
Drange_del_aggregator_test.cc42 auto range_del_iter = MakeRangeDelIter(range_dels); in MakeFragmentedTombstoneLists() local
44 std::move(range_del_iter), bytewise_icmp)); in MakeFragmentedTombstoneLists()
196 auto range_del_iter = MakeRangeDelIter({}); in TEST_F() local
197 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
214 auto range_del_iter = in TEST_F() local
216 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
248 auto range_del_iter = in TEST_F() local
250 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
281 auto range_del_iter = in TEST_F() local
283 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
[all …]
Dtable_cache.cc227 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in NewIterator() local
230 if (range_del_iter != nullptr) { in NewIterator()
231 s = range_del_iter->status(); in NewIterator()
242 range_del_agg->AddTombstones(std::move(range_del_iter), smallest, in NewIterator()
396 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in Get() local
398 if (range_del_iter != nullptr) { in Get()
401 range_del_iter->MaxCoveringTombstoneSeqnum(ExtractUserKey(k))); in Get()
495 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in MultiGet() local
497 if (range_del_iter != nullptr) { in MultiGet()
504 range_del_iter->MaxCoveringTombstoneSeqnum(iter->ukey)); in MultiGet()
Dexternal_sst_file_ingestion_job.cc461 std::unique_ptr<InternalIterator> range_del_iter( in GetIngestedFileInfo() local
495 if (range_del_iter != nullptr) { in GetIngestedFileInfo()
496 for (range_del_iter->SeekToFirst(); range_del_iter->Valid(); in GetIngestedFileInfo()
497 range_del_iter->Next()) { in GetIngestedFileInfo()
498 if (!ParseInternalKey(range_del_iter->key(), &key)) { in GetIngestedFileInfo()
501 RangeTombstone tombstone(key, range_del_iter->value()); in GetIngestedFileInfo()
Dmemtable.cc791 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in Get() local
794 if (range_del_iter != nullptr) { in Get()
797 range_del_iter->MaxCoveringTombstoneSeqnum(key.user_key())); in Get()
913 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in MultiGet() local
916 if (range_del_iter != nullptr) { in MultiGet()
919 range_del_iter->MaxCoveringTombstoneSeqnum(iter->lkey->user_key())); in MultiGet()
Dflush_job.cc327 auto* range_del_iter = in WriteLevel0Table() local
329 if (range_del_iter != nullptr) { in WriteLevel0Table()
330 range_del_iters.emplace_back(range_del_iter); in WriteLevel0Table()
Dbuilder.cc99 for (auto& range_del_iter : range_del_iters) { in BuildTable() local
100 range_del_agg->AddTombstones(std::move(range_del_iter)); in BuildTable()
Dforward_iterator.cc628 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in RebuildIterators() local
631 range_del_agg.AddTombstones(std::move(range_del_iter)); in RebuildIterators()
690 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in RenewIterators() local
693 range_del_agg.AddTombstones(std::move(range_del_iter)); in RenewIterators()
Drepair.cc420 auto range_del_iter = in ConvertLogToTable() local
422 if (range_del_iter != nullptr) { in ConvertLogToTable()
423 range_del_iters.emplace_back(range_del_iter); in ConvertLogToTable()
Drange_del_aggregator_bench.cc209 auto range_del_iter = in main() local
Dmemtable_list.cc196 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in AddRangeTombstoneIterators() local
198 range_del_agg->AddTombstones(std::move(range_del_iter)); in AddRangeTombstoneIterators()
/rocksdb-6.9/table/block_based/
Dblock_based_table_reader.cc3144 auto* range_del_iter = NewRangeTombstoneIterator(ReadOptions()); in DumpTable() local
3145 if (range_del_iter != nullptr) { in DumpTable()
3146 range_del_iter->SeekToFirst(); in DumpTable()
3147 if (range_del_iter->Valid()) { in DumpTable()
3152 for (; range_del_iter->Valid(); range_del_iter->Next()) { in DumpTable()
3153 DumpKeyValue(range_del_iter->key(), range_del_iter->value(), out_file); in DumpTable()
3157 delete range_del_iter; in DumpTable()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1237 auto range_del_iter = in WriteLevel0TableForRecovery() local
1239 if (range_del_iter != nullptr) { in WriteLevel0TableForRecovery()
1240 range_del_iters.emplace_back(range_del_iter); in WriteLevel0TableForRecovery()
Ddb_impl.cc1465 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter; in NewInternalIterator() local
1468 range_del_iter.reset( in NewInternalIterator()
1470 range_del_agg->AddTombstones(std::move(range_del_iter)); in NewInternalIterator()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator_test.cc230 std::unique_ptr<FragmentedRangeTombstoneIterator> range_del_iter( in InitIterators() local
234 range_del_agg_->AddTombstones(std::move(range_del_iter)); in InitIterators()