Home
last modified time | relevance | path

Searched refs:txn_db (Results 1 – 23 of 23) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_test.cc47 delete txn_db; in ~OptimisticTransactionTest()
52 delete txn_db; in Reopen()
53 txn_db = nullptr; in Reopen()
71 assert(txn_db != nullptr); in Open()
262 txn_db->Flush(flush_ops); in TEST_P()
302 txn_db->Flush(flush_ops); in TEST_P()
309 txn_db->Flush(flush_ops); in TEST_P()
317 txn_db->Flush(flush_ops); in TEST_P()
597 delete txn_db; in TEST_P()
598 txn_db = nullptr; in TEST_P()
[all …]
Dpessimistic_transaction_db.cc298 std::unique_ptr<PessimisticTransactionDB> txn_db; in WrapDB() local
301 txn_db.reset(new WriteUnpreparedTxnDB( in WrapDB()
305 txn_db.reset(new WritePreparedTxnDB( in WrapDB()
310 txn_db.reset(new WriteCommittedTxnDB( in WrapDB()
313 txn_db->UpdateCFComparatorMap(handles); in WrapDB()
318 *dbptr = txn_db.release(); in WrapDB()
336 txn_db.reset(new WriteUnpreparedTxnDB( in WrapStackableDB()
340 txn_db.reset(new WritePreparedTxnDB( in WrapStackableDB()
345 txn_db.reset(new WriteCommittedTxnDB( in WrapStackableDB()
348 txn_db->UpdateCFComparatorMap(handles); in WrapStackableDB()
[all …]
Doptimistic_transaction.cc29 OptimisticTransactionDB* txn_db, const WriteOptions& write_options, in OptimisticTransaction() argument
31 : TransactionBaseImpl(txn_db->GetBaseDB(), write_options), txn_db_(txn_db) { in OptimisticTransaction()
43 OptimisticTransactionDB* txn_db, const WriteOptions& write_options, in Reinitialize() argument
45 TransactionBaseImpl::Reinitialize(txn_db->GetBaseDB(), write_options); in Reinitialize()
Dpessimistic_transaction.cc39 TransactionDB* txn_db, const WriteOptions& write_options, in PessimisticTransaction() argument
41 : TransactionBaseImpl(txn_db->GetRootDB(), write_options), in PessimisticTransaction()
52 static_cast_with_check<PessimisticTransactionDB, TransactionDB>(txn_db); in PessimisticTransaction()
109 TransactionDB* txn_db, const WriteOptions& write_options, in Reinitialize() argument
114 TransactionBaseImpl::Reinitialize(txn_db->GetRootDB(), write_options); in Reinitialize()
129 WriteCommittedTxn::WriteCommittedTxn(TransactionDB* txn_db, in WriteCommittedTxn() argument
132 : PessimisticTransaction(txn_db, write_options, txn_options){}; in WriteCommittedTxn()
Dsnapshot_checker.cc30 WritePreparedTxnDB* txn_db)
31 : txn_db_(txn_db){};
Dwrite_prepared_txn.cc27 WritePreparedTxn::WritePreparedTxn(WritePreparedTxnDB* txn_db, in WritePreparedTxn() argument
30 : PessimisticTransaction(txn_db, write_options, txn_options, false), in WritePreparedTxn()
31 wpt_db_(txn_db) { in WritePreparedTxn()
Doptimistic_transaction.h40 void Reinitialize(OptimisticTransactionDB* txn_db,
Dtransaction_lock_mgr.cc164 TransactionDB* txn_db, size_t default_num_stripes, int64_t max_num_locks, in TransactionLockMgr() argument
173 assert(txn_db); in TransactionLockMgr()
175 static_cast_with_check<PessimisticTransactionDB, TransactionDB>(txn_db); in TransactionLockMgr()
Dwrite_unprepared_txn_db.cc366 IteratorState(WritePreparedTxnDB* txn_db, SequenceNumber sequence, in IteratorState()
369 : callback(txn_db, sequence, min_uncommitted, txn->unprep_seqs_, in IteratorState()
Dtransaction_lock_mgr.h57 TransactionLockMgr(TransactionDB* txn_db, size_t default_num_stripes,
Dwrite_unprepared_txn.cc36 WriteUnpreparedTxn::WriteUnpreparedTxn(WriteUnpreparedTxnDB* txn_db, in WriteUnpreparedTxn() argument
39 : WritePreparedTxn(txn_db, write_options, txn_options), in WriteUnpreparedTxn()
40 wupt_db_(txn_db), in WriteUnpreparedTxn()
Dpessimistic_transaction.h49 void Reinitialize(TransactionDB* txn_db, const WriteOptions& write_options,
Dwrite_prepared_txn_db.cc305 IteratorState(WritePreparedTxnDB* txn_db, SequenceNumber sequence, in IteratorState()
308 : callback(txn_db, sequence, min_uncommitted, kBackedByDBSnapshot), in IteratorState()
/rocksdb-6.9/examples/
Dtransaction_example.cc23 TransactionDB* txn_db; in main() local
52 s = txn_db->Get(read_options, "abc", &value); in main()
57 s = txn_db->Put(write_options, "xyz", "zzz"); in main()
62 s = txn_db->Put(write_options, "abc", "def"); in main()
76 s = txn_db->Get(read_options, "abc", &value); in main()
94 s = txn_db->Put(write_options, "abc", "xyz"); in main()
137 read_options.snapshot = txn_db->GetSnapshot(); in main()
144 s = txn_db->Put(write_options, "y", "y1"); in main()
172 s = txn_db->Get(read_options, "x", &value); in main()
176 s = txn_db->Get(read_options, "y", &value); in main()
[all …]
Doptimistic_transaction_example.cc23 OptimisticTransactionDB* txn_db; in main() local
25 Status s = OptimisticTransactionDB::Open(options, kDBPath, &txn_db); in main()
27 db = txn_db->GetBaseDB(); in main()
41 Transaction* txn = txn_db->BeginTransaction(write_options); in main()
86 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
129 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
175 delete txn_db; in main()
/rocksdb-6.9/java/rocksjni/
Dtransaction_db.cc166 assert(txn_db != nullptr); in Java_org_rocksdb_TransactionDB_disposeInternal()
167 delete txn_db; in Java_org_rocksdb_TransactionDB_disposeInternal()
178 assert(txn_db != nullptr); in Java_org_rocksdb_TransactionDB_closeDatabase()
179 ROCKSDB_NAMESPACE::Status s = txn_db->Close(); in Java_org_rocksdb_TransactionDB_closeDatabase()
194 txn_db->BeginTransaction(*write_options); in Java_org_rocksdb_TransactionDB_beginTransaction__JJ()
212 txn_db->BeginTransaction(*write_options, *txn_options); in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ()
231 txn_db->BeginTransaction(*write_options, txn_options, old_txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ()
294 txn_db->GetAllPreparedTransactions(&txns); in Java_org_rocksdb_TransactionDB_getAllPreparedTransactions()
329 lock_status_data = txn_db->GetLockStatusData(); in Java_org_rocksdb_TransactionDB_getLockStatusData()
378 txn_db->GetDeadlockInfoBuffer(); in Java_org_rocksdb_TransactionDB_getDeadlockInfoBuffer()
[all …]
/rocksdb-6.9/db/
Dc_test.c400 rocksdb_transactiondb_t* txn_db, in CheckTxnDBGet() argument
441 rocksdb_transactiondb_t* txn_db; in main() local
1546 CheckTxnDBGet(txn_db, roptions, "foo", NULL); in main()
1557 CheckTxnDBGet(txn_db, roptions, "box", "c"); in main()
1575 CheckTxnDBGet(txn_db, roptions, "foo", NULL); in main()
1598 CheckTxnDBGet(txn_db, roptions, "foo", "hey"); in main()
1614 CheckTxnDBGet(txn_db, roptions, "bar", NULL); in main()
1628 CheckTxnDBGet(txn_db, roptions, "foo1", NULL); in main()
1629 CheckTxnDBGet(txn_db, roptions, "foo2", NULL); in main()
1633 CheckTxnDBGet(txn_db, roptions, "foo2", NULL); in main()
[all …]
Dc.cc3835 rocksdb_transactiondb_t* txn_db, in rocksdb_transactiondb_create_column_family() argument
3849 TransactionDB* txn_db; in rocksdb_transactiondb_open() local
3855 result->rep = txn_db; in rocksdb_transactiondb_open()
3872 TransactionDB* txn_db; in rocksdb_transactiondb_open_column_families() local
3887 result->rep = txn_db; in rocksdb_transactiondb_open_column_families()
3892 rocksdb_transactiondb_t* txn_db) { in rocksdb_transactiondb_create_snapshot() argument
3894 result->rep = txn_db->rep->GetSnapshot(); in rocksdb_transactiondb_create_snapshot()
3905 rocksdb_transactiondb_t* txn_db, in rocksdb_transaction_begin() argument
4033 rocksdb_transactiondb_t* txn_db, in rocksdb_transactiondb_get() argument
4209 delete txn_db->rep; in rocksdb_transactiondb_close()
[all …]
Dsnapshot_checker.h49 explicit WritePreparedSnapshotChecker(WritePreparedTxnDB* txn_db);
/rocksdb-6.9/include/rocksdb/
Dc.h1516 rocksdb_transactiondb_t* txn_db,
1533 rocksdb_transactiondb_create_snapshot(rocksdb_transactiondb_t* txn_db);
1536 rocksdb_transactiondb_t* txn_db, const rocksdb_snapshot_t* snapshot);
1539 rocksdb_transactiondb_t* txn_db,
1583 rocksdb_transactiondb_t* txn_db, const rocksdb_readoptions_t* options,
1587 rocksdb_transactiondb_t* txn_db, const rocksdb_readoptions_t* options,
1600 rocksdb_transactiondb_t* txn_db, const rocksdb_writeoptions_t* options,
1604 rocksdb_transactiondb_t* txn_db, const rocksdb_writeoptions_t* options,
1655 rocksdb_transactiondb_create_iterator(rocksdb_transactiondb_t* txn_db,
1660 rocksdb_transactiondb_t* txn_db, const rocksdb_readoptions_t* options,
[all …]
/rocksdb-6.9/utilities/
Denv_librados_test.cc1011 TransactionDB* txn_db; in TEST_F() local
1028 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_F()
1040 s = txn_db->Get(read_options, "abc", &value); in TEST_F()
1045 s = txn_db->Put(write_options, "xyz", "zzz"); in TEST_F()
1061 txn = txn_db->BeginTransaction(write_options, txn_options); in TEST_F()
1066 s = txn_db->Put(write_options, "abc", "xyz"); in TEST_F()
1095 txn = txn_db->BeginTransaction(write_options, txn_options); in TEST_F()
1098 read_options.snapshot = txn_db->GetSnapshot(); in TEST_F()
1103 s = txn_db->Put(write_options, "y", "y"); in TEST_F()
1108 read_options.snapshot = txn_db->GetSnapshot(); in TEST_F()
[all …]
/rocksdb-6.9/docs/_posts/
D2019-08-15-unordered-write.markdown33 TransactionDB* txn_db;
34 TransactionDB::Open(options, txn_db_options, kDBPath, &txn_db);
35 db = txn_db;
/rocksdb-6.9/tools/
Ddb_bench_tool.cc6567 TransactionDB* txn_db = reinterpret_cast<TransactionDB*>(db_.db); in RandomTransaction() local
6568 success = inserter.TransactionDBInsert(txn_db, txn_options); in RandomTransaction()