Home
last modified time | relevance | path

Searched refs:Transaction (Results 1 – 25 of 48) sorted by relevance

12

/rocksdb-6.9/java/rocksjni/
Dtransaction.cc401 ROCKSDB_NAMESPACE::Transaction::*)( in Java_org_rocksdb_Transaction_multiGet__JJ_3_3B_3J()
421 ROCKSDB_NAMESPACE::Transaction::*)( in Java_org_rocksdb_Transaction_multiGet__JJ_3_3B()
607 bool)>(&ROCKSDB_NAMESPACE::Transaction::Put, txn, in Java_org_rocksdb_Transaction_put__J_3BI_3BIJZ()
626 &ROCKSDB_NAMESPACE::Transaction::Put, txn, _1, _2); in Java_org_rocksdb_Transaction_put__J_3BI_3BI()
769 &ROCKSDB_NAMESPACE::Transaction::Put, txn, _1, _2); in Java_org_rocksdb_Transaction_put__J_3_3BI_3_3BI()
791 bool)>(&ROCKSDB_NAMESPACE::Transaction::Merge, txn, in Java_org_rocksdb_Transaction_merge__J_3BI_3BIJZ()
872 &ROCKSDB_NAMESPACE::Transaction::Delete, txn, _1); in Java_org_rocksdb_Transaction_delete__J_3BI()
968 &ROCKSDB_NAMESPACE::Transaction::Delete, txn, _1); in Java_org_rocksdb_Transaction_delete__J_3_3BI()
988 &ROCKSDB_NAMESPACE::Transaction::SingleDelete, txn, in Java_org_rocksdb_Transaction_singleDelete__J_3BIJZ()
1027 &ROCKSDB_NAMESPACE::Transaction::SingleDelete, txn, in Java_org_rocksdb_Transaction_singleDelete__J_3_3BIJZ()
[all …]
Doptimistic_transaction_db.cc195 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJ()
215 ROCKSDB_NAMESPACE::Transaction* txn = optimistic_txn_db->BeginTransaction( in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJJ()
233 reinterpret_cast<ROCKSDB_NAMESPACE::Transaction*>(jold_txn_handle); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJ()
235 ROCKSDB_NAMESPACE::Transaction* txn = optimistic_txn_db->BeginTransaction( in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJ()
262 reinterpret_cast<ROCKSDB_NAMESPACE::Transaction*>(jold_txn_handle); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJJ()
263 ROCKSDB_NAMESPACE::Transaction* txn = optimistic_txn_db->BeginTransaction( in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJJ()
Dtransaction_db.cc193 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_TransactionDB_beginTransaction__JJ()
211 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ()
228 reinterpret_cast<ROCKSDB_NAMESPACE::Transaction*>(jold_txn_handle); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ()
230 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ()
255 reinterpret_cast<ROCKSDB_NAMESPACE::Transaction*>(jold_txn_handle); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ()
256 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ()
280 ROCKSDB_NAMESPACE::Transaction* txn = txn_db->GetTransactionByName(name); in Java_org_rocksdb_TransactionDB_getTransactionByName()
293 std::vector<ROCKSDB_NAMESPACE::Transaction*> txns; in Java_org_rocksdb_TransactionDB_getAllPreparedTransactions()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DTransactionTest.java29 try(final Transaction txn = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict()
35 try(final Transaction txn2 = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict()
62 try(final Transaction txn = dbContainer.beginTransaction()) { in getForUpdate_conflict()
171 final Transaction txn = dbContainer.beginTransaction()) { in name()
182 final Transaction txn = dbContainer.beginTransaction()) { in ID()
190 final Transaction txn = dbContainer.beginTransaction()) { in deadlockDetect()
209 .isSameAs(Transaction.TransactionState.STARTED); in state()
212 .isSameAs(Transaction.TransactionState.COMMITTED); in state()
217 .isSameAs(Transaction.TransactionState.STARTED); in state()
220 .isSameAs(Transaction.TransactionState.STARTED); in state()
[all …]
DAbstractTransactionTest.java41 final Transaction txn = dbContainer.beginTransaction()) { in setSnapshot()
49 final Transaction txn = dbContainer.beginTransaction()) { in setSnapshotOnNextOperation()
58 final Transaction txn = dbContainer.beginTransaction()) { in setSnapshotOnNextOperation_transactionNotifier()
75 final Transaction txn = dbContainer.beginTransaction()) { in getSnapshot()
85 final Transaction txn = dbContainer.beginTransaction()) { in getSnapshot_null()
94 final Transaction txn = dbContainer.beginTransaction()) { in clearSnapshot()
103 final Transaction txn = dbContainer.beginTransaction()) { in clearSnapshot_none()
186 final Transaction txn = dbContainer.beginTransaction()) { in getPut_cf()
200 final Transaction txn = dbContainer.beginTransaction()) { in getPut()
890 public abstract Transaction beginTransaction(); in beginTransaction()
[all …]
DOptimisticTransactionTest.java29 try(final Transaction txn = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict()
35 try(final Transaction txn2 = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict()
36 try(final Transaction txn3 = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict()
66 try(final Transaction txn = dbContainer.beginTransaction()) { in getForUpdate_conflict()
72 try(final Transaction txn2 = dbContainer.beginTransaction()) { in getForUpdate_conflict()
110 try(final Transaction txn = dbContainer.beginTransaction()) { in multiGetForUpdate_cf_conflict()
117 try(final Transaction txn2 = dbContainer.beginTransaction()) { in multiGetForUpdate_cf_conflict()
154 try(final Transaction txn = dbContainer.beginTransaction()) { in multiGetForUpdate_conflict()
195 try(final Transaction txn = dbContainer.beginTransaction()) { in undoGetForUpdate_cf_conflict()
258 final Transaction txn = dbContainer.beginTransaction()) { in name()
[all …]
DOptimisticTransactionDBTest.java66 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction()
81 try(final Transaction txn = otdb.beginTransaction(writeOptions, in beginTransaction_transactionOptions()
95 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction_withOld()
96 final Transaction txnReused = otdb.beginTransaction(writeOptions, txn); in beginTransaction_withOld()
112 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction_withOld_transactionOptions()
113 final Transaction txnReused = otdb.beginTransaction(writeOptions, in beginTransaction_withOld_transactionOptions()
DTransactionDBTest.java68 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction()
83 try(final Transaction txn = tdb.beginTransaction(writeOptions, in beginTransaction_transactionOptions()
98 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction_withOld()
99 final Transaction txnReused = tdb.beginTransaction(writeOptions, txn); in beginTransaction_withOld()
115 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction_withOld_transactionOptions()
116 final Transaction txnReused = tdb.beginTransaction(writeOptions, in beginTransaction_withOld_transactionOptions()
132 try (final Transaction txn = tdb.beginTransaction(writeOptions)) { in lockStatusData()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DTransactionDB.java156 return new Transaction(this, beginTransaction(nativeHandle_, in beginTransaction()
161 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
163 return new Transaction(this, beginTransaction(nativeHandle_, in beginTransaction()
174 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
175 final Transaction oldTransaction) { in beginTransaction()
188 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
190 final Transaction oldTransaction) { in beginTransaction()
209 final Transaction txn = new Transaction(this, jtxnHandle); in getTransactionByName()
217 public List<Transaction> getAllPreparedTransactions() { in getAllPreparedTransactions()
220 final List<Transaction> txns = new ArrayList<>(); in getAllPreparedTransactions()
[all …]
DTransactionalDB.java21 Transaction beginTransaction(final WriteOptions writeOptions); in beginTransaction()
33 Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
49 Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
50 final Transaction oldTransaction); in beginTransaction()
66 Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
67 final T transactionOptions, final Transaction oldTransaction); in beginTransaction()
DOptimisticTransactionDB.java146 public Transaction beginTransaction(final WriteOptions writeOptions) { in beginTransaction()
147 return new Transaction(this, beginTransaction(nativeHandle_, in beginTransaction()
152 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
154 return new Transaction(this, beginTransaction(nativeHandle_, in beginTransaction()
166 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
167 final Transaction oldTransaction) { in beginTransaction()
180 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction()
182 final Transaction oldTransaction) { in beginTransaction()
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction_db.h45 Transaction* BeginTransaction(const WriteOptions& write_options,
47 Transaction* old_txn) override = 0;
75 Transaction* txn = BeginInternalTransaction(opts); in WriteWithConcurrencyControl()
79 static_cast_with_check<PessimisticTransaction, Transaction>(txn); in WriteWithConcurrencyControl()
128 void RegisterTransaction(Transaction* txn);
129 void UnregisterTransaction(Transaction* txn);
152 Transaction* txn, const WriteOptions& write_options,
174 Transaction* BeginInternalTransaction(const WriteOptions& options);
185 std::unordered_map<TransactionName, Transaction*> transactions_;
206 Transaction* BeginTransaction(const WriteOptions& write_options,
[all …]
Dpessimistic_transaction_db.cc159 real_trx->SetState(Transaction::PREPARED); in Initialize()
170 Transaction* WriteCommittedTxnDB::BeginTransaction( in BeginTransaction()
172 Transaction* old_txn) { in BeginTransaction()
439 Transaction* txn = BeginInternalTransaction(options); in Put()
460 Transaction* txn = BeginInternalTransaction(wopts); in Delete()
482 Transaction* txn = BeginInternalTransaction(wopts); in SingleDelete()
504 Transaction* txn = BeginInternalTransaction(options); in Merge()
570 Transaction* txn, const WriteOptions& write_options, in ReinitializeTransaction()
590 std::vector<Transaction*>* transv) { in GetAllPreparedTransactions()
595 if (it->second->GetState() == Transaction::PREPARED) { in GetAllPreparedTransactions()
[all …]
Dtransaction_test.cc216 Transaction* txn1 = in TEST_P()
241 Transaction* txn2 = in TEST_P()
500 std::vector<Transaction*> txns(31); in TEST_P()
633 std::vector<Transaction*> txns_shared(2); in TEST_P()
707 std::vector<Transaction*> txns(len); in TEST_P()
822 Transaction* txn; in TEST_P()
884 std::vector<Transaction*> txns; in TEST_P()
965 std::vector<Transaction*> prepared_trans; in TEST_P()
1346 std::vector<Transaction*> prepared_trans; in TEST_P()
2047 Transaction* txn = db->BeginTransaction(write_options); in TEST_P()
[all …]
Doptimistic_transaction_test.cc86 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
115 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
223 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
243 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
283 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
451 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
482 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
616 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
746 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
943 Transaction* txn = txn_db->BeginTransaction(write_options); in TEST_P()
[all …]
Dwrite_prepared_txn.h54 using Transaction::Get;
59 using Transaction::MultiGet;
71 using Transaction::GetIterator;
82 inline void SetId(uint64_t id) override { Transaction::SetId(id); } in SetId()
Dwrite_unprepared_transaction_test.cc85 Transaction* txn = db->BeginTransaction(woptions, txn_options); in TEST_P()
178 Transaction* txn; in TEST_P()
326 std::vector<Transaction*> prepared_trans; in TEST_P()
350 Transaction* txn = db->BeginTransaction(write_options, txn_options); in TEST_P()
429 Transaction* txn = db->BeginTransaction(write_options, txn_options); in TEST_P()
500 Transaction* txn1 = db->BeginTransaction(write_options, txn_options); in TEST_P()
503 Transaction* txn2 = db->BeginTransaction(write_options, txn_options); in TEST_P()
563 Transaction* txn = db->BeginTransaction(woptions, txn_options); in TEST_P()
598 Transaction* txn = db->BeginTransaction(woptions, txn_options); in TEST_P()
647 Transaction* txn = db->BeginTransaction(woptions, txn_options); in TEST_P()
[all …]
Doptimistic_transaction_db_impl.h45 Transaction* BeginTransaction(const WriteOptions& write_options,
47 Transaction* old_txn) override;
64 void ReinitializeTransaction(Transaction* txn,
Doptimistic_transaction_db_impl.cc21 Transaction* OptimisticTransactionDBImpl::BeginTransaction( in BeginTransaction()
23 const OptimisticTransactionOptions& txn_options, Transaction* old_txn) { in BeginTransaction()
102 Transaction* txn, const WriteOptions& write_options, in ReinitializeTransaction()
/rocksdb-6.9/test_util/
Dtransaction_test_util.h75 static Status DBGet(DB* db, Transaction* txn, ReadOptions& read_options,
120 Transaction* txn_ = nullptr;
121 Transaction* optimistic_txn_ = nullptr;
127 bool DoInsert(DB* db, Transaction* txn, bool is_optimistic);
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction.h53 class Transaction {
56 Transaction(const Transaction&) = delete;
57 void operator=(const Transaction&) = delete;
59 virtual ~Transaction() {} in ~Transaction()
513 explicit Transaction(const TransactionDB* /*db*/) {} in Transaction() function
514 Transaction() : log_number_(0), txn_state_(STARTED) {} in Transaction() function
Dtransaction_db.h282 virtual Transaction* BeginTransaction(
285 Transaction* old_txn = nullptr) = 0;
287 virtual Transaction* GetTransactionByName(const TransactionName& name) = 0;
288 virtual void GetAllPreparedTransactions(std::vector<Transaction*>* trans) = 0;
Doptimistic_transaction_db.h18 class Transaction; variable
82 virtual Transaction* BeginTransaction(
86 Transaction* old_txn = nullptr) = 0;
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.h16 class Transaction; variable
52 Status NewTxn(WriteOptions& write_opts, Transaction** txn);
54 Status CommitTxn(Transaction* txn);
56 Status RollbackTxn(Transaction* txn);
/rocksdb-6.9/java/samples/src/main/java/
DOptimisticTransactionSample.java68 try(final Transaction txn = txnDb.beginTransaction(writeOptions)) { in readCommitted()
103 final Transaction txn = in repeatableRead()
152 final Transaction txn = in readCommitted_monotonicAtomicViews()

12