Home
last modified time | relevance | path

Searched refs:txn2 (Results 1 – 8 of 8) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_test.cc576 delete txn2; in TEST_P()
670 delete txn2; in TEST_P()
730 delete txn2; in TEST_P()
811 delete txn2; in TEST_P()
835 delete txn2; in TEST_P()
861 delete txn2; in TEST_P()
880 delete txn2; in TEST_P()
897 delete txn2; in TEST_P()
915 delete txn2; in TEST_P()
929 delete txn2; in TEST_P()
[all …]
Dtransaction_test.cc351 delete txn2; in TEST_P()
475 delete txn2; in TEST_P()
1111 delete txn2; in TEST_P()
1213 delete txn2; in TEST_P()
1834 delete txn2; in TEST_P()
1972 delete txn2; in TEST_P()
2572 delete txn2; in TEST_P()
2671 delete txn2; in TEST_P()
2735 delete txn2; in TEST_P()
2994 delete txn2; in TEST_P()
[all …]
Dwrite_unprepared_transaction_test.cc503 Transaction* txn2 = db->BeginTransaction(write_options, txn_options); in TEST_P() local
504 ASSERT_OK(txn2->SetName("xid2")); in TEST_P()
510 ASSERT_OK(txn2->Put("k2" + ToString(i), "v" + ToString(i))); in TEST_P()
519 ASSERT_GT(txn2->GetLogNumber(), 0); in TEST_P()
527 ASSERT_OK(txn2->Prepare()); in TEST_P()
531 ASSERT_GE(db_impl->TEST_LogfileNumber(), txn2->GetLogNumber()); in TEST_P()
542 txn2->GetLogNumber()); in TEST_P()
545 ASSERT_OK(txn2->Commit()); in TEST_P()
547 ASSERT_OK(txn2->Rollback()); in TEST_P()
553 delete txn2; in TEST_P()
Dwrite_prepared_transaction_test.cc926 delete txn2; in TEST_P()
1876 s = txn2->Prepare(); in TEST_P()
1879 delete txn2; in TEST_P()
1905 ASSERT_NE(txn2, nullptr); in TEST_P()
1906 txn2->Commit(); in TEST_P()
1915 delete txn2; in TEST_P()
2493 delete txn2; in TEST_P()
2552 txn2 = in TEST_P()
2566 delete txn2; in TEST_P()
3279 Transaction* txn2 = in TEST_P() local
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DOptimisticTransactionTest.java40 txn2.put(testCf, k1, v12); in getForUpdate_cf_conflict()
42 txn2.commit(); in getForUpdate_cf_conflict()
77 txn2.put(k1, v12); in getForUpdate_conflict()
79 txn2.commit(); in getForUpdate_conflict()
126 txn2.commit(); in multiGetForUpdate_cf_conflict()
167 txn2.put(keys[0], otherValue); in multiGetForUpdate_conflict()
170 txn2.commit(); in multiGetForUpdate_conflict()
209 txn2.put(testCf, k1, v12); in undoGetForUpdate_cf_conflict()
211 txn2.commit(); in undoGetForUpdate_cf_conflict()
243 txn2.put(k1, v12); in undoGetForUpdate_conflict()
[all …]
DTransactionTest.java35 try(final Transaction txn2 = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict() argument
41 txn2.put(testCf, k1, v12); // should cause an exception! in getForUpdate_cf_conflict()
68 try(final Transaction txn2 = dbContainer.beginTransaction()) { in getForUpdate_conflict() argument
74 txn2.put(k1, v12); // should cause an exception! in getForUpdate_conflict()
109 try(final Transaction txn2 = dbContainer.beginTransaction()) { in multiGetForUpdate_cf_conflict() argument
116 txn2.put(testCf, keys[0], otherValue); // should cause an exception! in multiGetForUpdate_cf_conflict()
148 try(final Transaction txn2 = dbContainer.beginTransaction()) { in multiGetForUpdate_conflict() argument
155 txn2.put(keys[0], otherValue); // should cause an exception! in multiGetForUpdate_conflict()
DAbstractTransactionTest.java119 final Transaction txn2 = dbContainer.beginTransaction()) { in commit()
120 assertThat(txn2.get(readOptions, k1)).isEqualTo(v1); in commit()
136 final Transaction txn2 = dbContainer.beginTransaction()) { in rollback()
137 assertThat(txn2.get(readOptions, k1)).isNull(); in rollback()
173 try(final Transaction txn2 = dbContainer.beginTransaction()) { in savePoint() argument
174 assertThat(txn2.get(readOptions, k1)).isEqualTo(v1); in savePoint()
175 assertThat(txn2.get(readOptions, k2)).isNull(); in savePoint()
/rocksdb-6.9/db/
Dc_test.c1670 rocksdb_transaction_t* txn2 = rocksdb_optimistictransaction_begin( in main() local
1674 rocksdb_transaction_put(txn2, "key1", 4, "value1", 6, &err); in main()
1679 rocksdb_transaction_commit(txn2, &err); in main()
1682 rocksdb_transaction_destroy(txn2); in main()