| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | TransactionDBTest.java | 26 final TransactionDB tdb = TransactionDB.open(options, txnDbOptions, in open()
46 final TransactionDB tdb = TransactionDB.open(dbOptions, txnDbOptions, in open_columnFamilies()
64 final TransactionDB tdb = TransactionDB.open(options, txnDbOptions, in beginTransaction()
78 final TransactionDB tdb = TransactionDB.open(options, txnDbOptions, in beginTransaction_transactionOptions()
94 final TransactionDB tdb = TransactionDB.open(options, txnDbOptions, in beginTransaction_withOld()
110 final TransactionDB tdb = TransactionDB.open(options, txnDbOptions, in beginTransaction_withOld_transactionOptions()
127 final TransactionDB tdb = TransactionDB.open(options, txnDbOptions, in lockStatusData()
140 final Map<Long, TransactionDB.KeyLockInfo> lockStatus = in lockStatusData()
148 final TransactionDB.KeyLockInfo keyLockInfo = entry.getValue(); in lockStatusData()
161 final TransactionDB tdb = TransactionDB.open(options, txnDbOptions, in deadlockInfoBuffer()
[all …]
|
| D | TransactionTest.java | 247 final TransactionDB txnDb; in startDb()
249 txnDb = TransactionDB.open(options, txnDbOptions, in startDb()
269 private final TransactionDB txnDb;
275 final TransactionDB txnDb, final TransactionDBOptions txnDbOptions, in TransactionDBContainer()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | transaction_db.h | 224 class TransactionDB : public StackableDB {
241 const std::string& dbname, TransactionDB** dbptr);
248 TransactionDB** dbptr);
261 TransactionDB** dbptr);
269 const std::vector<ColumnFamilyHandle*>& handles, TransactionDB** dbptr);
272 ~TransactionDB() override {} in ~TransactionDB()
301 explicit TransactionDB(DB* db) : StackableDB(db) {} in TransactionDB() function
303 TransactionDB(const TransactionDB&) = delete;
304 void operator=(const TransactionDB&) = delete;
|
| D | transaction.h | 20 class TransactionDB; variable
513 explicit Transaction(const TransactionDB* /*db*/) {} in Transaction() argument
|
| /rocksdb-6.9/java/rocksjni/ |
| D | transaction_db.cc | 35 ROCKSDB_NAMESPACE::TransactionDB* tdb = nullptr; in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2()
41 ROCKSDB_NAMESPACE::Status s = ROCKSDB_NAMESPACE::TransactionDB::Open( in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2()
126 ROCKSDB_NAMESPACE::TransactionDB* tdb = nullptr; in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
127 const ROCKSDB_NAMESPACE::Status s = ROCKSDB_NAMESPACE::TransactionDB::Open( in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
165 auto* txn_db = reinterpret_cast<ROCKSDB_NAMESPACE::TransactionDB*>(jhandle); in Java_org_rocksdb_TransactionDB_disposeInternal()
177 auto* txn_db = reinterpret_cast<ROCKSDB_NAMESPACE::TransactionDB*>(jhandle); in Java_org_rocksdb_TransactionDB_closeDatabase()
190 auto* txn_db = reinterpret_cast<ROCKSDB_NAMESPACE::TransactionDB*>(jhandle); in Java_org_rocksdb_TransactionDB_beginTransaction__JJ()
206 auto* txn_db = reinterpret_cast<ROCKSDB_NAMESPACE::TransactionDB*>(jhandle); in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ()
224 auto* txn_db = reinterpret_cast<ROCKSDB_NAMESPACE::TransactionDB*>(jhandle); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ()
249 auto* txn_db = reinterpret_cast<ROCKSDB_NAMESPACE::TransactionDB*>(jhandle); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ()
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | TransactionDB.java | 16 public class TransactionDB extends RocksDB class
26 private TransactionDB(final long nativeHandle) { in TransactionDB() method in TransactionDB
43 public static TransactionDB open(final Options options, in open()
46 final TransactionDB tdb = new TransactionDB(open(options.nativeHandle_, in open()
74 public static TransactionDB open(final DBOptions dbOptions, in open()
92 final TransactionDB tdb = new TransactionDB(handles[0]); in open()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | pessimistic_transaction_db.cc | 31 : TransactionDB(db), in PessimisticTransactionDB()
62 : TransactionDB(db), in PessimisticTransactionDB()
192 Status TransactionDB::Open(const Options& options, in Open()
194 const std::string& dbname, TransactionDB** dbptr) { in Open()
201 Status s = TransactionDB::Open(db_options, txn_db_options, dbname, in Open()
213 Status TransactionDB::Open( in Open()
217 std::vector<ColumnFamilyHandle*>* handles, TransactionDB** dbptr) { in Open()
265 void TransactionDB::PrepareWrap( in PrepareWrap()
289 Status TransactionDB::WrapDB( in WrapDB()
294 const std::vector<ColumnFamilyHandle*>& handles, TransactionDB** dbptr) { in WrapDB()
[all …]
|
| D | transaction_test.h | 43 TransactionDB* db;
79 s = TransactionDB::Open(options, txn_db_options, dbname, &db); in TransactionTestBase()
106 s = TransactionDB::Open(options, txn_db_options, dbname, &db); in ReOpenNoDelete()
127 s = TransactionDB::Open(options, txn_db_options, dbname, cfs, handles, in ReOpenNoDelete()
142 s = TransactionDB::Open(options, txn_db_options, dbname, &db); in ReOpen()
153 TransactionDB::PrepareWrap(&options, &cfs, &compaction_enabled_cf_indices); in OpenWithStackableDB()
167 s = TransactionDB::WrapStackableDB(stackable_db, txn_db_options, in OpenWithStackableDB()
182 TransactionDB::PrepareWrap(&options, &column_families, in OpenWithStackableDB()
202 s = TransactionDB::WrapStackableDB(stackable_db, txn_db_options, in OpenWithStackableDB()
|
| D | pessimistic_transaction.h | 40 PessimisticTransaction(TransactionDB* db, const WriteOptions& write_options,
49 void Reinitialize(TransactionDB* txn_db, const WriteOptions& write_options,
203 WriteCommittedTxn(TransactionDB* db, const WriteOptions& write_options,
|
| D | pessimistic_transaction_db.h | 29 class PessimisticTransactionDB : public TransactionDB {
69 using TransactionDB::Write;
212 using TransactionDB::Write;
|
| D | pessimistic_transaction.cc | 39 TransactionDB* txn_db, const WriteOptions& 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()
129 WriteCommittedTxn::WriteCommittedTxn(TransactionDB* txn_db, in WriteCommittedTxn()
|
| D | transaction_lock_mgr.h | 57 TransactionLockMgr(TransactionDB* txn_db, size_t default_num_stripes,
|
| D | transaction_lock_mgr.cc | 164 TransactionDB* txn_db, size_t default_num_stripes, int64_t max_num_locks, in TransactionLockMgr()
175 static_cast_with_check<PessimisticTransactionDB, TransactionDB>(txn_db); in TransactionLockMgr()
|
| /rocksdb-6.9/java/samples/src/main/java/ |
| D | TransactionSample.java | 22 final TransactionDB txnDb = in main()
23 TransactionDB.open(options, txnDbOptions, dbPath)) { in main()
59 private static void readCommitted(final TransactionDB txnDb, in readCommitted()
94 private static void repeatableRead(final TransactionDB txnDb, in repeatableRead()
138 final TransactionDB txnDb, final WriteOptions writeOptions, in readCommitted_monotonicAtomicViews()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2019-08-15-unordered-write.markdown | 19 …e and immutable snapshots when using this feature in conjunction with TransactionDB configured wit…
33 TransactionDB* txn_db;
34 TransactionDB::Open(options, txn_db_options, kDBPath, &txn_db);
|
| /rocksdb-6.9/examples/ |
| D | transaction_example.cc | 23 TransactionDB* txn_db; in main()
25 Status s = TransactionDB::Open(options, txn_db_options, kDBPath, &txn_db); in main()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_test_base.h | 17 class TransactionDB; variable
213 TransactionDB* txn_db_;
|
| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_test.cc | 598 TransactionDB* txdb; in TEST_F()
599 Status s = TransactionDB::Open(options, txn_db_options, dbname, &txdb); in TEST_F()
677 TransactionDB* snapshotDB; in TEST_F()
686 ASSERT_OK(TransactionDB::Open(options, txn_db_options, snapshot_name_, in TEST_F()
|
| /rocksdb-6.9/test_util/ |
| D | transaction_test_util.h | 54 TransactionDB* db,
|
| D | transaction_test_util.cc | 51 TransactionDB* db, const TransactionOptions& txn_options) { in TransactionDBInsert()
|
| /rocksdb-6.9/utilities/ |
| D | env_librados_test.cc | 1011 TransactionDB* txn_db; in TEST_F()
1013 Status s = TransactionDB::Open(options, txn_db_options, kDBPath, &txn_db); in TEST_F()
|
| /rocksdb-6.9/java/ |
| D | CMakeLists.txt | 222 src/main/java/org/rocksdb/TransactionDB.java
457 org.rocksdb.TransactionDB
|
| D | Makefile | 69 org.rocksdb.TransactionDB\
|
| /rocksdb-6.9/db/ |
| D | c.cc | 108 using ROCKSDB_NAMESPACE::TransactionDB;
176 TransactionDB* rep;
3849 TransactionDB* txn_db; in rocksdb_transactiondb_open()
3850 if (SaveError(errptr, TransactionDB::Open(options->rep, txn_db_options->rep, in rocksdb_transactiondb_open()
3872 TransactionDB* txn_db; in rocksdb_transactiondb_open_column_families()
3874 if (SaveError(errptr, TransactionDB::Open(options->rep, txn_db_options->rep, in rocksdb_transactiondb_open_column_families()
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 4156 TransactionDB* ptr; in OpenDb()
4163 s = TransactionDB::Open(options, txn_db_options, db_name, in OpenDb()
4187 TransactionDB* ptr = nullptr; in OpenDb()
4196 s = TransactionDB::Open(options, txn_db_options, db_name, &ptr); in OpenDb()
6567 TransactionDB* txn_db = reinterpret_cast<TransactionDB*>(db_.db); in RandomTransaction()
|