Home
last modified time | relevance | path

Searched refs:txn_options (Results 1 – 25 of 35) sorted by relevance

12

/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_transaction_test.cc78 TransactionOptions txn_options; in TEST_P() local
179 TransactionOptions txn_options; in TEST_P() local
325 TransactionOptions txn_options; in TEST_P() local
420 TransactionOptions txn_options; in TEST_P() local
486 TransactionOptions txn_options; in TEST_P() local
488 txn_options.write_batch_flush_threshold = 1; in TEST_P()
560 TransactionOptions txn_options; in TEST_P() local
561 txn_options.write_batch_flush_threshold = 1; in TEST_P()
588 TransactionOptions txn_options; in TEST_P() local
644 TransactionOptions txn_options; in TEST_P() local
[all …]
Dtransaction_test.cc96 TransactionOptions txn_options; in TEST_P() local
158 TransactionOptions txn_options; in TEST_P() local
159 txn_options.lock_timeout = 1; in TEST_P()
263 TransactionOptions txn_options; in TEST_P() local
267 txn_options.lock_timeout = 1; in TEST_P()
357 TransactionOptions txn_options; in TEST_P() local
360 txn_options.lock_timeout = 1; in TEST_P()
482 TransactionOptions txn_options; in TEST_P() local
3288 txn_options.expiration = 0; in TEST_P()
3334 txn_options.expiration = 0; in TEST_P()
[all …]
Dpessimistic_transaction.cc40 const TransactionOptions& txn_options, const bool init) in PessimisticTransaction() argument
55 Initialize(txn_options); in PessimisticTransaction()
64 deadlock_detect_ = txn_options.deadlock_detect; in Initialize()
65 deadlock_detect_depth_ = txn_options.deadlock_detect_depth; in Initialize()
66 write_batch_.SetMaxBytes(txn_options.max_write_batch_size); in Initialize()
67 skip_concurrency_control_ = txn_options.skip_concurrency_control; in Initialize()
69 lock_timeout_ = txn_options.lock_timeout * 1000; in Initialize()
76 if (txn_options.expiration >= 0) { in Initialize()
82 if (txn_options.set_snapshot) { in Initialize()
110 const TransactionOptions& txn_options) { in Reinitialize() argument
[all …]
Doptimistic_transaction_test.cc143 OptimisticTransactionOptions txn_options; in TEST_P() local
150 txn_options.set_snapshot = true; in TEST_P()
178 OptimisticTransactionOptions txn_options; in TEST_P() local
185 txn_options.set_snapshot = true; in TEST_P()
557 OptimisticTransactionOptions txn_options; in TEST_P() local
558 txn_options.set_snapshot = true; in TEST_P()
582 OptimisticTransactionOptions txn_options; in TEST_P() local
622 txn_options.set_snapshot = true; in TEST_P()
781 txn_options.set_snapshot = true; in TEST_P()
863 txn_options.set_snapshot = true; in TEST_P()
[all …]
Doptimistic_transaction.cc30 const OptimisticTransactionOptions& txn_options) in OptimisticTransaction() argument
32 Initialize(txn_options); in OptimisticTransaction()
36 const OptimisticTransactionOptions& txn_options) { in Initialize() argument
37 if (txn_options.set_snapshot) { in Initialize()
44 const OptimisticTransactionOptions& txn_options) { in Reinitialize() argument
46 Initialize(txn_options); in Reinitialize()
Doptimistic_transaction_db_impl.cc23 const OptimisticTransactionOptions& txn_options, Transaction* old_txn) { in BeginTransaction() argument
25 ReinitializeTransaction(old_txn, write_options, txn_options); in BeginTransaction()
28 return new OptimisticTransaction(this, write_options, txn_options); in BeginTransaction()
103 const OptimisticTransactionOptions& txn_options) { in ReinitializeTransaction() argument
107 txn_impl->Reinitialize(this, write_options, txn_options); in ReinitializeTransaction()
Dtransaction_test.h266 TransactionOptions txn_options; variable
268 Transaction* txn = db->BeginTransaction(write_options, txn_options);
299 TransactionOptions txn_options; variable
301 Transaction* txn = db->BeginTransaction(write_options, txn_options);
332 TransactionOptions txn_options; variable
334 Transaction* txn = db->BeginTransaction(write_options, txn_options);
376 TransactionOptions txn_options; in CrossCompatibilityTest() local
416 txn = db->BeginTransaction(write_options, txn_options); in CrossCompatibilityTest()
Dpessimistic_transaction.h41 const TransactionOptions& txn_options,
50 const TransactionOptions& txn_options);
137 virtual void Initialize(const TransactionOptions& txn_options);
204 const TransactionOptions& txn_options);
Doptimistic_transaction.h33 const OptimisticTransactionOptions& txn_options);
42 const OptimisticTransactionOptions& txn_options);
62 void Initialize(const OptimisticTransactionOptions& txn_options);
Dpessimistic_transaction_db.cc171 const WriteOptions& write_options, const TransactionOptions& txn_options, in BeginTransaction() argument
174 ReinitializeTransaction(old_txn, write_options, txn_options); in BeginTransaction()
177 return new WriteCommittedTxn(this, write_options, txn_options); in BeginTransaction()
417 TransactionOptions txn_options; in BeginInternalTransaction() local
418 Transaction* txn = BeginTransaction(options, txn_options, nullptr); in BeginInternalTransaction()
571 const TransactionOptions& txn_options) { in ReinitializeTransaction() argument
575 txn_impl->Reinitialize(this, write_options, txn_options); in ReinitializeTransaction()
Dwrite_prepared_transaction_test.cc804 TransactionOptions txn_options; in TEST_P() local
805 txn_options.set_snapshot = true; in TEST_P()
937 TransactionOptions txn_options; in TEST_P() local
1320 TransactionOptions txn_options; in TEST_P() local
1437 TransactionOptions txn_options; in TEST_P() local
1520 TransactionOptions txn_options; in TEST_P() local
1529 txn_options.set_snapshot = true; in TEST_P()
1556 TransactionOptions txn_options; in TEST_P() local
1597 TransactionOptions txn_options; in TEST_P() local
1800 TransactionOptions txn_options; in TEST_P() local
[all …]
Dwrite_unprepared_txn.cc38 const TransactionOptions& txn_options) in WriteUnpreparedTxn() argument
39 : WritePreparedTxn(txn_db, write_options, txn_options), in WriteUnpreparedTxn()
44 if (txn_options.write_batch_flush_threshold < 0) { in WriteUnpreparedTxn()
48 write_batch_flush_threshold_ = txn_options.write_batch_flush_threshold; in WriteUnpreparedTxn()
82 void WriteUnpreparedTxn::Initialize(const TransactionOptions& txn_options) { in Initialize() argument
83 PessimisticTransaction::Initialize(txn_options); in Initialize()
84 if (txn_options.write_batch_flush_threshold < 0) { in Initialize()
88 write_batch_flush_threshold_ = txn_options.write_batch_flush_threshold; in Initialize()
Dwrite_prepared_txn.cc29 const TransactionOptions& txn_options) in WritePreparedTxn() argument
30 : PessimisticTransaction(txn_db, write_options, txn_options, false), in WritePreparedTxn()
35 Initialize(txn_options); in WritePreparedTxn()
38 void WritePreparedTxn::Initialize(const TransactionOptions& txn_options) { in Initialize() argument
39 PessimisticTransaction::Initialize(txn_options); in Initialize()
Doptimistic_transaction_db_impl.h46 const OptimisticTransactionOptions& txn_options,
66 const OptimisticTransactionOptions& txn_options =
Dpessimistic_transaction_db.h46 const TransactionOptions& txn_options,
153 const TransactionOptions& txn_options = TransactionOptions());
207 const TransactionOptions& txn_options,
Dwrite_prepared_txn.h44 const TransactionOptions& txn_options);
79 void Initialize(const TransactionOptions& txn_options) override;
Dwrite_unprepared_txn_db.cc354 const WriteOptions& write_options, const TransactionOptions& txn_options, in BeginTransaction() argument
357 ReinitializeTransaction(old_txn, write_options, txn_options); in BeginTransaction()
360 return new WriteUnpreparedTxn(this, write_options, txn_options); in BeginTransaction()
Dwrite_unprepared_txn.h116 const TransactionOptions& txn_options);
170 void Initialize(const TransactionOptions& txn_options) override;
Dwrite_prepared_txn_db.cc105 const WriteOptions& write_options, const TransactionOptions& txn_options, in BeginTransaction() argument
108 ReinitializeTransaction(old_txn, write_options, txn_options); in BeginTransaction()
111 return new WritePreparedTxn(this, write_options, txn_options); in BeginTransaction()
727 TransactionOptions txn_options; in AdvanceSeqByOne() local
728 Transaction* txn0 = BeginTransaction(woptions, txn_options, nullptr); in AdvanceSeqByOne()
/rocksdb-6.9/examples/
Dtransaction_example.cc30 TransactionOptions txn_options; in main() local
88 txn_options.set_snapshot = true; in main()
89 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
133 txn_options.set_snapshot = true; in main()
134 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
Doptimistic_transaction_example.cc31 OptimisticTransactionOptions txn_options; in main() local
85 txn_options.set_snapshot = true; in main()
86 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
128 txn_options.set_snapshot = true; in main()
129 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
/rocksdb-6.9/java/rocksjni/
Dtransaction_db.cc209 auto* txn_options = reinterpret_cast<ROCKSDB_NAMESPACE::TransactionOptions*>( in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ() local
212 txn_db->BeginTransaction(*write_options, *txn_options); in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ()
229 ROCKSDB_NAMESPACE::TransactionOptions txn_options; in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ() local
231 txn_db->BeginTransaction(*write_options, txn_options, old_txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ()
252 auto* txn_options = reinterpret_cast<ROCKSDB_NAMESPACE::TransactionOptions*>( in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ() local
257 txn_db->BeginTransaction(*write_options, *txn_options, old_txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ()
/rocksdb-6.9/test_util/
Dtransaction_test_util.cc51 TransactionDB* db, const TransactionOptions& txn_options) { in TransactionDBInsert() argument
52 txn_ = db->BeginTransaction(write_options_, txn_options, txn_); in TransactionDBInsert()
76 const OptimisticTransactionOptions& txn_options) { in OptimisticTransactionDBInsert() argument
78 db->BeginTransaction(write_options_, txn_options, optimistic_txn_); in OptimisticTransactionDBInsert()
Dtransaction_test_util.h55 const TransactionOptions& txn_options = TransactionOptions());
65 const OptimisticTransactionOptions& txn_options =
/rocksdb-6.9/utilities/
Denv_librados_test.cc1018 TransactionOptions txn_options; in TEST_F() local
1060 txn_options.set_snapshot = true; in TEST_F()
1061 txn = txn_db->BeginTransaction(write_options, txn_options); in TEST_F()
1094 txn_options.set_snapshot = true; in TEST_F()
1095 txn = txn_db->BeginTransaction(write_options, txn_options); in TEST_F()

12