Home
last modified time | relevance | path

Searched refs:iter_ (Results 1 – 20 of 20) sorted by relevance

/rocksdb-6.9/table/
Diterator_wrapper.h39 iter_ = _iter; in Set()
49 if (iter_) { in DeleteIter()
70 assert(iter_); in status()
74 assert(iter_); in Next()
79 assert(iter_); in Prev()
80 iter_->Prev(); in Prev()
84 assert(iter_); in Seek()
89 assert(iter_); in SeekForPrev()
94 assert(iter_); in SeekToFirst()
99 assert(iter_); in SeekToLast()
[all …]
Dscoped_arena_iterator.h17 if (iter_ != nullptr) { in reset()
20 iter_ = iter; in reset()
26 : iter_(iter) {} in iter_() function
32 iter_ = o.iter_; in ScopedArenaIterator()
33 o.iter_ = nullptr; in ScopedArenaIterator()
37 reset(o.iter_);
38 o.iter_ = nullptr;
48 assert(iter_ != nullptr); in release()
49 auto* res = iter_; in release()
50 iter_ = nullptr; in release()
[all …]
Dtable_test.cc260 : iter_(iter), arena_mode_(arena_mode) {} in KeyConvertingIterator()
263 iter_->~InternalIterator(); in ~KeyConvertingIterator()
265 delete iter_; in ~KeyConvertingIterator()
273 iter_->Seek(encoded); in Seek()
279 iter_->SeekForPrev(encoded); in SeekForPrev()
281 void SeekToFirst() override { iter_->SeekToFirst(); } in SeekToFirst()
282 void SeekToLast() override { iter_->SeekToLast(); } in SeekToLast()
283 void Next() override { iter_->Next(); } in Next()
284 void Prev() override { iter_->Prev(); } in Prev()
299 return status_.ok() ? iter_->status() : status_; in status()
[all …]
/rocksdb-6.9/db/
Ddb_iter.cc48 iter_(iter), in DBIter()
81 if (iter_.iter()) { in DBIter()
143 iter_.Next(); in Next()
469 for (iter_.Next(); iter_.Valid(); iter_.Next()) { in MergeValuesNewToOld()
611 iter_.Next(); in ReverseToForward()
645 if (!iter_.Valid() && iter_.status().ok()) { in ReverseToBackward()
798 iter_.Prev(); in FindValueForCurrentKey()
917 iter_.Next(); in FindValueForCurrentKeyUsingSeek()
950 iter_.Next(); in FindValueForCurrentKeyUsingSeek()
1022 if (!iter_.Valid() && iter_.status().ok()) { in FindValueForCurrentKeyUsingSeek()
[all …]
Dmerge_helper_test.cc28 iter_->SeekToFirst(); in Run()
66 ASSERT_EQ(ks_[2], iter_->key()); in TEST_F()
83 ASSERT_EQ(ks_[3], iter_->key()); in TEST_F()
101 ASSERT_EQ(ks_[2], iter_->key()); in TEST_F()
134 ASSERT_FALSE(iter_->Valid()); in TEST_F()
149 ASSERT_FALSE(iter_->Valid()); in TEST_F()
186 ASSERT_FALSE(iter_->Valid()); in TEST_F()
209 ASSERT_FALSE(iter_->Valid()); in TEST_F()
219 ASSERT_TRUE(iter_->Valid()); in TEST_F()
244 ASSERT_TRUE(iter_->Valid()); in TEST_F()
[all …]
Drange_del_aggregator.cc29 : iter_(std::move(iter)), in TruncatedRangeDelIterator()
73 return iter_->Valid() && in Valid()
91 iter_->Invalidate(); in Seek()
96 iter_->Seek(smallest_->user_key); in Seek()
99 iter_->Seek(target); in Seek()
107 iter_->Invalidate(); in SeekForPrev()
112 iter_->SeekForPrev(largest_->user_key); in SeekForPrev()
115 iter_->SeekForPrev(target); in SeekForPrev()
120 iter_->Seek(smallest_->user_key); in SeekToFirst()
123 iter_->SeekToTopFirst(); in SeekToFirst()
[all …]
Dcomparator_db_test.cc29 : map_(map), iter_(map_->end()) {} in KVIter()
34 iter_ = map_->end(); in SeekToLast()
36 iter_ = map_->find(map_->rbegin()->first); in SeekToLast()
40 iter_ = map_->lower_bound(k.ToString()); in Seek()
43 iter_ = map_->upper_bound(k.ToString()); in SeekForPrev()
46 void Next() override { ++iter_; } in Next()
48 if (iter_ == map_->begin()) { in Prev()
49 iter_ = map_->end(); in Prev()
52 --iter_; in Prev()
55 Slice key() const override { return iter_->first; } in key()
[all …]
Dmemtable.cc311 iter_->~Iterator(); in ~MemTableIterator()
313 delete iter_; in ~MemTableIterator()
340 iter_->Seek(k, nullptr); in Seek()
341 valid_ = iter_->Valid(); in Seek()
357 iter_->Seek(k, nullptr); in SeekForPrev()
358 valid_ = iter_->Valid(); in SeekForPrev()
367 iter_->SeekToFirst(); in SeekToFirst()
368 valid_ = iter_->Valid(); in SeekToFirst()
371 iter_->SeekToLast(); in SeekToLast()
377 iter_->Next(); in Next()
[all …]
Ddb_iter.h134 iter_.DeleteIter(arena_mode_); in ~DBIter()
137 assert(iter_.iter() == nullptr); in SetIter()
138 iter_.Set(iter); in SetIter()
139 iter_.iter()->SetPinnedItersMgr(&pinned_iters_mgr_); in SetIter()
162 return iter_.value(); in value()
167 return iter_.status(); in status()
278 IteratorWrapper iter_; variable
Drange_del_aggregator.h61 icmp_->Compare(*smallest_, iter_->parsed_start_key()) <= 0) in start_key()
62 ? iter_->parsed_start_key() in start_key()
68 icmp_->Compare(iter_->parsed_end_key(), *largest_) <= 0) in end_key()
69 ? iter_->parsed_end_key() in end_key()
73 SequenceNumber seq() const { return iter_->seq(); } in seq()
78 SequenceNumber upper_bound() const { return iter_->upper_bound(); } in upper_bound()
80 SequenceNumber lower_bound() const { return iter_->lower_bound(); } in lower_bound()
83 std::unique_ptr<FragmentedRangeTombstoneIterator> iter_;
Ddb_iter_test.cc38 iter_(0), in TestIterator()
75 iter_++; in Add()
108 --iter_; in Vanish()
129 iter_ = 0; in SeekToFirst()
137 iter_ = data_.size() - 1; in SeekToLast()
149 ++iter_; in Seek()
172 ++iter_; in Next()
184 if (iter_ == 0) { in Prev()
187 --iter_; in Prev()
193 return data_[iter_].first; in key()
[all …]
Ddb_test.cc2985 : map_(map), owned_(owned), iter_(map_->end()) {} in ModelIter()
2993 iter_ = map_->end(); in SeekToLast()
2995 iter_ = map_->find(map_->rbegin()->first); in SeekToLast()
2999 iter_ = map_->lower_bound(k.ToString()); in Seek()
3002 iter_ = map_->upper_bound(k.ToString()); in SeekForPrev()
3005 void Next() override { ++iter_; } in Next()
3007 if (iter_ == map_->begin()) { in Prev()
3008 iter_ = map_->end(); in Prev()
3011 --iter_; in Prev()
3014 Slice key() const override { return iter_->first; } in key()
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_db_iterator.h25 iter_(iter), in BlobDBIterator()
51 iter_->Next(); in SeekToFirst()
58 iter_->SeekToLast(); in SeekToLast()
60 iter_->Prev(); in SeekToLast()
69 iter_->Next(); in Seek()
78 iter_->Prev(); in SeekForPrev()
86 iter_->Next(); in Next()
88 iter_->Next(); in Next()
96 iter_->Prev(); in Prev()
98 iter_->Prev(); in Prev()
[all …]
/rocksdb-6.9/memtable/
Dskiplistrep.cc109 : iter_(list) {} in Iterator()
165 rep_(rep), iter_(&rep_.skip_list_), prev_(iter_) {} in LookaheadIterator()
196 prev_ = iter_; in Next()
198 iter_.Next(); in Next()
203 iter_.Prev(); in Prev()
204 prev_ = iter_; in Prev()
215 iter_ = prev_; in Seek()
227 prev_ = iter_; in Seek()
236 prev_ = iter_; in SeekForPrev()
241 prev_ = iter_; in SeekToFirst()
[all …]
Dhash_skiplist_rep.cc85 : list_(list), iter_(list), own_list_(own_list), arena_(arena) {} in Iterator()
96 bool Valid() const override { return list_ != nullptr && iter_.Valid(); } in Valid()
102 return iter_.key(); in key()
109 iter_.Next(); in Next()
116 iter_.Prev(); in Prev()
125 iter_.Seek(encoded_key); in Seek()
140 iter_.SeekToFirst(); in SeekToFirst()
148 iter_.SeekToLast(); in SeekToLast()
159 iter_.SetList(list); in Reset()
166 Bucket::Iterator iter_; member in ROCKSDB_NAMESPACE::__anon252bdc020111::HashSkipListRep::Iterator
Dhash_linklist_rep.cc264 : iter_(list), full_list_(list), allocator_(allocator) {} in FullListIterator()
269 bool Valid() const override { return iter_.Valid(); } in Valid()
275 return iter_.key(); in key()
282 iter_.Next(); in Next()
289 iter_.Prev(); in Prev()
297 iter_.Seek(encoded_key); in Seek()
306 iter_.SeekForPrev(encoded_key); in SeekForPrev()
311 void SeekToFirst() override { iter_.SeekToFirst(); } in SeekToFirst()
315 void SeekToLast() override { iter_.SeekToLast(); } in SeekToLast()
318 MemtableSkipList::Iterator iter_; member in ROCKSDB_NAMESPACE::__anoncfd1c5190111::HashLinkListRep::FullListIterator
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.h112 explicit TtlIterator(Iterator* iter) : iter_(iter) { assert(iter_); } in TtlIterator()
114 ~TtlIterator() { delete iter_; } in ~TtlIterator() local
116 bool Valid() const override { return iter_->Valid(); } in Valid()
118 void SeekToFirst() override { iter_->SeekToFirst(); } in SeekToFirst()
120 void SeekToLast() override { iter_->SeekToLast(); } in SeekToLast()
126 void Next() override { iter_->Next(); } in Next()
128 void Prev() override { iter_->Prev(); } in Prev()
130 Slice key() const override { return iter_->key(); } in key()
133 return DecodeFixed32(iter_->value().data() + iter_->value().size() - in ttl_timestamp()
140 Slice trimmed_value = iter_->value(); in value()
[all …]
/rocksdb-6.9/table/block_based/
Dblock_test.cc240 if (offset < iter_->second) { in IsPinMarked()
243 if (offset <= iter_->first) { in IsPinMarked()
247 iter_++; in IsPinMarked()
248 if (iter_ == marked_ranges_.end()) { in IsPinMarked()
256 iter_ = marked_ranges_.lower_bound( in IsPinMarked()
258 if (iter_ == marked_ranges_.end()) { in IsPinMarked()
263 return offset <= iter_->first && offset >= iter_->second; in IsPinMarked()
268 std::set<std::pair<size_t, size_t>>::iterator iter_; member in ROCKSDB_NAMESPACE::BlockReadAmpBitmapSlowAndAccurate
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc510 void SeekToFirst() override { iter_ = map_->begin(); } in SeekToFirst()
513 iter_ = map_->end(); in SeekToLast()
515 iter_ = map_->find(map_->rbegin()->first); in SeekToLast()
519 iter_ = map_->lower_bound(k.ToString()); in Seek()
522 iter_ = map_->upper_bound(k.ToString()); in SeekForPrev()
525 void Next() override { ++iter_; } in Next()
527 if (iter_ == map_->begin()) { in Prev()
528 iter_ = map_->end(); in Prev()
531 --iter_; in Prev()
534 Slice key() const override { return iter_->first; } in key()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_iterator_test.cc252 iter_.reset(new LoggingForwardVectorIterator(ks, vs)); in InitIterators()
253 iter_->SeekToFirst(); in InitIterators()
255 iter_.get(), cmp_, merge_helper_.get(), last_sequence, &snapshots_, in InitIterators()
300 std::unique_ptr<LoggingForwardVectorIterator> iter_; member in ROCKSDB_NAMESPACE::CompactionIteratorTest
482 ASSERT_EQ(expected_actions, iter_->log); in TEST_P()