Home
last modified time | relevance | path

Searched refs:txn (Results 1 – 25 of 44) sorted by relevance

12

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DAbstractTransactionTest.java42 txn.setSnapshot(); in setSnapshot()
76 txn.setSnapshot(); in getSnapshot()
95 txn.setSnapshot(); in clearSnapshot()
114 txn.put(k1, v1); in commit()
115 txn.commit(); in commit()
132 txn.rollback(); in rollback()
170 txn.commit(); in savePoint()
202 txn.put(k1, v1); in getPut()
273 txn.put(k1, v1); in getForUpdate()
332 txn.put(k1, v1); in getIterator()
[all …]
DTransactionTest.java30 txn.put(testCf, k1, v1); in getForUpdate_cf_conflict()
32 txn.commit(); in getForUpdate_cf_conflict()
63 txn.put(k1, v1); in getForUpdate_conflict()
65 txn.commit(); in getForUpdate_conflict()
106 txn.commit(); in multiGetForUpdate_cf_conflict()
145 txn.commit(); in multiGetForUpdate_conflict()
174 txn.setName(name); in name()
208 assertThat(txn.getState()) in state()
210 txn.commit(); in state()
211 assertThat(txn.getState()) in state()
[all …]
DOptimisticTransactionTest.java30 txn.put(testCf, k1, v1); in getForUpdate_cf_conflict()
32 txn.commit(); in getForUpdate_cf_conflict()
67 txn.put(k1, v1); in getForUpdate_conflict()
69 txn.commit(); in getForUpdate_conflict()
114 txn.commit(); in multiGetForUpdate_cf_conflict()
158 txn.commit(); in multiGetForUpdate_conflict()
196 txn.put(testCf, k1, v1); in undoGetForUpdate_cf_conflict()
198 txn.commit(); in undoGetForUpdate_cf_conflict()
230 txn.put(k1, v1); in undoGetForUpdate_conflict()
232 txn.commit(); in undoGetForUpdate_conflict()
[all …]
DTransactionDBTest.java68 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction() argument
69 assertThat(txn).isNotNull(); in beginTransaction()
83 try(final Transaction txn = tdb.beginTransaction(writeOptions, in beginTransaction_transactionOptions() argument
85 assertThat(txn).isNotNull(); in beginTransaction_transactionOptions()
98 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction_withOld() argument
100 assertThat(txnReused).isSameAs(txn); in beginTransaction_withOld()
115 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction_withOld_transactionOptions() argument
117 txnOptions, txn); in beginTransaction_withOld_transactionOptions()
118 assertThat(txnReused).isSameAs(txn); in beginTransaction_withOld_transactionOptions()
132 try (final Transaction txn = tdb.beginTransaction(writeOptions)) { in lockStatusData() argument
[all …]
DOptimisticTransactionDBTest.java66 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction() argument
67 assertThat(txn).isNotNull(); in beginTransaction()
81 try(final Transaction txn = otdb.beginTransaction(writeOptions, in beginTransaction_transactionOptions() argument
83 assertThat(txn).isNotNull(); in beginTransaction_transactionOptions()
95 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction_withOld() argument
96 final Transaction txnReused = otdb.beginTransaction(writeOptions, txn); in beginTransaction_withOld()
97 assertThat(txnReused).isSameAs(txn); in beginTransaction_withOld()
112 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction_withOld_transactionOptions() argument
114 optimisticTxnOptions, txn); in beginTransaction_withOld_transactionOptions()
115 assertThat(txnReused).isSameAs(txn); in beginTransaction_withOld_transactionOptions()
/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_test.cc103 delete txn; in TEST_P()
137 delete txn; in TEST_P()
172 delete txn; in TEST_P()
211 delete txn; in TEST_P()
231 delete txn; in TEST_P()
271 delete txn; in TEST_P()
326 delete txn; in TEST_P()
469 delete txn; in TEST_P()
548 delete txn; in TEST_P()
568 delete txn; in TEST_P()
[all …]
Dwrite_unprepared_transaction_test.cc87 txn->SetSnapshot(); in TEST_P()
135 delete txn; in TEST_P()
178 Transaction* txn; in TEST_P() local
227 delete txn; in TEST_P()
303 delete txn; in TEST_P()
373 delete txn; in TEST_P()
461 delete txn; in TEST_P()
582 delete txn; in TEST_P()
638 delete txn; in TEST_P()
659 delete txn; in TEST_P()
[all …]
Dtransaction_test.cc148 delete txn; in TEST_P()
203 delete txn; in TEST_P()
1282 delete txn; in TEST_P()
1337 delete txn; in TEST_P()
1416 delete txn; in TEST_P()
1527 delete txn; in TEST_P()
1567 delete txn; in TEST_P()
1603 delete txn; in TEST_P()
1639 delete txn; in TEST_P()
1655 delete txn; in TEST_P()
[all …]
Dpessimistic_transaction_db.cc422 return txn; in BeginInternalTransaction()
447 s = txn->Commit(); in Put()
450 delete txn; in Put()
469 s = txn->Commit(); in Delete()
472 delete txn; in Delete()
491 s = txn->Commit(); in SingleDelete()
494 delete txn; in SingleDelete()
516 delete txn; in Merge()
615 assert(txn); in RegisterTransaction()
620 transactions_[txn->GetName()] = txn; in RegisterTransaction()
[all …]
Dtransaction_test.h275 ASSERT_OK(txn->Commit());
294 delete txn; variable
310 ASSERT_OK(txn->Prepare());
312 ASSERT_OK(txn->Commit());
328 delete txn; variable
343 ASSERT_OK(txn->Prepare());
345 ASSERT_OK(txn->Rollback());
369 delete txn; variable
383 Transaction* txn; in CrossCompatibilityTest() local
426 ASSERT_OK(txn->Commit()); in CrossCompatibilityTest()
[all …]
Dtransaction_lock_mgr.cc306 LockInfo lock_info(txn->GetID(), txn->GetExpirationTime(), exclusive); in TryLock()
366 if (txn->IsDeadlockDetect()) { in AcquireWithTimeout()
390 txn->ClearWaitingTxn(); in AcquireWithTimeout()
391 if (txn->IsDeadlockDetect()) { in AcquireWithTimeout()
416 const PessimisticTransaction* txn, in DecrementWaiters() argument
419 DecrementWaitersImpl(txn, wait_ids); in DecrementWaiters()
423 const PessimisticTransaction* txn, in DecrementWaitersImpl() argument
425 auto id = txn->GetID(); in DecrementWaitersImpl()
438 const PessimisticTransaction* txn, in IncrementWaiters() argument
441 auto id = txn->GetID(); in IncrementWaiters()
[all …]
Dwrite_prepared_transaction_test.cc925 delete txn; in TEST_P()
956 delete txn; in TEST_P()
1357 delete txn; in TEST_P()
1643 delete txn; in TEST_P()
2698 auto* txn = in TEST_P() local
2706 delete txn; in TEST_P()
2930 delete txn; in TEST_P()
2978 delete txn; in TEST_P()
3174 delete txn; in TEST_P()
3250 delete txn; in TEST_P()
[all …]
Dpessimistic_transaction_db.h75 Transaction* txn = BeginInternalTransaction(opts); in WriteWithConcurrencyControl() local
76 txn->DisableIndexing(); in WriteWithConcurrencyControl()
79 static_cast_with_check<PessimisticTransaction, Transaction>(txn); in WriteWithConcurrencyControl()
87 delete txn; in WriteWithConcurrencyControl() local
100 Status TryLock(PessimisticTransaction* txn, uint32_t cfh_id,
103 void UnLock(PessimisticTransaction* txn, const TransactionKeyMap* keys);
104 void UnLock(PessimisticTransaction* txn, uint32_t cfh_id,
128 void RegisterTransaction(Transaction* txn);
129 void UnregisterTransaction(Transaction* txn);
152 Transaction* txn, const WriteOptions& write_options,
Dtransaction_lock_mgr.h76 Status TryLock(PessimisticTransaction* txn, uint32_t column_family_id,
81 void UnLock(const PessimisticTransaction* txn, const TransactionKeyMap* keys,
83 void UnLock(PessimisticTransaction* txn, uint32_t column_family_id,
134 Status AcquireWithTimeout(PessimisticTransaction* txn, LockMap* lock_map,
144 void UnLockKey(const PessimisticTransaction* txn, const std::string& key,
147 bool IncrementWaiters(const PessimisticTransaction* txn,
151 void DecrementWaiters(const PessimisticTransaction* txn,
153 void DecrementWaitersImpl(const PessimisticTransaction* txn,
/rocksdb-6.9/java/rocksjni/
Dtransaction.cc33 txn->SetSnapshot(); in Java_org_rocksdb_Transaction_setSnapshot()
84 txn->ClearSnapshot(); in Java_org_rocksdb_Transaction_clearSnapshot()
138 txn->SetSavePoint(); in Java_org_rocksdb_Transaction_setSavePoint()
1265 txn->PutLogData(key_slice); in Java_org_rocksdb_Transaction_putLogData()
1282 txn->DisableIndexing(); in Java_org_rocksdb_Transaction_disableIndexing()
1294 txn->EnableIndexing(); in Java_org_rocksdb_Transaction_enableIndexing()
1305 return txn->GetNumKeys(); in Java_org_rocksdb_Transaction_getNumKeys()
1316 return txn->GetNumPuts(); in Java_org_rocksdb_Transaction_getNumPuts()
1340 return txn->GetNumMerges(); in Java_org_rocksdb_Transaction_getNumMerges()
1505 return txn->GetLogNumber(); in Java_org_rocksdb_Transaction_getLogNumber()
[all …]
Doptimistic_transaction_db.cc195 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJ() local
197 return reinterpret_cast<jlong>(txn); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJ()
215 ROCKSDB_NAMESPACE::Transaction* txn = optimistic_txn_db->BeginTransaction( in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJJ() local
217 return reinterpret_cast<jlong>(txn); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJJ()
235 ROCKSDB_NAMESPACE::Transaction* txn = optimistic_txn_db->BeginTransaction( in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJ() local
241 assert(txn == old_txn); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJ()
243 return reinterpret_cast<jlong>(txn); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJ()
263 ROCKSDB_NAMESPACE::Transaction* txn = optimistic_txn_db->BeginTransaction( in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJJ() local
269 assert(txn == old_txn); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJJ()
271 return reinterpret_cast<jlong>(txn); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJJ()
Dtransaction_db.cc193 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_TransactionDB_beginTransaction__JJ() local
195 return reinterpret_cast<jlong>(txn); in Java_org_rocksdb_TransactionDB_beginTransaction__JJ()
211 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ() local
213 return reinterpret_cast<jlong>(txn); in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ()
230 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ() local
236 assert(txn == old_txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ()
238 return reinterpret_cast<jlong>(txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ()
256 ROCKSDB_NAMESPACE::Transaction* txn = in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ() local
262 assert(txn == old_txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ()
264 return reinterpret_cast<jlong>(txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ()
[all …]
/rocksdb-6.9/examples/
Dtransaction_example.cc41 assert(txn); in main()
71 s = txn->Commit(); in main()
73 delete txn; in main()
113 txn->Rollback(); in main()
116 delete txn; in main()
140 s = txn->Put("x", "x"); in main()
148 txn->SetSnapshot(); in main()
149 txn->SetSavePoint(); in main()
158 s = txn->Put("y", "y2"); in main()
165 s = txn->Commit(); in main()
[all …]
Doptimistic_transaction_example.cc42 assert(txn); in main()
49 s = txn->Put("abc", "xyz"); in main()
65 s = txn->Commit(); in main()
67 delete txn; in main()
101 s = txn->Commit(); in main()
107 delete txn; in main()
135 s = txn->Put("x", "x"); in main()
148 txn->SetSnapshot(); in main()
155 txn->Put("y", "y"); in main()
159 s = txn->Commit(); in main()
[all …]
/rocksdb-6.9/java/samples/src/main/java/
DTransactionSample.java75 txn.put(key1, value1); in readCommitted()
87 txn.commit(); in readCommitted()
104 final Transaction txn = in repeatableRead()
123 txn.rollback(); in repeatableRead()
149 final Transaction txn = in readCommitted_monotonicAtomicViews()
156 txn.put(valueX, valueX); in readCommitted_monotonicAtomicViews()
162 txn.setSnapshot(); in readCommitted_monotonicAtomicViews()
163 txn.setSavePoint(); in readCommitted_monotonicAtomicViews()
171 txn.put(keyY, valueY); in readCommitted_monotonicAtomicViews()
174 txn.rollbackToSavePoint(); in readCommitted_monotonicAtomicViews()
[all …]
DOptimisticTransactionSample.java70 byte[] value = txn.get(readOptions, key1); in readCommitted()
74 txn.put(key1, value1); in readCommitted()
86 txn.commit(); in readCommitted()
103 final Transaction txn = in repeatableRead()
118 txn.commit(); in repeatableRead()
126 txn.rollback(); in repeatableRead()
152 final Transaction txn = in readCommitted_monotonicAtomicViews()
159 txn.put(valueX, valueX); in readCommitted_monotonicAtomicViews()
165 txn.setSnapshot(); in readCommitted_monotonicAtomicViews()
173 txn.put(keyY, valueY); in readCommitted_monotonicAtomicViews()
[all …]
/rocksdb-6.9/test_util/
Dtransaction_test_util.cc105 if (txn != nullptr) { in DBGet()
109 s = txn->Get(read_options, key, &value); in DBGet()
167 if (txn != nullptr) { in DoInsert()
168 s = txn->Put(key, sum); in DoInsert()
184 if (txn != nullptr) { in DoInsert()
195 if (txn != nullptr) { in DoInsert()
199 s = txn->Prepare(); in DoInsert()
214 s = txn->Commit(); in DoInsert()
221 s = txn->Rollback(); in DoInsert()
259 if (txn != nullptr) { in DoInsert()
[all …]
/rocksdb-6.9/db_stress_tool/
Dno_batched_ops_stress.cc182 Transaction* txn = nullptr; in TestMultiGet() local
185 Status s = NewTxn(wo, &txn); in TestMultiGet()
240 RollbackTxn(txn); in TestMultiGet()
344 Transaction* txn; in TestPut() local
349 s = CommitTxn(txn); in TestPut()
359 Transaction* txn; in TestPut() local
364 s = CommitTxn(txn); in TestPut()
415 Transaction* txn; in TestDelete() local
420 s = CommitTxn(txn); in TestDelete()
437 Transaction* txn; in TestDelete() local
[all …]
/rocksdb-6.9/db/
Dc_test.c372 rocksdb_transaction_t* txn, in CheckTxnGet() argument
443 rocksdb_transaction_t* txn; in main() local
1569 CheckTxnGet(txn, roptions, "foo", NULL); in main()
1578 rocksdb_transaction_commit(txn, &err); in main()
1585 txn = rocksdb_transaction_begin(txn_db, woptions, txn_options, txn); in main()
1612 rocksdb_transaction_rollback(txn, &err); in main()
1618 rocksdb_transaction_set_savepoint(txn); in main()
1630 rocksdb_transaction_commit(txn, &err); in main()
1653 rocksdb_transaction_destroy(txn); in main()
1697 rocksdb_transaction_commit(txn, &err); in main()
[all …]
/rocksdb-6.9/utilities/
Denv_librados_test.cc1029 assert(txn); in TEST_F()
1048 s = txn->Commit(); in TEST_F()
1050 delete txn; in TEST_F()
1075 txn->Rollback(); in TEST_F()
1077 delete txn; in TEST_F()
1100 txn->Put("x", "x"); in TEST_F()
1106 txn->SetSnapshot(); in TEST_F()
1107 txn->SetSavePoint(); in TEST_F()
1114 txn->Put("y", "y"); in TEST_F()
1120 s = txn->Commit(); in TEST_F()
[all …]

12