From c7f8ae9f17743774ac48e2ffc6e150eafcfae416 Mon Sep 17 00:00:00 2001 From: sdong Date: Mon, 24 May 2021 12:45:35 -0700 Subject: [PATCH] SequenceIterWrapper should use internal comparator (#8328) Summary: https://github.com/facebook/rocksdb/pull/8288 introduces a bug: SequenceIterWrapper should do next for seek key using internal key comparator rather than user comparator. Fix it. Pull Request resolved: https://github.com/facebook/rocksdb/pull/8328 Test Plan: Pass all existing tests Reviewed By: ltamasi Differential Revision: D28647263 fbshipit-source-id: 4081d684fd8a86d248c485ef8a1563c7af136447 --- db/compaction/compaction_iterator.h | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/db/compaction/compaction_iterator.h b/db/compaction/compaction_iterator.h index 51749ce80..616434253 100644 --- a/db/compaction/compaction_iterator.h +++ b/db/compaction/compaction_iterator.h @@ -30,7 +30,9 @@ class SequenceIterWrapper : public InternalIterator { public: SequenceIterWrapper(InternalIterator* iter, const Comparator* cmp, bool need_count_entries) - : cmp_(cmp), inner_iter_(iter), need_count_entries_(need_count_entries) {} + : icmp_(cmp, /*named=*/false), + inner_iter_(iter), + need_count_entries_(need_count_entries) {} bool Valid() const override { return inner_iter_->Valid(); } Status status() const override { return inner_iter_->status(); } void Next() override { @@ -44,7 +46,7 @@ class SequenceIterWrapper : public InternalIterator { // For flush cases, we need to count total number of entries, so we // do Next() rather than Seek(). while (inner_iter_->Valid() && - cmp_->Compare(inner_iter_->key(), target) < 0) { + icmp_.Compare(inner_iter_->key(), target) < 0) { Next(); } } @@ -61,7 +63,7 @@ class SequenceIterWrapper : public InternalIterator { uint64_t num_itered() const { return num_itered_; } private: - const Comparator* cmp_; // not owned + InternalKeyComparator icmp_; InternalIterator* inner_iter_; // not owned uint64_t num_itered_ = 0; bool need_count_entries_;