Home
last modified time | relevance | path

Searched refs:Iterator (Results 1 – 25 of 133) sorted by relevance

123456

/rocksdb-6.9/memtable/
Dvectorrep.cc48 class Iterator : public MemTableRep::Iterator { class in ROCKSDB_NAMESPACE::__anonfd4f76000111::VectorRep
57 explicit Iterator(class VectorRep* vrep,
64 ~Iterator() override{}; in ~Iterator()
100 friend class Iterator;
146 VectorRep::Iterator::Iterator(class VectorRep* vrep, in Iterator() function in ROCKSDB_NAMESPACE::__anonfd4f76000111::VectorRep::Iterator
155 void VectorRep::Iterator::DoSort() const { in DoSort()
176 bool VectorRep::Iterator::Valid() const { in Valid()
190 void VectorRep::Iterator::Next() { in Next()
200 void VectorRep::Iterator::Prev() { in Prev()
235 void VectorRep::Iterator::SeekToFirst() { in SeekToFirst()
[all …]
Dhash_skiplist_rep.cc44 MemTableRep::Iterator* GetDynamicPrefixIterator(
81 class Iterator : public MemTableRep::Iterator { class in ROCKSDB_NAMESPACE::__anon252bdc020111::HashSkipListRep
87 ~Iterator() override { in ~Iterator()
166 Bucket::Iterator iter_;
177 : HashSkipListRep::Iterator(nullptr, false), in DynamicIterator()
184 HashSkipListRep::Iterator::Seek(k, memtable_key); in Seek()
208 class EmptyIterator : public MemTableRep::Iterator {
294 Bucket::Iterator iter(bucket); in Get()
309 Bucket::Iterator itr(bucket); in GetIterator()
316 return new Iterator(list, true, new_arena); in GetIterator()
[all …]
Dskiplistrep.cc82 SkipListRep::Iterator iter(&skip_list_); in Get()
101 class Iterator : public MemTableRep::Iterator { class in ROCKSDB_NAMESPACE::__anon1cbf76c00111::SkipListRep
102 InlineSkipList<const MemTableRep::KeyComparator&>::Iterator iter_;
107 explicit Iterator( in Iterator() function in ROCKSDB_NAMESPACE::__anon1cbf76c00111::SkipListRep::Iterator
111 ~Iterator() override {} in ~Iterator()
162 class LookaheadIterator : public MemTableRep::Iterator {
254 InlineSkipList<const MemTableRep::KeyComparator&>::Iterator iter_;
255 InlineSkipList<const MemTableRep::KeyComparator&>::Iterator prev_;
266 arena ? arena->AllocateAligned(sizeof(SkipListRep::Iterator)) in GetIterator()
267 : operator new(sizeof(SkipListRep::Iterator)); in GetIterator()
[all …]
Dskiplist.h69 class Iterator {
73 explicit Iterator(const SkipList* list);
212 inline SkipList<Key, Comparator>::Iterator::Iterator(const SkipList* list) {
223 inline bool SkipList<Key, Comparator>::Iterator::Valid() const {
228 inline const Key& SkipList<Key, Comparator>::Iterator::key() const {
234 inline void SkipList<Key, Comparator>::Iterator::Next() {
240 inline void SkipList<Key, Comparator>::Iterator::Prev() {
251 inline void SkipList<Key, Comparator>::Iterator::Seek(const Key& target) {
256 inline void SkipList<Key, Comparator>::Iterator::SeekForPrev(
268 inline void SkipList<Key, Comparator>::Iterator::SeekToFirst() {
[all …]
Dhash_linklist_rep.cc184 MemTableRep::Iterator* GetIterator(Arena* arena = nullptr) override;
186 MemTableRep::Iterator* GetDynamicPrefixIterator(
261 class FullListIterator : public MemTableRep::Iterator {
318 MemtableSkipList::Iterator iter_;
325 class LinkListIterator : public MemTableRep::Iterator {
468 std::unique_ptr<MemtableSkipList::Iterator> skip_list_iter_;
471 class EmptyIterator : public MemTableRep::Iterator {
723 MemtableSkipList::Iterator iter(&skip_list_header->skip_list); in Get()
740 MemTableRep::Iterator* HashLinkListRep::GetIterator(Arena* alloc_arena) { in GetIterator()
753 MemtableSkipList::Iterator itr(&skip_list_header->skip_list); in GetIterator()
[all …]
Dinlineskiplist.h148 class Iterator {
152 explicit Iterator(const InlineSkipList* list);
358 inline InlineSkipList<Comparator>::Iterator::Iterator(
364 inline void InlineSkipList<Comparator>::Iterator::SetList(
371 inline bool InlineSkipList<Comparator>::Iterator::Valid() const {
376 inline const char* InlineSkipList<Comparator>::Iterator::key() const {
382 inline void InlineSkipList<Comparator>::Iterator::Next() {
388 inline void InlineSkipList<Comparator>::Iterator::Prev() {
404 inline void InlineSkipList<Comparator>::Iterator::SeekForPrev(
416 inline void InlineSkipList<Comparator>::Iterator::SeekToFirst() {
[all …]
Dskiplist_test.cc42 SkipList<Key, TestComparator>::Iterator iter(&list); in TEST_F()
79 SkipList<Key, TestComparator>::Iterator iter(&list); in TEST_F()
101 SkipList<Key, TestComparator>::Iterator iter(&list); in TEST_F()
121 SkipList<Key, TestComparator>::Iterator iter(&list); in TEST_F()
245 SkipList<Key, TestComparator>::Iterator iter(&list_); in ReadStep()
/rocksdb-6.9/table/
Dmultiget_context.h146 class Iterator {
149 typedef Iterator self_type;
164 Iterator(const Iterator&) = default;
165 Iterator& operator=(const Iterator&) = default;
167 Iterator& operator++() {
205 const Iterator& first, in Range()
206 const Iterator& last) { in Range()
215 Iterator begin() const { return Iterator(this, start_); } in begin()
217 Iterator end() const { return Iterator(this, end_); } in end()
228 void MarkKeyDone(Iterator& iter) { in MarkKeyDone()
[all …]
Diterator.cc98 Status Iterator::GetProperty(std::string prop_name, std::string* prop) { in GetProperty()
110 class EmptyIterator : public Iterator {
160 Iterator* NewEmptyIterator() { return new EmptyIterator(Status::OK()); } in NewEmptyIterator()
162 Iterator* NewErrorIterator(const Status& status) { in NewErrorIterator()
/rocksdb-6.9/java/rocksjni/
Diterator.cc26 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_RocksIterator_disposeInternal()
61 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->SeekToLast(); in Java_org_rocksdb_RocksIterator_seekToLast0()
71 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->Next(); in Java_org_rocksdb_RocksIterator_next0()
81 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->Prev(); in Java_org_rocksdb_RocksIterator_prev0()
101 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_RocksIterator_seek0()
116 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_RocksIterator_seekDirect0()
132 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_RocksIterator_seekForPrevDirect0()
158 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_RocksIterator_seekForPrev0()
171 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_RocksIterator_status0()
188 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_RocksIterator_key0()
[all …]
Dsst_file_reader_iterator.cc25 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_SstFileReaderIterator_disposeInternal()
60 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->SeekToLast(); in Java_org_rocksdb_SstFileReaderIterator_seekToLast0()
71 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->Next(); in Java_org_rocksdb_SstFileReaderIterator_next0()
82 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->Prev(); in Java_org_rocksdb_SstFileReaderIterator_prev0()
103 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_SstFileReaderIterator_seek0()
128 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_SstFileReaderIterator_seekForPrev0()
142 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_SstFileReaderIterator_status0()
160 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_SstFileReaderIterator_key0()
181 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_SstFileReaderIterator_value0()
203 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_SstFileReaderIterator_keyDirect0()
[all …]
/rocksdb-6.9/include/rocksdb/
Diterator.h28 class Iterator : public Cleanable {
30 Iterator() {} in Iterator() function
32 Iterator(const Iterator&) = delete;
33 void operator=(const Iterator&) = delete;
35 virtual ~Iterator() {} in ~Iterator()
123 extern Iterator* NewEmptyIterator();
126 extern Iterator* NewErrorIterator(const Status& status);
Dmemtablerep.h204 class Iterator {
209 virtual ~Iterator() {} in ~Iterator()
247 virtual Iterator* GetIterator(Arena* arena = nullptr) = 0;
255 virtual Iterator* GetDynamicPrefixIterator(Arena* arena = nullptr) {
/rocksdb-6.9/db/
Ddb_tailing_iter_test.cc30 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
49 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options, handles_[1])); in TEST_F()
71 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options, handles_[1])); in TEST_F()
72 std::unique_ptr<Iterator> itern(db_->NewIterator(read_options, handles_[1])); in TEST_F()
139 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options, handles_[1])); in TEST_F()
340 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
370 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
405 std::unique_ptr<Iterator> it(db_->NewIterator(read_options, handles_[1])); in TEST_F()
468 std::unique_ptr<Iterator> it(db_->NewIterator(read_options, handles_[1])); in TEST_F()
497 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
[all …]
Ddb_iter_test.cc252 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
285 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
312 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
345 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
381 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
411 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
705 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
1352 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
1380 std::unique_ptr<Iterator> db_iter(NewDBIterator( in TEST_F()
2592 Iterator* merge_iter_;
[all …]
Dwrite_thread.h86 struct Iterator { struct
90 explicit Iterator(Writer* w, Writer* last) in Iterator() function
95 Iterator& operator++() {
105 bool operator!=(const Iterator& other) const {
110 Iterator begin() const { return Iterator(leader, last_writer); } in begin()
111 Iterator end() const { return Iterator(nullptr, nullptr); } in end()
Ddb_iterator_test.cc103 std::vector<Iterator*> iters; in TEST_P()
1718 Iterator* iter = NewIterator(ro); in TEST_P()
1736 Iterator* iter = NewIterator(ro); in TEST_P()
1773 Iterator* iter = NewIterator(ro); in TEST_P()
1791 Iterator* iter = NewIterator(ro); in TEST_P()
1840 Iterator* iter = NewIterator(ro); in TEST_P()
1942 Iterator* iter = NewIterator(ro); in TEST_P()
1958 Iterator* iter = NewIterator(ro); in TEST_P()
2361 Iterator* iter = NewIterator(ro); in TEST_P()
2468 Iterator* iter = NewIterator(ro); in TEST_P()
[all …]
Ddb_bloom_filter_test.cc1266 Iterator* iter; in TEST_F()
1501 int CountIter(std::unique_ptr<Iterator>& iter, const Slice& key) { in CountIter()
1542 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
1550 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
1564 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
1578 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
1591 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
1606 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
1678 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
1808 std::unique_ptr<Iterator> iter( in TEST_F()
[all …]
Ddeletefile_test.cc210 Iterator *itr = nullptr; in TEST_F()
235 Iterator* itr = nullptr; in TEST_F()
341 Iterator* itr = nullptr; in TEST_F()
384 Iterator* itr1 = db_->NewIterator(read_options); in TEST_F()
386 Iterator* itr2 = db_->NewIterator(read_options); in TEST_F()
419 Iterator* it = db_->NewIterator(read_options); in TEST_F()
522 std::unique_ptr<Iterator> itr(db_->NewIterator(ReadOptions(), handles_[1])); in TEST_F()
535 std::unique_ptr<Iterator> itr(db_->NewIterator(ReadOptions(), handles_[1])); in TEST_F()
/rocksdb-6.9/utilities/option_change_migration/
Doption_change_migration_test.cc77 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
104 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
145 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
172 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
220 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
247 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
294 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
321 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
384 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_F()
407 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_secondary_test.cc127 Iterator* iter = db1->NewIterator(ropts); in TEST_F()
170 Iterator* iter = db_secondary_->NewIterator(ropts); in TEST_F()
250 std::unique_ptr<Iterator> iter1(dbfull()->NewIterator(ReadOptions())); in TEST_F()
305 Iterator* iter = db_secondary_->NewIterator(ropts); in TEST_F()
433 Iterator* iter = db_secondary_->NewIterator(ropts); in TEST_F()
505 Iterator* iter = db_secondary_->NewIterator(ropts); in TEST_F()
660 std::unique_ptr<Iterator> it1(db1->NewIterator(read_opts)); in TEST_F()
661 std::unique_ptr<Iterator> it2(db2->NewIterator(read_opts)); in TEST_F()
778 std::unique_ptr<Iterator> iter1(db_secondary_->NewIterator(read_opts)); in TEST_F()
788 std::unique_ptr<Iterator> iter2(db_secondary_->NewIterator(read_opts)); in TEST_F()
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Dwrite_batch_with_index.h175 Iterator* NewIteratorWithBase(ColumnFamilyHandle* column_family,
176 Iterator* base_iterator,
179 Iterator* NewIteratorWithBase(Iterator* base_iterator);
/rocksdb-6.9/db/blob/
Ddb_blob_index_test.cc254 auto check_iterator = [&](Iterator* iterator, Status::Code expected_status, in TEST_F()
265 auto create_normal_iterator = [&]() -> Iterator* { in TEST_F()
269 auto create_blob_iterator = [&]() -> Iterator* { return GetBlobIterator(); }; in TEST_F()
272 return [is_blob](Iterator* iterator) { in TEST_F()
280 std::function<Iterator*()> create_iterator, in TEST_F()
281 std::function<void(Iterator*)> extra_check = nullptr) { in TEST_F()
/rocksdb-6.9/java/
DHISTORY-JAVA.md23 * Iterator support for WriteBatch and WriteBatchWithIndex
49 * Renamed org.rocksdb.Iterator to org.rocksdb.RocksIterator to avoid potential confliction with Jav…
60 * Added Java binding for RocksDB Iterator which enables sequential scan operation.
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn.h163 void RemoveActiveIterator(Iterator* iter) { in RemoveActiveIterator()
200 virtual Iterator* GetIterator(const ReadOptions& options) override;
201 virtual Iterator* GetIterator(const ReadOptions& options,
320 std::vector<Iterator*> active_iterators_;

123456