Home
last modified time | relevance | path

Searched refs:active_iters_ (Results 1 – 2 of 2) sorted by relevance

/rocksdb-6.9/db/
Drange_del_aggregator.cc161 active_iters_(EndKeyMinComparator(icmp)), in ForwardRangeDelIterator()
166 while (!active_iters_.empty() && in ShouldDelete()
167 icmp_->Compare((*active_iters_.top())->end_key(), parsed) <= 0) { in ShouldDelete()
173 assert(active_iters_.size() == active_seqnums_.size()); in ShouldDelete()
184 assert(active_iters_.size() == active_seqnums_.size()); in ShouldDelete()
194 active_iters_.clear(); in Invalidate()
204 active_iters_(StartKeyMaxComparator(icmp)), in ReverseRangeDelIterator()
209 while (!active_iters_.empty() && in ShouldDelete()
216 assert(active_iters_.size() == active_seqnums_.size()); in ShouldDelete()
227 assert(active_iters_.size() == active_seqnums_.size()); in ShouldDelete()
[all …]
Drange_del_aggregator.h122 assert(active_iters_.size() == active_seqnums_.size()); in AddNewIter()
160 active_iters_.push(seq_pos); in PushActiveIter()
164 auto active_top = active_iters_.top(); in PopActiveIter()
166 active_iters_.pop(); in PopActiveIter()
184 BinaryHeap<ActiveSeqSet::const_iterator, EndKeyMinComparator> active_iters_; variable
199 assert(active_iters_.size() == active_seqnums_.size()); in AddNewIter()
244 active_iters_.push(seq_pos); in PushActiveIter()
248 auto active_top = active_iters_.top(); in PopActiveIter()
250 active_iters_.pop(); in PopActiveIter()
268 BinaryHeap<ActiveSeqSet::const_iterator, StartKeyMaxComparator> active_iters_; variable