Searched refs:txn3 (Results 1 – 5 of 5) sorted by relevance
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | OptimisticTransactionTest.java | 36 try(final Transaction txn3 = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict() argument
45 txn3.commit(); // should cause an exception! in getForUpdate_cf_conflict()
73 try(final Transaction txn3 = dbContainer.beginTransaction()) { in getForUpdate_conflict() argument
82 txn3.commit(); // should cause an exception! in getForUpdate_conflict()
129 txn3.commit(); // should cause an exception! in multiGetForUpdate_cf_conflict()
163 assertThat(txn3.multiGetForUpdate(readOptions, keys)) in multiGetForUpdate_conflict()
173 txn3.commit(); // should cause an exception! in multiGetForUpdate_conflict()
206 txn3.undoGetForUpdate(testCf, k1); in undoGetForUpdate_cf_conflict()
215 txn3.commit(); in undoGetForUpdate_cf_conflict()
240 txn3.undoGetForUpdate(k1); in undoGetForUpdate_conflict()
[all …]
|
| D | TransactionTest.java | 36 try(final Transaction txn3 = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict() argument
37 assertThat(txn3.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in getForUpdate_cf_conflict()
69 try(final Transaction txn3 = dbContainer.beginTransaction()) { in getForUpdate_conflict() argument
70 assertThat(txn3.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate_conflict()
110 try(final Transaction txn3 = dbContainer.beginTransaction()) { in multiGetForUpdate_cf_conflict() argument
111 assertThat(txn3.multiGetForUpdate(readOptions, cfList, keys)) in multiGetForUpdate_cf_conflict()
149 try(final Transaction txn3 = dbContainer.beginTransaction()) { in multiGetForUpdate_conflict() argument
150 assertThat(txn3.multiGetForUpdate(readOptions, keys)) in multiGetForUpdate_conflict()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | optimistic_transaction_test.cc | 403 Transaction* txn3 = txn_db->BeginTransaction(write_options); in TEST_P() local
404 ASSERT_TRUE(txn3 != nullptr); in TEST_P()
424 txn3->Put(Slice("foo2"), Slice("bar2")); in TEST_P()
426 s = txn3->Commit(); in TEST_P()
439 delete txn3; in TEST_P()
|
| D | transaction_test.cc | 366 Transaction* txn3 = db->BeginTransaction(write_options, txn_options); in TEST_P() local
369 ASSERT_TRUE(txn3); in TEST_P()
391 txn3->GetID()}; in TEST_P()
398 txn3->Rollback(); in TEST_P()
407 s = txn3->GetForUpdate(read_options, "foo", nullptr); in TEST_P()
412 s = txn3->GetForUpdate(read_options, "foo", nullptr); in TEST_P()
417 s = txn3->GetForUpdate(read_options, "foo", nullptr); in TEST_P()
422 txn3->Rollback(); in TEST_P()
476 delete txn3; in TEST_P()
1063 ASSERT_TRUE(txn3); in TEST_P()
[all …]
|
| D | write_prepared_transaction_test.cc | 863 Transaction* txn3 = db->BeginTransaction(write_options, txn_options); in TEST_P() local
864 ASSERT_TRUE(txn3 != nullptr); in TEST_P()
865 ASSERT_OK(txn3->SetName("txn3")); in TEST_P()
874 ASSERT_TRUE(txn3->GetForUpdate(read_options, "foo", &value).IsBusy()); in TEST_P()
927 delete txn3; in TEST_P()
|