Home
last modified time | relevance | path

Searched refs:NewIterator (Results 1 – 25 of 129) sorted by relevance

123456

/rocksdb-6.9/db/
Ddb_iterator_test.cc204 auto iter = NewIterator(opts); in TEST_P()
265 iter = NewIterator(ReadOptions()); in TEST_P()
1004 iter.reset(NewIterator(ro)); in TEST_P()
1204 iter.reset(NewIterator(ropt)); in TEST_P()
1378 auto iter = NewIterator(ro); in PinnedDataIteratorRandomized()
1537 auto iter = NewIterator(ro); in TEST_P()
1592 auto iter = NewIterator(ro); in TEST_P()
1639 auto iter = NewIterator(ro); in TEST_P()
2538 iter = NewIterator(ro); in TEST_P()
2549 iter = NewIterator(ro); in TEST_P()
[all …]
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()
237 iter.reset(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()
497 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
[all …]
Ddb_bloom_filter_test.cc951 auto iter = db_->NewIterator(ReadOptions()); in TEST_F()
1175 iter.reset(dbfull()->NewIterator(ReadOptions())); in TEST_P()
1296 iter = db_->NewIterator(ReadOptions()); in TEST_F()
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()
1678 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
1809 db_->NewIterator(read_options, handles_[2])); in TEST_F()
[all …]
Dprefix_test.cc315 auto db_iter = db->NewIterator(ReadOptions()); in TEST()
335 auto db_iter = db->NewIterator(ReadOptions()); in TEST()
386 iter.reset(db->NewIterator(read_options)); in TEST_F()
406 iter.reset(db->NewIterator(read_options)); in TEST_F()
433 iter.reset(db->NewIterator(read_options)); in TEST_F()
453 iter.reset(db->NewIterator(read_options)); in TEST_F()
479 iter.reset(db->NewIterator(read_options)); in TEST_F()
619 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
733 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
817 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
[all …]
Ddeletefile_test.cc212 itr = db_->NewIterator(ReadOptions()); in TEST_F()
239 itr = db_->NewIterator(read_options); in TEST_F()
346 itr = db_->NewIterator(read_options); 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()
Drange_del_aggregator_test.cc543 auto range_del_compaction_iter = range_del_agg.NewIterator(); in TEST_F()
582 auto range_del_compaction_iter = range_del_agg.NewIterator(); in TEST_F()
628 range_del_agg.NewIterator(&start, &end, false /* end_key_inclusive */); in TEST_F()
632 range_del_agg.NewIterator(&start, &end, true /* end_key_inclusive */); in TEST_F()
653 range_del_agg.NewIterator(&start, &end, false /* end_key_inclusive */); in TEST_F()
658 range_del_agg.NewIterator(&start, &end, true /* end_key_inclusive */); in TEST_F()
682 range_del_agg.NewIterator(&start, &end, false /* end_key_inclusive */); in TEST_F()
693 range_del_agg.NewIterator(&start, &end, true /* end_key_inclusive */); in TEST_F()
Ddb_block_cache_test.cc166 iter = db_->NewIterator(read_options); in TEST_F()
191 iter = db_->NewIterator(read_options); in TEST_F()
204 iter = db_->NewIterator(read_options); in TEST_F()
218 iter = db_->NewIterator(read_options); in TEST_F()
247 iter = db_->NewIterator(read_options); in TEST_F()
267 iter = db_->NewIterator(read_options); in TEST_F()
278 iter = db_->NewIterator(read_options); in TEST_F()
369 iter = db_->NewIterator(read_options); in TEST_F()
Ddb_merge_operator_test.cc174 auto* iter = db_->NewIterator(ReadOptions()); in TEST_F()
179 iter = db_->NewIterator(ReadOptions()); in TEST_F()
193 iter = db_->NewIterator(ReadOptions()); in TEST_F()
403 Iterator* iter = db_->NewIterator(ro); in TEST_P()
455 std::unique_ptr<Iterator> someone_else(db_->NewIterator(ReadOptions())); in TEST_F()
475 std::unique_ptr<Iterator> iter(db_->NewIterator(ro)); in TEST_F()
Ddb_test2.cc92 Iterator* iter1 = db_->NewIterator(ReadOptions()); in TEST_F()
102 Iterator* iter2 = db_->NewIterator(ReadOptions()); in TEST_F()
112 Iterator* iter3 = db_->NewIterator(ReadOptions()); in TEST_F()
1879 Iterator* iter = db_->NewIterator(ReadOptions()); in TEST_F()
1912 iter = db_->NewIterator(ReadOptions()); in TEST_F()
2757 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
2776 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
2788 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
3171 single_iter = db_->NewIterator(ro); in TEST_F()
3414 single_iter = db_->NewIterator(ro); in TEST_F()
[all …]
Ddb_with_timestamp_basic_test.cc202 std::unique_ptr<Iterator> it(db_->NewIterator(read_opts)); in TEST_F()
224 it.reset(db_->NewIterator(read_opts)); in TEST_F()
283 std::unique_ptr<Iterator> iter(db_->NewIterator(read_opts)); in TEST_F()
324 std::unique_ptr<Iterator> iter(db_->NewIterator(read_opts)); in TEST_F()
371 std::unique_ptr<Iterator> iter(db_->NewIterator(read_opts)); in TEST_F()
412 std::unique_ptr<Iterator> iter(db_->NewIterator(read_opts)); in TEST_F()
814 std::unique_ptr<Iterator> iter(db_->NewIterator(read_opts)); in TEST_P()
836 std::unique_ptr<Iterator> it(db_->NewIterator(read_opts)); in TEST_P()
Dforward_iterator.cc78 file_iter_ = cfd_->table_cache()->NewIterator( in Reset()
625 mutable_iter_ = sv_->mem->NewIterator(read_options_, &arena_); in RebuildIterators()
650 l0_iters_.push_back(cfd_->table_cache()->NewIterator( in RebuildIterators()
685 mutable_iter_ = svnew->mem->NewIterator(read_options_, &arena_); in RenewIterators()
726 l0_iters_new.push_back(cfd_->table_cache()->NewIterator( in RenewIterators()
791 l0_iters_[i] = cfd_->table_cache()->NewIterator( in ResetIncompleteIterators()
Dplain_table_db_test.cc519 std::unique_ptr<Iterator> iter(dbfull()->NewIterator(ReadOptions())); in TEST_P()
734 Iterator* iter = dbfull()->NewIterator(ReadOptions()); in TEST_P()
902 Iterator* iter = dbfull()->NewIterator(ReadOptions()); in TEST_P()
950 Iterator* iter = dbfull()->NewIterator(ReadOptions()); in TEST_P()
986 Iterator* iter = dbfull()->NewIterator(ReadOptions()); in TEST_P()
1074 Iterator* iter = dbfull()->NewIterator(ro); in TEST_P()
1168 Iterator* iter = dbfull()->NewIterator(ro); in TEST_P()
1246 Iterator* iter = dbfull()->NewIterator(ReadOptions()); in TEST_P()
Dperf_context_test.cc110 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
131 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
562 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
570 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
851 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
932 std::unique_ptr<Iterator> iter2(db->NewIterator(read_options)); 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 …]
Ddb_impl_readonly.h33 using DBImpl::NewIterator;
34 virtual Iterator* NewIterator(const ReadOptions&,
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc250 single_iter = db_->NewIterator(roptions); in Replay()
252 single_iter = db_->NewIterator(roptions, cf_map_[cf_id]); in Replay()
267 single_iter = db_->NewIterator(roptions); in Replay()
269 single_iter = db_->NewIterator(roptions, cf_map_[cf_id]); in Replay()
452 single_iter = ra->db->NewIterator(ra->roptions); in BGWorkIterSeek()
454 single_iter = ra->db->NewIterator(ra->roptions, (*cf_map)[cf_id]); in BGWorkIterSeek()
476 single_iter = ra->db->NewIterator(ra->roptions); in BGWorkIterSeekForPrev()
478 single_iter = ra->db->NewIterator(ra->roptions, (*cf_map)[cf_id]); in BGWorkIterSeekForPrev()
/rocksdb-6.9/monitoring/
Dstats_history_test.cc231 Iterator* iterator = db_->NewIterator(ReadOptions()); in TEST_F()
250 iterator = db_->NewIterator(ReadOptions()); in TEST_F()
329 db_->NewIterator(ReadOptions(), dbfull()->PersistentStatsColumnFamily()); in TEST_F()
335 db_->NewIterator(ReadOptions(), dbfull()->PersistentStatsColumnFamily()); in TEST_F()
341 db_->NewIterator(ReadOptions(), dbfull()->PersistentStatsColumnFamily()); in TEST_F()
412 db_->NewIterator(ReadOptions(), dbfull()->PersistentStatsColumnFamily()); in TEST_F()
418 db_->NewIterator(ReadOptions(), dbfull()->PersistentStatsColumnFamily()); in TEST_F()
424 db_->NewIterator(ReadOptions(), dbfull()->PersistentStatsColumnFamily()); in TEST_F()
491 db_->NewIterator(ReadOptions(), dbfull()->PersistentStatsColumnFamily()); in TEST_F()
/rocksdb-6.9/utilities/blob_db/
Dblob_db.h198 using ROCKSDB_NAMESPACE::StackableDB::NewIterator;
199 virtual Iterator* NewIterator(const ReadOptions& options) override = 0;
200 virtual Iterator* NewIterator(const ReadOptions& options, in NewIterator() function
206 return NewIterator(options); in NewIterator()
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache_test.cc96 iter = db_->NewIterator(read_options); in TEST_F()
113 iter = db_->NewIterator(read_options); in TEST_F()
127 std::unique_ptr<Iterator> it(db_->NewIterator(read_options)); in TEST_F()
134 std::unique_ptr<Iterator> it(db_->NewIterator(read_options)); in TEST_F()
/rocksdb-6.9/examples/
Dmulti_processes_example.cc287 std::unique_ptr<Iterator> iter(db->NewIterator(ropts)); in RunSecondary()
318 std::unique_ptr<Iterator> iter(db->NewIterator(ropts)); in RunSecondary()
353 Iterator* iter1 = verification_db->NewIterator(ropts); in RunSecondary()
356 Iterator* iter = db->NewIterator(ropts); in RunSecondary()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc106 std::unique_ptr<WBWIIterator> iter(batch->NewIterator(&data)); in TestValueAsSecondaryIndexHelper()
119 std::unique_ptr<WBWIIterator> iter(batch->NewIterator(&data)); in TestValueAsSecondaryIndexHelper()
160 std::unique_ptr<WBWIIterator> iter(batch->NewIterator(&index)); in TestValueAsSecondaryIndexHelper()
202 std::unique_ptr<WBWIIterator> iter(batch->NewIterator(&data)); in TestValueAsSecondaryIndexHelper()
332 std::unique_ptr<WBWIIterator> iter(batch.NewIterator(&cf1)); in TEST_F()
351 std::unique_ptr<WBWIIterator> iter(batch.NewIterator(&cf2)); in TEST_F()
421 std::unique_ptr<WBWIIterator> iter(batch.NewIterator(&cf1)); in TEST_F()
438 std::unique_ptr<WBWIIterator> iter(batch.NewIterator(&cf2)); in TEST_F()
1360 std::unique_ptr<WBWIIterator> iter(batch.NewIterator()); in TEST_F()
1528 iter = batch->NewIterator(); in PrintContents()
[all …]
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn_db.h30 using WritePreparedTxnDB::NewIterator;
31 Iterator* NewIterator(const ReadOptions& options,
/rocksdb-6.9/table/
Dtable_test.cc196 virtual InternalIterator* NewIterator(
241 InternalIterator* NewIterator( in NewIterator() function in ROCKSDB_NAMESPACE::BlockConstructor
386 InternalIterator* NewIterator( in NewIterator() function in ROCKSDB_NAMESPACE::TableConstructor
389 InternalIterator* iter = table_reader_->NewIterator( in NewIterator()
495 InternalIterator* NewIterator( in NewIterator() function in ROCKSDB_NAMESPACE::MemTableConstructor
558 InternalIterator* NewIterator( in NewIterator() function in ROCKSDB_NAMESPACE::DBConstructor
844 InternalIterator* iter = constructor_->NewIterator(); in TestForwardScan()
862 InternalIterator* iter = constructor_->NewIterator(); in TestBackwardScan()
3133 c.NewIterator(moptions.prefix_extractor.get())); in TEST_P()
4131 return table_reader->NewIterator( in TEST_P()
[all …]
Dsst_file_reader.cc65 Iterator* SstFileReader::NewIterator(const ReadOptions& options) { in NewIterator() function in ROCKSDB_NAMESPACE::SstFileReader
70 auto internal_iter = r->table_reader->NewIterator( in NewIterator()

123456