Home
last modified time | relevance | path

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

/rocksdb-6.9/db/
Drange_del_aggregator.cc160 active_seqnums_(SeqMaxComparator()), in ForwardRangeDelIterator()
173 assert(active_iters_.size() == active_seqnums_.size()); in ShouldDelete()
184 assert(active_iters_.size() == active_seqnums_.size()); in ShouldDelete()
187 return active_seqnums_.empty() in ShouldDelete()
189 : (*active_seqnums_.begin())->seq() > parsed.sequence; in ShouldDelete()
195 active_seqnums_.clear(); in Invalidate()
203 active_seqnums_(SeqMaxComparator()), in ReverseRangeDelIterator()
216 assert(active_iters_.size() == active_seqnums_.size()); in ShouldDelete()
227 assert(active_iters_.size() == active_seqnums_.size()); in ShouldDelete()
230 return active_seqnums_.empty() in ShouldDelete()
[all …]
Drange_del_aggregator.h122 assert(active_iters_.size() == active_seqnums_.size()); in AddNewIter()
159 auto seq_pos = active_seqnums_.insert(iter); in PushActiveIter()
167 active_seqnums_.erase(active_top); in PopActiveIter()
183 ActiveSeqSet active_seqnums_; variable
199 assert(active_iters_.size() == active_seqnums_.size()); in AddNewIter()
243 auto seq_pos = active_seqnums_.insert(iter); in PushActiveIter()
251 active_seqnums_.erase(active_top); in PopActiveIter()
267 ActiveSeqSet active_seqnums_; variable