| /rocksdb-6.9/db/ |
| D | file_indexer_test.cc | 87 IntComparator ucmp; member in ROCKSDB_NAMESPACE::FileIndexerTest 96 indexer = new FileIndexer(&ucmp); in TEST_F() 104 indexer = new FileIndexer(&ucmp); in TEST_F() 144 indexer = new FileIndexer(&ucmp); in TEST_F() 186 indexer = new FileIndexer(&ucmp); in TEST_F() 226 indexer = new FileIndexer(&ucmp); in TEST_F()
|
| D | import_column_family_job.cc | 36 const auto ucmp = cfd_->internal_comparator().user_comparator(); in Prepare() local 59 [&ucmp](const IngestedFileInfo* info1, in Prepare() 61 return sstableKeyCompare(ucmp, info1->smallest_internal_key, in Prepare() 66 if (sstableKeyCompare(ucmp, sorted_files[i]->largest_internal_key, in Prepare()
|
| D | external_sst_file_ingestion_job.cc | 53 const Comparator* ucmp = cfd_->internal_comparator().user_comparator(); in Prepare() local 66 [&ucmp](const IngestedFileInfo* info1, const IngestedFileInfo* info2) { in Prepare() 67 return sstableKeyCompare(ucmp, info1->smallest_internal_key, in Prepare() 72 if (sstableKeyCompare(ucmp, sorted_files[i]->largest_internal_key, in Prepare() 494 const Comparator* ucmp = cfd_->internal_comparator().user_comparator(); in GetIngestedFileInfo() local 505 sstableKeyCompare(ucmp, start_key, in GetIngestedFileInfo() 511 sstableKeyCompare(ucmp, end_key, in GetIngestedFileInfo()
|
| D | file_indexer.cc | 18 FileIndexer::FileIndexer(const Comparator* ucmp) in FileIndexer() argument 19 : num_levels_(0), ucmp_(ucmp), level_rb_(nullptr) {} in FileIndexer()
|
| D | file_indexer.h | 44 explicit FileIndexer(const Comparator* ucmp);
|
| D | version_set.cc | 77 Status OverlapWithIterator(const Comparator* ucmp, in OverlapWithIterator() argument 798 static bool AfterFile(const Comparator* ucmp, in AfterFile() argument 802 ucmp->CompareWithoutTimestamp(*user_key, in AfterFile() 806 static bool BeforeFile(const Comparator* ucmp, in BeforeFile() argument 810 ucmp->CompareWithoutTimestamp(*user_key, in BeforeFile() 820 const Comparator* ucmp = icmp.user_comparator(); in SomeFileOverlapsRange() local 825 if (AfterFile(ucmp, smallest_user_key, f) || in SomeFileOverlapsRange() 826 BeforeFile(ucmp, largest_user_key, f)) { in SomeFileOverlapsRange() 1608 auto ucmp = icmp.user_comparator(); in OverlapWithLevelIterator() local 1620 if (AfterFile(ucmp, &smallest_user_key, file) || in OverlapWithLevelIterator() [all …]
|
| D | column_family.cc | 1096 auto* ucmp = vstorage->InternalComparator()->user_comparator(); in RangesOverlapWithMemtables() local 1110 ucmp->Compare(seek_result.user_key, ranges[i].limit) <= 0) { in RangesOverlapWithMemtables()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction.cc | 80 const Comparator* ucmp = vstorage->InternalComparator()->user_comparator(); in GetBoundaryKeys() local 90 ucmp->Compare(start_user_key, *smallest_user_key) < 0) { in GetBoundaryKeys() 95 ucmp->Compare(end_user_key, *largest_user_key) > 0) { in GetBoundaryKeys() 104 ucmp->Compare(start_user_key, *smallest_user_key) < 0) { in GetBoundaryKeys() 108 if (!initialized || ucmp->Compare(end_user_key, *largest_user_key) > 0) { in GetBoundaryKeys() 118 const Comparator* ucmp = vstorage->InternalComparator()->user_comparator(); in PopulateWithAtomicBoundaries() local 139 } else if (sstableKeyCompare(ucmp, *cur_boundary.largest, f->smallest) == in PopulateWithAtomicBoundaries()
|
| D | compaction_job.cc | 1132 const Comparator* ucmp = cfd->user_comparator(); in FinishCompactionOutputFile() local 1167 ucmp->Compare(upper_bound_guard, *sub_compact->end) >= 0) { in FinishCompactionOutputFile() 1184 ucmp->Compare(meta->largest.user_key(), *upper_bound) == 0; in FinishCompactionOutputFile() 1195 ucmp->Compare(*upper_bound , *sub_compact->end) <= 0); in FinishCompactionOutputFile() 1209 int cmp = ucmp->Compare(*upper_bound, tombstone.start_key_); in FinishCompactionOutputFile() 1232 ucmp->Compare(*lower_bound, kv.second) < 0); in FinishCompactionOutputFile() 1236 ucmp->Compare(smallest_candidate.user_key(), *lower_bound) <= 0) { in FinishCompactionOutputFile() 1262 ucmp->Compare(*upper_bound, largest_candidate.user_key()) <= 0) { in FinishCompactionOutputFile()
|
| D | compaction_picker_universal.cc | 150 explicit SmallestKeyHeapComparator(const Comparator* ucmp) { ucmp_ = ucmp; } in SmallestKeyHeapComparator() 168 SmallestKeyHeap create_level_heap(Compaction* c, const Comparator* ucmp) { in create_level_heap() argument 170 SmallestKeyHeap(SmallestKeyHeapComparator(ucmp)); in create_level_heap()
|
| D | compaction_picker.cc | 287 const Comparator* ucmp = icmp_->user_comparator(); in RangeOverlapWithCompaction() local 290 ucmp->Compare(smallest_user_key, c->GetLargestUserKey()) <= 0 && in RangeOverlapWithCompaction() 291 ucmp->Compare(largest_user_key, c->GetSmallestUserKey()) >= 0) { in RangeOverlapWithCompaction()
|
| /rocksdb-6.9/table/ |
| D | get_context.cc | 42 const Comparator* ucmp, const MergeOperator* merge_operator, Logger* logger, in GetContext() argument 49 : ucmp_(ucmp), in GetContext() 75 const Comparator* ucmp, const MergeOperator* merge_operator, Logger* logger, in GetContext() argument 81 : GetContext(ucmp, merge_operator, logger, statistics, init_state, user_key, in GetContext()
|
| D | get_context.h | 88 GetContext(const Comparator* ucmp, const MergeOperator* merge_operator, 97 GetContext(const Comparator* ucmp, const MergeOperator* merge_operator,
|
| /rocksdb-6.9/table/cuckoo/ |
| D | cuckoo_table_reader_test.cc | 332 auto* ucmp = BytewiseComparator(); in TEST_F() local 340 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucmp, in TEST_F() 350 GetContext get_context(ucmp, nullptr, nullptr, nullptr, GetContext::kNotFound, in TEST_F() 364 GetContext get_context2(ucmp, nullptr, nullptr, nullptr, in TEST_F() 380 GetContext get_context3(ucmp, nullptr, nullptr, nullptr, in TEST_F()
|
| /rocksdb-6.9/table/block_based/ |
| D | block.cc | 926 const Comparator* ucmp, in NewDataIterator() argument 946 cmp, ucmp, data_, restart_offset_, num_restarts_, global_seqno, in NewDataIterator() 961 const Comparator* cmp, const Comparator* ucmp, SequenceNumber global_seqno, in NewIndexIterator() argument 982 ret_iter->Initialize(cmp, ucmp, data_, restart_offset_, num_restarts_, in NewIndexIterator()
|