| /rocksdb-6.9/db/ |
| D | range_del_aggregator_test.cc | 143 void VerifyShouldDelete(RangeDelAggregator* range_del_agg, in VerifyShouldDelete() argument
148 range_del_agg->ShouldDelete( in VerifyShouldDelete()
155 range_del_agg->ShouldDelete( in VerifyShouldDelete()
161 ReadRangeDelAggregator* range_del_agg, in VerifyIsRangeOverlapped() argument
355 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
380 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
412 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
529 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
563 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
567 &range_del_agg, in TEST_F()
[all …]
|
| D | forward_iterator.cc | 76 ReadRangeDelAggregator range_del_agg(&cfd_->internal_comparator(), in Reset() local
81 read_options_.ignore_range_deletions ? nullptr : &range_del_agg, in Reset()
89 if (!range_del_agg.IsEmpty()) { in Reset()
623 ReadRangeDelAggregator range_del_agg(&cfd_->internal_comparator(), in RebuildIterators() local
631 range_del_agg.AddTombstones(std::move(range_del_iter)); in RebuildIterators()
633 &range_del_agg); in RebuildIterators()
665 if (!range_del_agg.IsEmpty()) { in RebuildIterators()
687 ReadRangeDelAggregator range_del_agg(&cfd_->internal_comparator(), in RenewIterators() local
693 range_del_agg.AddTombstones(std::move(range_del_iter)); in RenewIterators()
695 &range_del_agg); in RenewIterators()
[all …]
|
| D | builder.cc | 97 std::unique_ptr<CompactionRangeDelAggregator> range_del_agg( in BuildTable() local
100 range_del_agg->AddTombstones(std::move(range_del_iter)); in BuildTable()
111 if (iter->Valid() || !range_del_agg->IsEmpty()) { in BuildTable()
158 true /* internal key corruption is not ok */, range_del_agg.get()); in BuildTable()
175 auto range_del_it = range_del_agg->NewIterator(); in BuildTable()
|
| D | merge_helper.cc | 117 CompactionRangeDelAggregator* range_del_agg, in MergeUntil() argument
206 (range_del_agg == nullptr || in MergeUntil()
207 !range_del_agg->ShouldDelete( in MergeUntil()
255 range_del_agg != nullptr && in MergeUntil()
256 range_del_agg->ShouldDelete( in MergeUntil()
|
| D | range_del_aggregator_bench.cc | 189 ROCKSDB_NAMESPACE::ReadRangeDelAggregator range_del_agg( in main() local
224 range_del_agg.AddTombstones(std::move(fragmented_range_del_iter)); in main()
241 range_del_agg.ShouldDelete(parsed_key, mode); in main()
|
| D | db_compaction_filter_test.cc | 337 ReadRangeDelAggregator range_del_agg(&icmp, in TEST_F() local
340 &arena, &range_del_agg, kMaxSequenceNumber, handles_[1])); in TEST_F()
427 ReadRangeDelAggregator range_del_agg(&icmp, in TEST_F() local
430 &arena, &range_del_agg, kMaxSequenceNumber, handles_[1])); in TEST_F()
645 ReadRangeDelAggregator range_del_agg(&icmp, in TEST_F() local
648 &arena, &range_del_agg, kMaxSequenceNumber)); in TEST_F()
|
| D | table_cache.cc | 178 RangeDelAggregator* range_del_agg, const SliceTransform* prefix_extractor, in NewIterator() argument
225 if (s.ok() && range_del_agg != nullptr && !options.ignore_range_deletions) { in NewIterator()
226 if (range_del_agg->AddFile(fd.GetNumber())) { in NewIterator()
242 range_del_agg->AddTombstones(std::move(range_del_iter), smallest, in NewIterator()
|
| D | db_test_util.cc | 910 ReadRangeDelAggregator range_del_agg(&icmp, in AllEntriesFor() local
914 iter.set(dbfull()->NewInternalIterator(&arena, &range_del_agg, in AllEntriesFor()
917 iter.set(dbfull()->NewInternalIterator(&arena, &range_del_agg, in AllEntriesFor()
1323 ReadRangeDelAggregator range_del_agg(&icmp, in validateNumberOfEntries() local
1329 iter.set(dbfull()->NewInternalIterator(&arena, &range_del_agg, in validateNumberOfEntries()
1332 iter.set(dbfull()->NewInternalIterator(&arena, &range_del_agg, in validateNumberOfEntries()
1533 ReadRangeDelAggregator range_del_agg(&icmp, in VerifyDBInternal() local
1536 dbfull()->NewInternalIterator(&arena, &range_del_agg, kMaxSequenceNumber); in VerifyDBInternal()
|
| D | memtable_list.cc | 188 RangeDelAggregator* range_del_agg) { in AddRangeTombstoneIterators() argument
189 assert(range_del_agg != nullptr); in AddRangeTombstoneIterators()
198 range_del_agg->AddTombstones(std::move(range_del_iter)); in AddRangeTombstoneIterators()
|
| D | merge_helper.h | 81 CompactionRangeDelAggregator* range_del_agg = nullptr,
|
| D | version_set.h | 576 RangeDelAggregator* range_del_agg);
580 int level, RangeDelAggregator* range_del_agg);
1032 const Compaction* c, RangeDelAggregator* range_del_agg,
|
| D | column_family.cc | 1085 ReadRangeDelAggregator range_del_agg(&internal_comparator_, read_seq); in RangesOverlapWithMemtables() local
1088 range_del_agg.AddTombstones( in RangesOverlapWithMemtables()
1091 &range_del_agg); in RangesOverlapWithMemtables()
1112 } else if (range_del_agg.IsRangeOverlapped(ranges[i].start, in RangesOverlapWithMemtables()
|
| D | table_cache.h | 72 const FileMetaData& file_meta, RangeDelAggregator* range_del_agg,
|
| D | version_set.cc | 878 range_del_agg_(range_del_agg), in LevelIterator()
1536 RangeDelAggregator* range_del_agg) { in AddIterators() argument
1541 range_del_agg); in AddIterators()
1568 *file.file_metadata, range_del_agg, in AddIteratorsForLevel()
1596 range_del_agg, /*largest_compaction_key=*/nullptr)); in AddIteratorsForLevel()
1612 ReadRangeDelAggregator range_del_agg(&icmp, in OverlapWithLevelIterator() local
1626 *file->file_metadata, &range_del_agg, in OverlapWithLevelIterator()
1647 &range_del_agg)); in OverlapWithLevelIterator()
5517 const Compaction* c, RangeDelAggregator* range_del_agg, in MakeInputIterator() argument
5545 *flevel->files[i].file_metadata, range_del_agg, in MakeInputIterator()
[all …]
|
| D | memtable_list.h | 111 RangeDelAggregator* range_del_agg);
|
| D | db_memtable_test.cc | 136 ReadRangeDelAggregator range_del_agg(&ikey_cmp, in TEST_F() local
|
| /rocksdb-6.9/utilities/ |
| D | debug.cc | 40 ReadRangeDelAggregator range_del_agg(&icmp, in GetAllKeyVersions() local
43 ScopedArenaIterator iter(idb->NewInternalIterator(&arena, &range_del_agg, in GetAllKeyVersions()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator.h | 68 CompactionRangeDelAggregator* range_del_agg,
83 CompactionRangeDelAggregator* range_del_agg,
|
| D | compaction_iterator.cc | 39 CompactionRangeDelAggregator* range_del_agg, const Compaction* compaction, in CompactionIterator() argument
48 report_detailed_time, expect_valid_internal_key, range_del_agg, in CompactionIterator()
60 CompactionRangeDelAggregator* range_del_agg, in CompactionIterator() argument
76 range_del_agg_(range_del_agg), in CompactionIterator()
|
| D | compaction_job.cc | 837 CompactionRangeDelAggregator range_del_agg(&cfd->internal_comparator(), in ProcessKeyValueCompaction() local
843 sub_compact->compaction, &range_del_agg, file_options_for_read_)); in ProcessKeyValueCompaction()
897 &range_del_agg, sub_compact->compaction, compaction_filter, in ProcessKeyValueCompaction()
990 FinishCompactionOutputFile(input_status, sub_compact, &range_del_agg, in ProcessKeyValueCompaction()
1036 sub_compact->outputs.size() == 0 && !range_del_agg.IsEmpty()) { in ProcessKeyValueCompaction()
1045 Status s = FinishCompactionOutputFile(status, sub_compact, &range_del_agg, in ProcessKeyValueCompaction()
1118 CompactionRangeDelAggregator* range_del_agg, in FinishCompactionOutputFile() argument
1196 auto it = range_del_agg->NewIterator(lower_bound, upper_bound, in FinishCompactionOutputFile()
|
| D | compaction_job.h | 127 CompactionRangeDelAggregator* range_del_agg,
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 1315 Arena* arena, RangeDelAggregator* range_del_agg, SequenceNumber sequence, in NewInternalIterator() argument
1329 return NewInternalIterator(roptions, cfd, super_version, arena, range_del_agg, in NewInternalIterator()
1452 RangeDelAggregator* range_del_agg, in NewInternalIterator() argument
1456 assert(range_del_agg != nullptr); in NewInternalIterator()
1470 range_del_agg->AddTombstones(std::move(range_del_iter)); in NewInternalIterator()
1477 range_del_agg); in NewInternalIterator()
1485 &merge_iter_builder, range_del_agg); in NewInternalIterator()
|
| D | db_impl.h | 585 Arena* arena, RangeDelAggregator* range_del_agg, SequenceNumber sequence,
712 Arena* arena, RangeDelAggregator* range_del_agg, SequenceNumber sequence);
|