Home
last modified time | relevance | path

Searched refs:user_comparator (Results 1 – 25 of 50) sorted by relevance

12

/rocksdb-6.9/db/
Drange_tombstone_fragmenter.cc90 if (icmp.user_comparator()->Compare(cur_start_key, cur_end_key) == 0) { in FragmentTombstones()
94 if (icmp.user_comparator()->Compare(next_start_key, cur_end_key) <= 0) { in FragmentTombstones()
112 icmp.user_comparator()->Compare(tombstones_.back().end_key, in FragmentTombstones()
190 if (!cur_end_keys.empty() && icmp.user_comparator()->Compare( in FragmentTombstones()
221 : tombstone_start_cmp_(icmp.user_comparator()), in FragmentedRangeTombstoneIterator()
222 tombstone_end_cmp_(icmp.user_comparator()), in FragmentedRangeTombstoneIterator()
224 ucmp_(icmp.user_comparator()), in FragmentedRangeTombstoneIterator()
236 : tombstone_start_cmp_(icmp.user_comparator()), in FragmentedRangeTombstoneIterator()
237 tombstone_end_cmp_(icmp.user_comparator()), in FragmentedRangeTombstoneIterator()
239 ucmp_(icmp.user_comparator()), in FragmentedRangeTombstoneIterator()
Dmemtable.cc501 size_t ts_sz = GetInternalKeyComparator().user_comparator()->timestamp_size(); in Add()
647 const Comparator* user_comparator = in SaveValue() local
648 s->mem->GetInternalKeyComparator().user_comparator(); in SaveValue()
649 size_t ts_sz = user_comparator->timestamp_size(); in SaveValue()
650 if (user_comparator->CompareWithoutTimestamp(user_key_slice, in SaveValue()
804 size_t ts_sz = GetInternalKeyComparator().user_comparator()->timestamp_size(); in Get()
962 if (comparator_.comparator.user_comparator()->Equal( in Update()
1021 if (comparator_.comparator.user_comparator()->Equal( in UpdateCallback()
1092 if (!comparator_.comparator.user_comparator()->Equal( in CountSuccessiveMergeEntries()
Drange_del_aggregator.cc95 icmp_->user_comparator()->Compare(target, smallest_->user_key) < 0) { in Seek()
111 icmp_->user_comparator()->Compare(largest_->user_key, target) < 0) { in SeekForPrev()
447 int cmp = icmp_->user_comparator()->Compare(iter->start_key().user_key, in BeforeEndKey()
Dbuilder.cc148 MergeHelper merge(env, internal_comparator.user_comparator(), in BuildTable()
155 iter, internal_comparator.user_comparator(), &merge, kMaxSequenceNumber, in BuildTable()
Dmerge_helper.cc22 MergeHelper::MergeHelper(Env* env, const Comparator* user_comparator, in MergeHelper() argument
31 user_comparator_(user_comparator), in MergeHelper()
Dversion_set.cc116 const Comparator* user_comparator, in FilePicker() argument
133 user_comparator_(user_comparator), in FilePicker()
359 const Comparator* user_comparator, in FilePickerMultiGet() argument
375 user_comparator_(user_comparator), in FilePickerMultiGet()
820 const Comparator* ucmp = icmp.user_comparator(); in SomeFileOverlapsRange()
1608 auto ucmp = icmp.user_comparator(); in OverlapWithLevelIterator()
1661 const Comparator* user_comparator, int levels, in VersionStorageInfo() argument
1665 user_comparator_(user_comparator), in VersionStorageInfo()
1669 file_indexer_(user_comparator), in VersionStorageInfo()
1773 user_comparator(), internal_comparator()); in Get()
[all …]
Dcolumn_family.h423 const Comparator* user_comparator() const { in user_comparator() function
424 return internal_comparator_.user_comparator(); in user_comparator()
/rocksdb-6.9/table/block_based/
Dblock.h191 const Comparator* user_comparator,
210 const Comparator* user_comparator,
364 DataBlockIter(const Comparator* comparator, const Comparator* user_comparator, in DataBlockIter() argument
370 Initialize(comparator, user_comparator, data, restarts, num_restarts, in DataBlockIter()
375 const Comparator* user_comparator, const char* data, in Initialize() argument
383 user_comparator_ = user_comparator; in Initialize()
495 const Comparator* user_comparator, const char* data, in Initialize() argument
500 InitializeBase(key_includes_seq ? comparator : user_comparator, data, in Initialize()
Dpartitioned_index_reader.cc73 internal_comparator(), internal_comparator()->user_comparator(), in NewIterator()
84 internal_comparator(), internal_comparator()->user_comparator(), in NewIterator()
127 internal_comparator(), internal_comparator()->user_comparator(), in CacheDependencies()
Dblock_based_table_reader.cc1346 &rep->internal_comparator, rep->internal_comparator.user_comparator(), in InitBlockIterator()
1356 &rep->internal_comparator, rep->internal_comparator.user_comparator(), in InitBlockIterator()
1886 &rep->internal_comparator, rep->internal_comparator.user_comparator(), in NewSecondaryIterator()
1946 rep_->internal_comparator.user_comparator(), const_ikey_ptr, in PrefixMayMatch()
2075 rep_->internal_comparator.user_comparator()->timestamp_size(); in FullFilterKeyMayMatch()
2164 rep_->internal_comparator.user_comparator()->timestamp_size(); in Get()
2187 UserComparatorWrapper(rep_->internal_comparator.user_comparator()) in Get()
2374 UserComparatorWrapper(rep_->internal_comparator.user_comparator()) in MultiGet()
2483 UserComparatorWrapper(rep_->internal_comparator.user_comparator()) in MultiGet()
2609 UserComparatorWrapper user_comparator(comparator.user_comparator()); in Prefetch() local
[all …]
Dblock_based_table_builder.cc383 icomparator.user_comparator() in Rep()
543 size_t ts_sz = r->internal_comparator.user_comparator()->timestamp_size(); in Add()
933 rep_->props.comparator_name = rep_->ioptions.user_comparator != nullptr in WritePropertiesBlock()
934 ? rep_->ioptions.user_comparator->Name() in WritePropertiesBlock()
1115 r->internal_comparator.user_comparator()->timestamp_size(); in EnterUnbuffered()
Dpartitioned_filter_block.cc197 comparator, comparator->user_comparator(), in GetFilterPartitionHandle()
323 comparator, comparator->user_comparator(), in CacheDependencies()
Dbinary_search_index_reader.cc64 internal_comparator(), internal_comparator()->user_comparator(), in NewIterator()
Ddata_block_hash_index_test.cc394 auto iter = reader.NewDataIterator(&icmp, icmp.user_comparator(), in TEST()
478 auto iter = reader.NewDataIterator(&icmp, icmp.user_comparator(), in TEST()
516 auto iter = reader.NewDataIterator(&icmp, icmp.user_comparator(), in TEST()
Dpartitioned_index_iterator.h35 user_comparator_(icomp.user_comparator()), in table_()
/rocksdb-6.9/util/
Dset_comparator.h12 explicit SetComparator(const Comparator* user_comparator) in SetComparator()
13 : user_comparator_(user_comparator ? user_comparator in SetComparator()
Duser_comparator_wrapper.h25 const Comparator* user_comparator() const { return user_comparator_; } in user_comparator() function
/rocksdb-6.9/table/
Dsst_file_writer.cc70 if (internal_comparator.user_comparator()->Compare( in Add()
119 if (internal_comparator.user_comparator()->Compare( in DeleteRange()
124 if (internal_comparator.user_comparator()->Compare( in DeleteRange()
163 const Comparator* user_comparator, in SstFileWriter() argument
167 : rep_(new Rep(env_options, options, io_priority, user_comparator, in SstFileWriter()
Dsst_file_reader.cc74 r->ioptions.user_comparator, internal_iter, sequence, in NewIterator()
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_factory.cc22 table_reader_options.internal_comparator.user_comparator(), nullptr)); in NewTableReader()
40 table_builder_options.internal_comparator.user_comparator(), in NewTableBuilder()
Dcuckoo_table_reader.h33 uint64_t file_size, const Comparator* user_comparator,
Dcuckoo_table_builder.h27 const Comparator* user_comparator,
/rocksdb-6.9/db/compaction/
Dcompaction.cc80 const Comparator* ucmp = vstorage->InternalComparator()->user_comparator(); in GetBoundaryKeys()
118 const Comparator* ucmp = vstorage->InternalComparator()->user_comparator(); in PopulateWithAtomicBoundaries()
366 const Comparator* user_cmp = cfd_->user_comparator(); in KeyNotExistsBeyondOutputLevel()
/rocksdb-6.9/utilities/
Ddebug.cc63 icmp.user_comparator()->Compare(ikey.user_key, end_key) > 0) { in GetAllKeyVersions()
/rocksdb-6.9/include/rocksdb/
Dsst_file_writer.h93 const Comparator* user_comparator,

12