| /rocksdb-6.9/db/ |
| D | c_test.c | 320 CheckGet(db, roptions, "bar", NULL); in CheckCompaction()
438 rocksdb_readoptions_t* roptions; in main() local
529 CheckGet(db, roptions, "foo", NULL); in main()
727 CheckGet(db, roptions, "bar", NULL); in main()
728 CheckGet(db, roptions, "box", "c"); in main()
738 CheckGet(db, roptions, "bar", NULL); in main()
739 CheckGet(db, roptions, "bay", "d"); in main()
749 CheckGet(db, roptions, "bay", NULL); in main()
767 CheckGet(db, roptions, "zap", NULL); in main()
833 CheckGet(db, roptions, "box", "c"); in main()
[all …]
|
| D | db_memtable_test.cc | 261 ReadOptions roptions; in TEST_F() local
265 &max_covering_tombstone_seq, roptions); in TEST_F()
|
| D | deletefile_test.cc | 57 ReadOptions roptions; in AddKeys() local
|
| D | db_compaction_test.cc | 1686 ReadOptions roptions; in TEST_F() local
1688 Status s = db_->Get(roptions, Key(i), &result); in TEST_F()
1716 ReadOptions roptions; in TEST_F() local
1718 Status s = db_->Get(roptions, Key(i), &result); in TEST_F()
3287 ReadOptions roptions; in TEST_P() local
3289 ASSERT_TRUE(db_->Get(roptions, Key(0), &result).IsNotFound()); in TEST_P()
|
| D | db_test2.cc | 3012 ReadOptions roptions; in TEST_F() local
3020 Status s = dbfull()->GetImpl(roptions, key, get_impl_options); in TEST_F()
|
| D | db_test.cc | 2232 ReadOptions roptions; in TEST_F() local
2235 stat = snapdb->Get(roptions, cf_handles[i < 40], Key(i), &val); in TEST_F()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_unprepared_transaction_test.cc | 80 ReadOptions roptions; in TEST_P() local
103 auto iter = txn->GetIterator(roptions); in TEST_P()
119 iter = txn->GetIterator(roptions); in TEST_P()
572 ReadOptions roptions; in TEST_P() local
573 auto iter = txn->GetIterator(roptions); in TEST_P()
602 ReadOptions roptions; in TEST_P() local
622 iter = db->NewIterator(roptions); in TEST_P()
653 ReadOptions roptions; in TEST_P() local
675 ReadOptions roptions; in TEST_P() local
699 s = txn->Get(roptions, "a", &value); in TEST_P()
[all …]
|
| D | write_unprepared_txn.cc | 643 ReadCallback* callback, const ReadOptions& roptions) { in WriteRollbackKeys() argument
654 auto s = db_impl_->GetImpl(roptions, key, get_impl_options); in WriteRollbackKeys()
702 ReadOptions roptions; in RollbackInternal() local
704 roptions.snapshot = wpt_db_->GetMaxSnapshot(); in RollbackInternal()
712 WriteRollbackKeys(GetTrackedKeys(), &rollback_batch, &callback, roptions); in RollbackInternal()
847 ReadOptions roptions; in RollbackToSavePointInternal() local
848 roptions.snapshot = top.snapshot_->snapshot(); in RollbackToSavePointInternal()
851 roptions.snapshot) in RollbackToSavePointInternal()
853 SequenceNumber snap_seq = roptions.snapshot->GetSequenceNumber(); in RollbackToSavePointInternal()
857 WriteRollbackKeys(tracked_keys, &write_batch_, &callback, roptions); in RollbackToSavePointInternal()
|
| D | write_prepared_transaction_test.cc | 2219 ReadOptions roptions; in TEST_P() local
3089 ReadOptions roptions; in TEST_P() local
3161 ReadOptions roptions; in TEST_P() local
3162 roptions.snapshot = snap; in TEST_P()
3238 ReadOptions roptions; in TEST_P() local
3239 roptions.snapshot = snap; in TEST_P()
3317 ReadOptions roptions; in TEST_P() local
3326 roptions.snapshot = snap; in TEST_P()
3360 ReadOptions roptions; in TEST_P() local
3412 ReadOptions roptions; in TEST_P() local
[all …]
|
| D | write_prepared_txn.cc | 250 ReadOptions roptions; in RollbackInternal() local
252 roptions.snapshot = wpt_db_->GetMaxSnapshot(); in RollbackInternal()
348 roptions); in RollbackInternal()
|
| D | write_unprepared_txn_db.cc | 66 ReadOptions roptions; in RollbackRecoveredTransaction() member
108 s = db_->GetImpl(roptions, key, get_impl_options); in RollbackRecoveredTransaction()
|
| D | write_unprepared_txn.h | 217 ReadCallback* callback, const ReadOptions& roptions);
|
| /rocksdb-6.9/trace_replay/ |
| D | trace_replay.cc | 208 ReadOptions roptions; in Replay() local
236 db_->Get(roptions, key, &value); in Replay()
238 db_->Get(roptions, cf_map_[cf_id], key, &value); in Replay()
250 single_iter = db_->NewIterator(roptions); in Replay()
267 single_iter = db_->NewIterator(roptions); in Replay()
315 ReadOptions roptions; in MultiThreadReplay() local
325 ra->roptions = roptions; in MultiThreadReplay()
421 ra->db->Get(ra->roptions, key, &value); in BGWorkGet()
423 ra->db->Get(ra->roptions, (*cf_map)[cf_id], key, &value); in BGWorkGet()
452 single_iter = ra->db->NewIterator(ra->roptions); in BGWorkIterSeek()
[all …]
|
| D | trace_replay.h | 186 ReadOptions roptions; member
|
| /rocksdb-6.9/test_util/ |
| D | transaction_test_util.cc | 290 ReadOptions roptions; in Verify() local
292 roptions.snapshot = db->GetSnapshot(); in Verify()
321 Status s = DBGet(db, nullptr, roptions, set_i, k, FOR_UPDATE, in Verify()
328 Iterator* iter = db->NewIterator(roptions); in Verify()
345 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul, in Verify()
346 roptions.snapshot in Verify()
347 ? ((SnapshotImpl*)roptions.snapshot)->min_uncommitted_ in Verify()
363 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul); in Verify()
372 roptions.snapshot ? roptions.snapshot->GetSequenceNumber() : 0ul); in Verify()
379 db->ReleaseSnapshot(roptions.snapshot); in Verify()
|
| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_test.cc | 265 ReadOptions roptions; in TEST_F() local
290 ASSERT_OK(snapshotDB->Get(roptions, key, &result)); in TEST_F()
434 ReadOptions roptions; in TEST_F() local
473 ASSERT_OK(snapshotDB->Get(roptions, cphandles[0], "Default", &result)); in TEST_F()
475 ASSERT_OK(snapshotDB->Get(roptions, cphandles[1], "one", &result)); in TEST_F()
477 ASSERT_OK(snapshotDB->Get(roptions, cphandles[2], "two", &result)); in TEST_F()
498 ReadOptions roptions; in TEST_F() local
532 ASSERT_OK(snapshotDB->Get(roptions, cphandles[0], "Default", &result)); in TEST_F()
534 ASSERT_OK(snapshotDB->Get(roptions, cphandles[1], "one", &result)); in TEST_F()
536 ASSERT_OK(snapshotDB->Get(roptions, cphandles[2], "two", &result)); in TEST_F()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 1328 ReadOptions roptions; in NewInternalIterator() local
1329 return NewInternalIterator(roptions, cfd, super_version, arena, range_del_agg, in NewInternalIterator()
2504 ReadOptions roptions = read_options; in KeyMayExist() local
2505 roptions.read_tier = kBlockCacheTier; // read from block cache only in KeyMayExist()
2512 auto s = GetImpl(roptions, key, get_impl_options); in KeyMayExist()
|