Home
last modified time | relevance | path

Searched refs:txn_db_options (Results 1 – 18 of 18) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dtransaction_test.h48 TransactionDBOptions txn_db_options; variable
67 txn_db_options.transaction_lock_timeout = 0; in TransactionTestBase()
68 txn_db_options.default_lock_timeout = 0; in TransactionTestBase()
69 txn_db_options.write_policy = write_policy; in TransactionTestBase()
70 txn_db_options.rollback_merge_operands = true; in TransactionTestBase()
76 txn_db_options.autogenerate_name = true; in TransactionTestBase()
279 } else if (txn_db_options.write_policy ==
316 } else if (txn_db_options.write_policy ==
349 } else if (txn_db_options.write_policy ==
385 txn_db_options.write_policy = from_policy; in CrossCompatibilityTest()
[all …]
Dpessimistic_transaction_db.cc30 DB* db, const TransactionDBOptions& txn_db_options) in PessimisticTransactionDB() argument
33 txn_db_options_(txn_db_options), in PessimisticTransactionDB()
64 txn_db_options_(txn_db_options), in PessimisticTransactionDB()
182 const TransactionDBOptions& txn_db_options) { in ValidateTxnDBOptions() argument
183 TransactionDBOptions validated = txn_db_options; in ValidateTxnDBOptions()
185 if (txn_db_options.num_stripes == 0) { in ValidateTxnDBOptions()
231 if (txn_db_options.write_policy == WRITE_PREPARED && in Open()
244 txn_db_options.write_policy == WRITE_PREPARED || in Open()
248 txn_db_options.write_policy == WRITE_PREPARED; in Open()
299 switch (txn_db_options.write_policy) { in WrapDB()
[all …]
Dpessimistic_transaction_db.h32 const TransactionDBOptions& txn_db_options);
35 const TransactionDBOptions& txn_db_options);
110 const TransactionDBOptions& txn_db_options);
197 const TransactionDBOptions& txn_db_options) in WriteCommittedTxnDB() argument
198 : PessimisticTransactionDB(db, txn_db_options) {} in WriteCommittedTxnDB()
201 const TransactionDBOptions& txn_db_options) in WriteCommittedTxnDB() argument
202 : PessimisticTransactionDB(db, txn_db_options) {} in WriteCommittedTxnDB()
Dwrite_prepared_txn_db.h41 const TransactionDBOptions& txn_db_options) in WritePreparedTxnDB() argument
42 : PessimisticTransactionDB(db, txn_db_options), in WritePreparedTxnDB()
43 SNAPSHOT_CACHE_BITS(txn_db_options.wp_snapshot_cache_bits), in WritePreparedTxnDB()
45 COMMIT_CACHE_BITS(txn_db_options.wp_commit_cache_bits), in WritePreparedTxnDB()
48 Init(txn_db_options); in WritePreparedTxnDB()
52 const TransactionDBOptions& txn_db_options) in WritePreparedTxnDB() argument
53 : PessimisticTransactionDB(db, txn_db_options), in WritePreparedTxnDB()
54 SNAPSHOT_CACHE_BITS(txn_db_options.wp_snapshot_cache_bits), in WritePreparedTxnDB()
56 COMMIT_CACHE_BITS(txn_db_options.wp_commit_cache_bits), in WritePreparedTxnDB()
59 Init(txn_db_options); in WritePreparedTxnDB()
Dtransaction_test.cc1005 switch (txn_db_options.write_policy) { in TEST_P()
1388 switch (txn_db_options.write_policy) { in TEST_P()
1760 switch (txn_db_options.write_policy) { in TEST_P()
1791 switch (txn_db_options.write_policy) { in TEST_P()
1810 switch (txn_db_options.write_policy) { in TEST_P()
1895 switch (txn_db_options.write_policy) { in TEST_P()
1917 switch (txn_db_options.write_policy) { in TEST_P()
1943 switch (txn_db_options.write_policy) { in TEST_P()
3480 txn_db_options.max_num_locks = 3; in TEST_P()
4550 txn_db_options.default_lock_timeout = -1; in TEST_P()
[all …]
Dwrite_prepared_transaction_test.cc367 txn_db_options.wp_snapshot_cache_bits = snapshot_cache_bits; in UpdateTransactionDBOptions()
368 txn_db_options.wp_commit_cache_bits = commit_cache_bits; in UpdateTransactionDBOptions()
371 txn_db_options.wp_snapshot_cache_bits = snapshot_cache_bits; in UpdateTransactionDBOptions()
1012 new WritePreparedTxnDBMock(mock_db, txn_db_options)); in TEST_P()
1098 new WritePreparedTxnDBMock(mock_db, txn_db_options)); in TEST_P()
1194 new WritePreparedTxnDBMock(mock_db, txn_db_options)); in TEST_P()
1262 new WritePreparedTxnDBMock(mock_db, txn_db_options)); in TEST_P()
1652 txn_db_options.transaction_lock_timeout = 1000; in TEST_P()
1653 txn_db_options.default_lock_timeout = 1000; in TEST_P()
2110 new WritePreparedTxnDBMock(mock_db, txn_db_options)); in TEST_P()
Dwrite_unprepared_transaction_test.cc159 txn_db_options.transaction_lock_timeout = -1; in TEST_P()
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction_db.h240 const TransactionDBOptions& txn_db_options,
244 const TransactionDBOptions& txn_db_options,
258 static Status WrapDB(DB* db, const TransactionDBOptions& txn_db_options,
267 StackableDB* db, const TransactionDBOptions& txn_db_options,
/rocksdb-6.9/docs/_posts/
D2019-08-15-unordered-write.markdown30 TransactionDBOptions txn_db_options;
31 txn_db_options.write_policy = TxnDBWritePolicy::WRITE_PREPARED;
32 txn_db_options.skip_concurrency_control = true;
34 TransactionDB::Open(options, txn_db_options, kDBPath, &txn_db);
/rocksdb-6.9/java/rocksjni/
Dtransaction_db.cc32 auto* txn_db_options = in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2() local
42 *options, *txn_db_options, db_path, &tdb); in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2()
122 auto* txn_db_options = in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J() local
128 *db_options, *txn_db_options, db_path, column_families, &handles, &tdb); in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
/rocksdb-6.9/examples/
Dtransaction_example.cc21 TransactionDBOptions txn_db_options; in main() local
25 Status s = TransactionDB::Open(options, txn_db_options, kDBPath, &txn_db); in main()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc597 TransactionDBOptions txn_db_options; in TEST_F() local
599 Status s = TransactionDB::Open(options, txn_db_options, dbname, &txdb); in TEST_F()
686 ASSERT_OK(TransactionDB::Open(options, txn_db_options, snapshot_name_, in TEST_F()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.cc1989 TransactionDBOptions txn_db_options; in Open() local
1991 txn_db_options.write_policy = in Open()
1994 assert(txn_db_options.write_policy == TxnDBWritePolicy::WRITE_PREPARED); in Open()
1997 txn_db_options.skip_concurrency_control = true; in Open()
1999 s = TransactionDB::Open(options_, txn_db_options, FLAGS_db, in Open()
/rocksdb-6.9/db/
Dc_test.c442 rocksdb_transactiondb_options_t* txn_db_options; in main() local
1532 txn_db_options = rocksdb_transactiondb_options_create(); in main()
1535 txn_db = rocksdb_transactiondb_open(options, txn_db_options, dbname, &err); in main()
1658 rocksdb_transactiondb_options_destroy(txn_db_options); in main()
Dc.cc3847 const rocksdb_transactiondb_options_t* txn_db_options, const char* name, in rocksdb_transactiondb_open() argument
3850 if (SaveError(errptr, TransactionDB::Open(options->rep, txn_db_options->rep, in rocksdb_transactiondb_open()
3861 const rocksdb_transactiondb_options_t* txn_db_options, const char* name, in rocksdb_transactiondb_open_column_families() argument
3874 if (SaveError(errptr, TransactionDB::Open(options->rep, txn_db_options->rep, in rocksdb_transactiondb_open_column_families()
/rocksdb-6.9/utilities/
Denv_librados_test.cc1008 TransactionDBOptions txn_db_options; in TEST_F() local
1013 Status s = TransactionDB::Open(options, txn_db_options, kDBPath, &txn_db); in TEST_F()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc4157 TransactionDBOptions txn_db_options; in OpenDb() local
4160 txn_db_options.skip_concurrency_control = true; in OpenDb()
4161 txn_db_options.write_policy = WRITE_PREPARED; in OpenDb()
4163 s = TransactionDB::Open(options, txn_db_options, db_name, in OpenDb()
4188 TransactionDBOptions txn_db_options; in OpenDb() local
4191 txn_db_options.skip_concurrency_control = true; in OpenDb()
4192 txn_db_options.write_policy = WRITE_PREPARED; in OpenDb()
4196 s = TransactionDB::Open(options, txn_db_options, db_name, &ptr); in OpenDb()
/rocksdb-6.9/include/rocksdb/
Dc.h1522 const rocksdb_transactiondb_options_t* txn_db_options, const char* name,
1527 const rocksdb_transactiondb_options_t* txn_db_options, const char* name,