Home
last modified time | relevance | path

Searched refs:it (Results 1 – 25 of 153) sorted by relevance

1234567

/rocksdb-6.9/utilities/option_change_migration/
Doption_change_migration_test.cc78 it->SeekToFirst(); in TEST_P()
79 for (; it->Valid(); it->Next()) { in TEST_P()
109 it->Next(); in TEST_P()
147 for (; it->Valid(); it->Next()) { in TEST_P()
177 it->Next(); in TEST_P()
222 for (; it->Valid(); it->Next()) { in TEST_P()
252 it->Next(); in TEST_P()
296 for (; it->Valid(); it->Next()) { in TEST_P()
326 it->Next(); in TEST_P()
386 for (; it->Valid(); it->Next()) { in TEST_F()
[all …]
/rocksdb-6.9/java/rocksjni/
Diterator.cc27 assert(it != nullptr); in Java_org_rocksdb_RocksIterator_disposeInternal()
28 delete it; in Java_org_rocksdb_RocksIterator_disposeInternal()
102 it->Seek(target_slice); in Java_org_rocksdb_RocksIterator_seek0()
118 it->Seek(target_slice); in Java_org_rocksdb_RocksIterator_seekDirect0()
134 it->SeekForPrev(target_slice); in Java_org_rocksdb_RocksIterator_seekForPrevDirect0()
159 it->SeekForPrev(target_slice); in Java_org_rocksdb_RocksIterator_seekForPrev0()
172 ROCKSDB_NAMESPACE::Status s = it->status(); in Java_org_rocksdb_RocksIterator_status0()
189 ROCKSDB_NAMESPACE::Slice key_slice = it->key(); in Java_org_rocksdb_RocksIterator_key0()
212 ROCKSDB_NAMESPACE::Slice key_slice = it->key(); in Java_org_rocksdb_RocksIterator_keyDirect0()
225 ROCKSDB_NAMESPACE::Slice value_slice = it->value(); in Java_org_rocksdb_RocksIterator_value0()
[all …]
Dsst_file_reader_iterator.cc26 assert(it != nullptr); in Java_org_rocksdb_SstFileReaderIterator_disposeInternal()
27 delete it; in Java_org_rocksdb_SstFileReaderIterator_disposeInternal()
104 it->Seek(target_slice); in Java_org_rocksdb_SstFileReaderIterator_seek0()
129 it->SeekForPrev(target_slice); in Java_org_rocksdb_SstFileReaderIterator_seekForPrev0()
143 ROCKSDB_NAMESPACE::Status s = it->status(); in Java_org_rocksdb_SstFileReaderIterator_status0()
161 ROCKSDB_NAMESPACE::Slice key_slice = it->key(); in Java_org_rocksdb_SstFileReaderIterator_key0()
182 ROCKSDB_NAMESPACE::Slice value_slice = it->value(); in Java_org_rocksdb_SstFileReaderIterator_value0()
204 ROCKSDB_NAMESPACE::Slice key_slice = it->key(); in Java_org_rocksdb_SstFileReaderIterator_keyDirect0()
218 ROCKSDB_NAMESPACE::Slice value_slice = it->value(); in Java_org_rocksdb_SstFileReaderIterator_valueDirect0()
233 it->Seek(target_slice); in Java_org_rocksdb_SstFileReaderIterator_seekDirect0()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWriteBatchWithIndexTest.java48 it.seek(k1); in readYourOwnWrites()
53 it.seek(k2); in readYourOwnWrites()
62 it.seek(k3); in readYourOwnWrites()
70 it.seek(k2); in readYourOwnWrites()
77 it.seek(k1); in readYourOwnWrites()
83 it.seek(k1); in readYourOwnWrites()
90 it.seek(k3); in readYourOwnWrites()
96 it.seek(k3); in readYourOwnWrites()
229 it.seek(db); in iterator()
236 for (it.seekToFirst(); it.isValid(); it.next()) { in iterator()
[all …]
/rocksdb-6.9/utilities/merge_operators/string_append/
Dstringappend2.cc38 for (auto it = merge_in.operand_list.begin(); in FullMergeV2() local
39 it != merge_in.operand_list.end(); ++it) { in FullMergeV2()
40 numBytes += it->size() + 1; // Plus 1 for the delimiter in FullMergeV2()
58 for (auto it = merge_in.operand_list.begin(); in FullMergeV2() local
59 it != merge_in.operand_list.end(); ++it) { in FullMergeV2()
63 merge_out->new_value.append(it->data(), it->size()); in FullMergeV2()
98 for (std::deque<Slice>::const_iterator it = operand_list.begin() + 1; in _AssocPartialMergeMulti() local
99 it != operand_list.end(); ++it) { in _AssocPartialMergeMulti()
101 new_value->append(it->data(), it->size()); in _AssocPartialMergeMulti()
Dstringappend_test.cc150 for (it->Seek(k1); it->Valid(); it->Next()) { in TEST_F()
151 res = it->value().ToString(); in TEST_F()
164 for (it->Seek(k1); it->Valid(); it->Next()) { in TEST_F()
165 res = it->value().ToString(); in TEST_F()
178 for (it->Seek(k1); it->Valid(); it->Next()) { in TEST_F()
179 res = it->value().ToString(); in TEST_F()
189 for (it->Seek(k2); it->Valid(); it->Next()) { in TEST_F()
190 res = it->value().ToString(); in TEST_F()
204 for(it->Seek(k2); it->Valid(); it->Next()) { in TEST_F()
205 res = it->value().ToString(); in TEST_F()
[all …]
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader_test.cc155 ASSERT_OK(it->status()); in CheckIterator()
157 it->SeekToFirst(); in CheckIterator()
159 while (it->Valid()) { in CheckIterator()
164 it->Next(); in CheckIterator()
168 it->SeekToLast(); in CheckIterator()
171 while (it->Valid()) { in CheckIterator()
176 it->Prev(); in CheckIterator()
181 it->Seek(keys[cnt]); in CheckIterator()
182 while (it->Valid()) { in CheckIterator()
187 it->Next(); in CheckIterator()
[all …]
/rocksdb-6.9/util/
Dfile_checksum_helper.cc41 auto it = checksum_map_.find(file_number); in SearchOneFileChecksum() local
42 if (it == checksum_map_.end()) { in SearchOneFileChecksum()
45 *checksum = it->second.first; in SearchOneFileChecksum()
46 *checksum_func_name = it->second.second; in SearchOneFileChecksum()
54 auto it = checksum_map_.find(file_number); in InsertOneFileChecksum() local
55 if (it == checksum_map_.end()) { in InsertOneFileChecksum()
59 it->second.first = checksum; in InsertOneFileChecksum()
60 it->second.second = checksum_func_name; in InsertOneFileChecksum()
66 auto it = checksum_map_.find(file_number); in RemoveOneFileChecksum() local
67 if (it == checksum_map_.end()) { in RemoveOneFileChecksum()
[all …]
Dhash_map.h33 auto it = std::find_if( in Contains() local
36 return it != bucket.end(); in Contains()
46 auto it = std::find_if( in Delete() local
49 if (it != bucket.end()) { in Delete()
51 if (it != last) { in Delete()
52 *it = *last; in Delete()
60 auto it = std::find_if( in Get() local
63 return it->second; in Get()
/rocksdb-6.9/utilities/persistent_cache/
Dhash_table.h176 for (auto it = list->begin(); it != list->end(); ++it) { in Find() local
177 if (Equal()(*it, t)) { in Find()
178 return it; in Find()
186 auto it = Find(&bucket->list_, t); in Insert() local
187 if (it != bucket->list_.end()) { in Insert()
197 auto it = Find(&bucket->list_, t); in Find() local
198 if (it != bucket->list_.end()) { in Find()
200 *ret = *it; in Find()
209 if (it != bucket->list_.end()) { in Erase()
211 *ret = *it; in Erase()
[all …]
/rocksdb-6.9/db/
Dlogs_with_prep_tracker.cc14 auto it = prepared_section_completed_.find(log); in MarkLogAsHavingPrepSectionFlushed() local
15 if (UNLIKELY(it == prepared_section_completed_.end())) { in MarkLogAsHavingPrepSectionFlushed()
18 it->second += 1; in MarkLogAsHavingPrepSectionFlushed()
45 auto it = logs_with_prep_.begin(); in FindMinLogContainingOutstandingPrep() local
47 for (; it != logs_with_prep_.end();) { in FindMinLogContainingOutstandingPrep()
48 auto min_log = it->log; in FindMinLogContainingOutstandingPrep()
53 completed_it->second < it->cnt) { in FindMinLogContainingOutstandingPrep()
57 completed_it->second == it->cnt); in FindMinLogContainingOutstandingPrep()
62 it = logs_with_prep_.erase(it); in FindMinLogContainingOutstandingPrep()
Ddb_tailing_iter_test.cc406 it->Seek("12"); in TEST_F()
407 ASSERT_TRUE(it->Valid()); in TEST_F()
410 it->Next(); in TEST_F()
412 ASSERT_FALSE(it->Valid()); in TEST_F()
422 it->Seek("13"); in TEST_F()
469 it->Seek("30"); in TEST_F()
470 ASSERT_TRUE(it->Valid()); in TEST_F()
473 it->Next(); in TEST_F()
474 ASSERT_TRUE(it->Valid()); in TEST_F()
477 it->Next(); in TEST_F()
[all …]
Drange_del_aggregator.cc253 it != iters_.end(); ++it, forward_iter_.IncUnusedIdx()) { in ShouldDelete()
254 auto& iter = *it; in ShouldDelete()
264 it != iters_.end(); ++it, reverse_iter_.IncUnusedIdx()) { in ShouldDelete()
265 auto& iter = *it; in ShouldDelete()
349 auto it = reps_.find(split_iter.first); in AddTombstones() local
350 if (it == reps_.end()) { in AddTombstones()
354 std::tie(it, inserted) = reps_.emplace( in AddTombstones()
358 assert(it != reps_.end()); in AddTombstones()
365 auto it = reps_.lower_bound(parsed.sequence); in ShouldDelete() local
366 if (it == reps_.end()) { in ShouldDelete()
[all …]
Ddb_iter_stress_test.cc199 auto it = std::partition_point( in Seek() local
211 auto it = std::partition_point( in SeekForPrev() local
280 if (it != data->entries.end()) { in FindNextKey()
281 key = it->key; in FindNextKey()
286 --it; in FindNextKey()
287 key = it->key; in FindNextKey()
309 for (;; ++it) { in FindValueForCurrentKey()
310 if (it == data->entries.end()) { in FindValueForCurrentKey()
313 Entry& e = *it; in FindValueForCurrentKey()
333 for (; it != data->entries.end(); ++it) { in FindValueForCurrentKey()
[all …]
Ddb_with_timestamp_basic_test.cc139 ASSERT_TRUE(it->Valid()); in CheckIterUserEntry()
140 ASSERT_OK(it->status()); in CheckIterUserEntry()
149 ASSERT_TRUE(it->Valid()); in CheckIterEntry()
150 ASSERT_OK(it->status()); in CheckIterEntry()
157 ASSERT_EQ(Slice(ikey), it->key()); in CheckIterEntry()
205 for (it->Seek(Key1(0)), key = start_keys[i]; it->Valid(); in TEST_F()
226 it->Valid(); it->Next(), ++key, ++count) { in TEST_F()
843 it->Seek(Key1(targets[j])); in TEST_P()
844 while (it->Valid()) { in TEST_P()
846 saved_prev_key.assign(it->key().data(), it->key().size()); in TEST_P()
[all …]
Dmemtable_list.cc342 for (auto it = memlist.rbegin(); it != memlist.rend(); ++it) { in PickMemtablesToFlush() local
343 MemTable* m = *it; in PickMemtablesToFlush()
440 for (auto it = memlist.rbegin(); it != memlist.rend(); ++it) { in TryInstallMemtableFlushResults() local
441 MemTable* m = *it; in TryInstallMemtableFlushResults()
445 if (it == memlist.rbegin() || batch_file_number != m->file_number_) { in TryInstallMemtableFlushResults()
515 for (auto it = current_->memlist_.rbegin(); batch_count-- > 0; ++it) { in TryInstallMemtableFlushResults() local
516 MemTable* m = *it; in TryInstallMemtableFlushResults()
754 for (auto it = memlist.rbegin(); it != memlist.rend(); ++it) { in RemoveOldMemTables() local
755 MemTable* mem = *it; in RemoveOldMemTables()
762 for (auto it = old_memtables.begin(); it != old_memtables.end(); ++it) { in RemoveOldMemTables() local
[all …]
Dforward_iterator_bench.cc82 std::unique_ptr<ROCKSDB_NAMESPACE::Iterator> it; member
119 if (!state.it) { in readOnceFromShard()
130 state.it.reset(db_->NewIterator(options)); in readOnceFromShard()
139 for (ROCKSDB_NAMESPACE::Iterator* it : in readOnceFromShard()
140 {state.it_cacheonly.get(), state.it.get()}) { in readOnceFromShard()
141 if (it == nullptr) { in readOnceFromShard()
154 it->Next(); in readOnceFromShard()
156 if (it->status().IsIncomplete()) { in readOnceFromShard()
160 assert(it->Valid()); in readOnceFromShard()
161 assert(it->key().size() == sizeof(Key)); in readOnceFromShard()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DBytewiseComparatorIntTest.java164 final RocksIterator it = db.newIterator()) { in testRoundtrip() argument
165 it.seekToFirst(); in testRoundtrip()
168 for (it.seekToFirst(); it.isValid(); it.next()) { in testRoundtrip()
169 key.put(it.key()); in testRoundtrip()
235 final RocksIterator it = db.newIterator(cfHandles.get(1))) { in testRoundtripCf() argument
240 it.seekToFirst(); in testRoundtripCf()
243 for (it.seekToFirst(); it.isValid(); it.next()) { in testRoundtripCf()
244 key.put(it.key()); in testRoundtripCf()
DReverseBytewiseComparatorIntTest.java167 final RocksIterator it = db.newIterator()) { in testRoundtrip() argument
168 it.seekToFirst(); in testRoundtrip()
171 for (it.seekToFirst(); it.isValid(); it.next()) { in testRoundtrip()
172 key.put(it.key()); in testRoundtrip()
238 final RocksIterator it = db.newIterator(cfHandles.get(1))) { in testRoundtripCf() argument
243 it.seekToFirst(); in testRoundtripCf()
246 for (it.seekToFirst(); it.isValid(); it.next()) { in testRoundtripCf()
247 key.put(it.key()); in testRoundtripCf()
DIntComparatorTest.java163 final RocksIterator it = db.newIterator()) { in testRoundtrip() argument
164 it.seekToFirst(); in testRoundtrip()
167 for (it.seekToFirst(); it.isValid(); it.next()) { in testRoundtrip()
168 key.put(it.key()); in testRoundtrip()
234 final RocksIterator it = db.newIterator(cfHandles.get(1))) { in testRoundtripCf() argument
239 it.seekToFirst(); in testRoundtripCf()
242 for (it.seekToFirst(); it.isValid(); it.next()) { in testRoundtripCf()
243 key.put(it.key()); in testRoundtripCf()
DJNIComparatorTest.java121 try (final RocksIterator it = db.newIterator()) { in readAllWithJavaComparator() argument
122 it.seekToFirst(); in readAllWithJavaComparator()
127 while (it.isValid()) { in readAllWithJavaComparator()
128 buf.put(it.key()); in readAllWithJavaComparator()
136 it.next(); in readAllWithJavaComparator()
152 try (final RocksIterator it = db.newIterator()) { in readAllWithCppComparator() argument
153 it.seekToFirst(); in readAllWithCppComparator()
158 while (it.isValid()) { in readAllWithCppComparator()
159 buf.put(it.key()); in readAllWithCppComparator()
167 it.next(); in readAllWithCppComparator()
/rocksdb-6.9/docs/_posts/
D2017-08-24-pinnableslice.markdown8 …cd5/include/rocksdb/db.h#L310) receives a std::string as argument to which it will copy the value.…
12 …it does not incur the memcpy cost. To ensure that the data will not be erased while it is being pr…
14 ### How good is it?
22 …en reading large values from the block cache. There are however cases that it would still have to …
26 ### How to use it?
32 // ... use it
33 pinnable_val.Reset(); // then release it immediately
/rocksdb-6.9/
DCOPYING7 of this license document, but changing it is not allowed.
12 freedom to share and change it. By contrast, the GNU General Public
18 the GNU Lesser General Public License instead.) You can apply it to
25 if you want it, that you can change the software or use pieces of it
31 distribute copies of the software, or if you modify it.
67 that is to say, a work containing the Program or a portion of it,
80 source code as you receive it, in any medium, provided that you
91 of it, thus forming a work based on the Program, and copy and
104 when run, you must cause it, when started running for such
187 the Program or works based on it.
[all …]
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction_db.cc120 for (auto it = rtrxs.begin(); it != rtrxs.end(); ++it) { in Initialize() local
121 auto recovered_trx = it->second; in Initialize()
581 auto it = transactions_.find(name); in GetTransactionByName() local
582 if (it == transactions_.end()) { in GetTransactionByName()
585 return it->second; in GetTransactionByName()
594 for (auto it = transactions_.begin(); it != transactions_.end(); ++it) { in GetAllPreparedTransactions() local
595 if (it->second->GetState() == Transaction::PREPARED) { in GetAllPreparedTransactions()
596 transv->push_back(it->second); in GetAllPreparedTransactions()
626 auto it = transactions_.find(txn->GetName()); in UnregisterTransaction() local
627 assert(it != transactions_.end()); in UnregisterTransaction()
[all …]
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache_test.cc127 std::unique_ptr<Iterator> it(db_->NewIterator(read_options)); in TEST_F() local
128 it->Seek(ToString(i)); in TEST_F()
129 ASSERT_OK(it->status()); in TEST_F()
134 std::unique_ptr<Iterator> it(db_->NewIterator(read_options)); in TEST_F() local
135 it->Seek(ToString(i)); in TEST_F()
136 ASSERT_OK(it->status()); in TEST_F()
205 for (int it = 0; it < 10; it++) { in TEST_F() local

1234567