Home
last modified time | relevance | path

Searched refs:roptions (Results 1 – 17 of 17) sorted by relevance

/rocksdb-6.9/db/
Dc_test.c320 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 …]
Ddb_memtable_test.cc261 ReadOptions roptions; in TEST_F() local
265 &max_covering_tombstone_seq, roptions); in TEST_F()
Ddeletefile_test.cc57 ReadOptions roptions; in AddKeys() local
Ddb_compaction_test.cc1686 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()
Ddb_test2.cc3012 ReadOptions roptions; in TEST_F() local
3020 Status s = dbfull()->GetImpl(roptions, key, get_impl_options); in TEST_F()
Ddb_test.cc2232 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/
Dwrite_unprepared_transaction_test.cc80 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 …]
Dwrite_unprepared_txn.cc643 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()
Dwrite_prepared_transaction_test.cc2219 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 …]
Dwrite_prepared_txn.cc250 ReadOptions roptions; in RollbackInternal() local
252 roptions.snapshot = wpt_db_->GetMaxSnapshot(); in RollbackInternal()
348 roptions); in RollbackInternal()
Dwrite_unprepared_txn_db.cc66 ReadOptions roptions; in RollbackRecoveredTransaction() member
108 s = db_->GetImpl(roptions, key, get_impl_options); in RollbackRecoveredTransaction()
Dwrite_unprepared_txn.h217 ReadCallback* callback, const ReadOptions& roptions);
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc208 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 …]
Dtrace_replay.h186 ReadOptions roptions; member
/rocksdb-6.9/test_util/
Dtransaction_test_util.cc290 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/
Dcheckpoint_test.cc265 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/
Ddb_impl.cc1328 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()