Home
last modified time | relevance | path

Searched refs:ro (Results 1 – 25 of 34) sorted by relevance

12

/rocksdb-6.9/db/
Ddb_iter_test.cc251 ReadOptions ro; in TEST_F() local
284 ReadOptions ro; in TEST_F() local
309 ReadOptions ro; in TEST_F() local
342 ReadOptions ro; in TEST_F() local
664 ReadOptions ro; in TEST_F() local
692 ReadOptions ro; in TEST_F() local
733 ReadOptions ro; in TEST_F() local
969 ReadOptions ro; in TEST_F() local
1340 ReadOptions ro; in TEST_F() local
1368 ReadOptions ro; in TEST_F() local
[all …]
Ddb_iterator_test.cc814 ReadOptions ro; in TEST_P() local
835 ReadOptions ro; in TEST_P() local
867 ReadOptions ro; in TEST_P() local
902 ReadOptions ro; in TEST_P() local
1535 ReadOptions ro; in TEST_P() local
1590 ReadOptions ro; in TEST_P() local
1637 ReadOptions ro; in TEST_P() local
2198 ReadOptions ro; in TEST_P() local
2357 ReadOptions ro; in TEST_P() local
2464 ReadOptions ro; in TEST_P() local
[all …]
Ddb_test2.cc3142 ReadOptions ro; in TEST_F() local
3246 ReadOptions ro; in TEST_F() local
3313 ReadOptions ro; in TEST_F() local
3385 ReadOptions ro; in TEST_F() local
4208 ReadOptions ro; in TEST_F() local
4209 ro.total_order_seek = true; in TEST_F()
4432 ReadOptions ro; in TEST_F() local
4592 ReadOptions ro; in TEST_F() local
4593 ro.total_order_seek = false; in TEST_F()
4594 ro.auto_prefix_mode = true; in TEST_F()
[all …]
Dexternal_sst_file_ingestion_job.cc396 ReadOptions ro; in GetIngestedFileInfo() local
397 ro.readahead_size = ingestion_options_.verify_checksums_readahead_size; in GetIngestedFileInfo()
399 ro, TableReaderCaller::kExternalSSTIngestion); in GetIngestedFileInfo()
451 ReadOptions ro; in GetIngestedFileInfo() local
457 ro.fill_cache = false; in GetIngestedFileInfo()
459 ro, sv->mutable_cf_options.prefix_extractor.get(), /*arena=*/nullptr, in GetIngestedFileInfo()
462 table_reader->NewRangeTombstoneIterator(ro)); in GetIngestedFileInfo()
542 ReadOptions ro; in AssignLevelAndSeqnoForIngestedFile() local
543 ro.total_order_seek = true; in AssignLevelAndSeqnoForIngestedFile()
555 ro, env_options_, file_to_ingest->smallest_internal_key.user_key(), in AssignLevelAndSeqnoForIngestedFile()
Ddb_merge_operator_test.cc401 ReadOptions ro; in TEST_P() local
402 ro.tailing = true; in TEST_P()
403 Iterator* iter = db_->NewIterator(ro); in TEST_P()
473 ReadOptions ro; in TEST_F() local
474 ro.tailing = true; in TEST_F()
475 std::unique_ptr<Iterator> iter(db_->NewIterator(ro)); in TEST_F()
Ddb_basic_test.cc1589 ReadOptions ro; in TEST_P() local
1592 ro.snapshot = snap2; in TEST_P()
1620 ro.snapshot = snap1; in TEST_P()
1726 ReadOptions ro; in TEST_F() local
1735 dbfull()->MultiGet(ro, dbfull()->DefaultColumnFamily(), keys.size(), in TEST_F()
2150 ReadOptions ro; in TEST_P() local
2151 ro.fill_cache = fill_cache(); in TEST_P()
2274 ReadOptions ro; in TEST_P() local
2275 ro.fill_cache = fill_cache(); in TEST_P()
2311 ReadOptions ro; in TEST_P() local
[all …]
Dimport_column_family_job.cc242 ReadOptions ro; in GetIngestedFileInfo() local
248 ro.fill_cache = false; in GetIngestedFileInfo()
250 ro, sv->mutable_cf_options.prefix_extractor.get(), /*arena=*/nullptr, in GetIngestedFileInfo()
Dflush_job.cc315 ReadOptions ro; in WriteLevel0Table() local
316 ro.total_order_seek = true; in WriteLevel0Table()
326 memtables.push_back(m->NewIterator(ro, &arena)); in WriteLevel0Table()
328 m->NewRangeTombstoneIterator(ro, kMaxSequenceNumber); in WriteLevel0Table()
Ddb_test_util.cc1256 ReadOptions ro; in VerifyIterLast() local
1258 iter = db_->NewIterator(ro); in VerifyIterLast()
1260 iter = db_->NewIterator(ro, handles_[cf]); in VerifyIterLast()
1435 ReadOptions ro; in VerifyDBFromMap() local
1436 ro.total_order_seek = true; in VerifyDBFromMap()
1437 Iterator* iter = db_->NewIterator(ro); in VerifyDBFromMap()
1461 iter = db_->NewIterator(ro); in VerifyDBFromMap()
1495 ReadOptions ro; in VerifyDBFromMap() local
1496 ro.tailing = true; in VerifyDBFromMap()
1497 ro.total_order_seek = true; in VerifyDBFromMap()
[all …]
Dcorruption_test.cc361 ReadOptions ro; in TEST_F() local
362 ro.readahead_size = size_t{32 * 1024}; in TEST_F()
363 ASSERT_OK(dbi->VerifyChecksum(ro)); in TEST_F()
378 ASSERT_OK(dbi->VerifyChecksum(ro)); in TEST_F()
Drepair.cc408 ReadOptions ro; in ConvertLogToTable() local
409 ro.total_order_seek = true; in ConvertLogToTable()
411 ScopedArenaIterator iter(mem->NewIterator(ro, &arena)); in ConvertLogToTable()
421 mem->NewRangeTombstoneIterator(ro, kMaxSequenceNumber); in ConvertLogToTable()
Dfault_injection_test.cc515 ReadOptions ro; in TEST_P() local
533 ASSERT_OK(db_->Get(ro, "cats", &val)); in TEST_P()
535 ASSERT_EQ(db_->Get(ro, "boys", &val), Status::NotFound()); in TEST_P()
Ddb_bloom_filter_test.cc166 ReadOptions ro; in TEST_F() local
205 ro.total_order_seek = true; in TEST_F()
206 ASSERT_TRUE(db_->Get(ro, "foobarbar", &value).IsNotFound()); in TEST_F()
232 ReadOptions ro; in TEST_F() local
256 ro.total_order_seek = true; in TEST_F()
257 ASSERT_TRUE(db_->Get(ro, "foobarbar", &value).IsNotFound()); in TEST_F()
284 ReadOptions ro; in TEST_F() local
Dcolumn_family_test.cc975 ReadOptions ro; in TEST_P() local
979 ASSERT_OK(db_->NewIterators(ro, handles_, &iterators)); in TEST_P()
3074 ReadOptions ro; in TEST_P() local
3075 ro.background_purge_on_iterator_cleanup = true; in TEST_P()
3076 Iterator* it = db_->NewIterator(ro, handles_[1]); in TEST_P()
3136 ReadOptions ro; in TEST_P() local
3137 ro.tailing = true; in TEST_P()
3138 ro.background_purge_on_iterator_cleanup = true; in TEST_P()
3139 Iterator* it = db_->NewIterator(ro, handles_[1]); in TEST_P()
Dplain_table_db_test.cc1073 ReadOptions ro; in TEST_P() local
1074 Iterator* iter = dbfull()->NewIterator(ro); in TEST_P()
1167 ReadOptions ro; in TEST_P() local
1168 Iterator* iter = dbfull()->NewIterator(ro); in TEST_P()
/rocksdb-6.9/table/block_based/
Dblock_based_table_reader_impl.h26 const ReadOptions& ro, const BlockHandle& handle, TBlockIter* input_iter, in NewDataBlockIterator() argument
40 const bool no_io = (ro.read_tier == kBlockCacheTier); in NewDataBlockIterator()
55 s = RetrieveBlock(prefetch_buffer, ro, handle, dict, &block, block_type, in NewDataBlockIterator()
81 if (!ro.fill_cache && rep_->cache_key_prefix_size != 0) { in NewDataBlockIterator()
126 TBlockIter* BlockBasedTable::NewDataBlockIterator(const ReadOptions& ro, in NewDataBlockIterator() argument
153 if (!ro.fill_cache && rep_->cache_key_prefix_size != 0) { in NewDataBlockIterator()
Dpartitioned_index_reader.cc78 ReadOptions ro; in NewIterator() local
79 ro.fill_cache = read_options.fill_cache; in NewIterator()
90 table(), ro, *internal_comparator(), std::move(index_iter), in NewIterator()
156 auto ro = ReadOptions(); in CacheDependencies() local
163 prefetch_buffer.get(), ro, handle, UncompressionDict::GetEmptyDict(), in CacheDependencies()
Dblock_based_table_reader.cc1377 const bool no_io = (ro.read_tier == kBlockCacheTier); in MaybeReadBlockAndLoadToCache()
1489 bool no_insert = no_io || !ro.fill_cache; in MaybeReadBlockAndLoadToCache()
1799 const bool no_io = ro.read_tier == kBlockCacheTier; in RetrieveBlock()
2360 ReadOptions ro = read_options; in MultiGet() local
2361 ro.read_tier = kBlockCacheTier; in MultiGet()
2934 ReadOptions ro; in ApproximateOffsetOf() local
2935 ro.total_order_seek = true; in ApproximateOffsetOf()
2937 NewIndexIterator(ro, /*disable_prefix_seek=*/true, in ApproximateOffsetOf()
2955 ReadOptions ro; in ApproximateSize() local
2956 ro.total_order_seek = true; in ApproximateSize()
[all …]
Dblock_based_table_reader.h224 const ReadOptions& ro, const BlockHandle& block_handle,
231 TBlockIter* NewDataBlockIterator(const ReadOptions& ro,
285 FilePrefetchBuffer* prefetch_buffer, const ReadOptions& ro,
296 const ReadOptions& ro, const BlockHandle& handle,
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.cc1043 (ro.iterate_upper_bound != nullptr && in VerifyIterator()
1044 options_.comparator->Compare(*ro.iterate_lower_bound, in VerifyIterator()
1053 (ro.iterate_lower_bound != nullptr && in VerifyIterator()
1054 options_.comparator->Compare(*ro.iterate_lower_bound, in VerifyIterator()
1062 const SliceTransform* pe = (ro.total_order_seek || ro.auto_prefix_mode) in VerifyIterator()
1123 (ro.iterate_upper_bound == nullptr || in VerifyIterator()
1125 (ro.iterate_lower_bound == nullptr || in VerifyIterator()
1603 ReadOptions ro; in GetRangeHash() local
1604 ro.snapshot = snapshot; in GetRangeHash()
1605 ro.total_order_seek = true; in GetRangeHash()
[all …]
/rocksdb-6.9/util/
Dslice_transform_test.cc108 ReadOptions ro; in TEST_F() local
118 std::unique_ptr<Iterator> iter(db()->NewIterator(ro)); in TEST_F()
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc125 ReadOptions ro; in AdvanceIteratorByTime() local
127 db_impl_->NewIterator(ro, db_impl_->PersistentStatsColumnFamily()); in AdvanceIteratorByTime()
/rocksdb-6.9/tools/
Dtrace_analyzer_test.cc60 ReadOptions ro; in GenerateTrace() local
81 ASSERT_OK(db_->Get(ro, "a", &value)); in GenerateTrace()
82 single_iter = db_->NewIterator(ro); in GenerateTrace()
88 db_->Get(ro, "g", &value); in GenerateTrace()
/rocksdb-6.9/table/
Dtable_reader_bench.cc292 ROCKSDB_NAMESPACE::ReadOptions ro; in main() local
337 options, env_options, ro, FLAGS_num_keys1, FLAGS_num_keys2, FLAGS_iter, in main()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc1328 ReadOptions ro(read_options); in MultiGet() local
1329 bool snapshot_created = SetSnapshotIfNeeded(&ro); in MultiGet()
1337 statuses.push_back(Get(ro, DefaultColumnFamily(), keys[i], &value)); in MultiGet()
1342 db_->ReleaseSnapshot(ro.snapshot); in MultiGet()
1584 ReadOptions ro(read_options); in GetImpl() local
1585 bool snapshot_created = SetSnapshotIfNeeded(&ro); in GetImpl()
1594 s = db_impl_->GetImpl(ro, key, get_impl_options); in GetImpl()
1609 db_->ReleaseSnapshot(ro.snapshot); in GetImpl()

12