Lines Matching refs:txn

372         rocksdb_transaction_t* txn,  in CheckTxnGet()  argument
379 val = rocksdb_transaction_get(txn, options, key, strlen(key), &val_len, &err); in CheckTxnGet()
385 static void CheckTxnGetCF(rocksdb_transaction_t* txn, in CheckTxnGetCF() argument
392 val = rocksdb_transaction_get_cf(txn, options, column_family, key, in CheckTxnGetCF()
443 rocksdb_transaction_t* txn; in main() local
1561 txn = rocksdb_transaction_begin(txn_db, woptions, txn_options, NULL); in main()
1563 rocksdb_transaction_put(txn, "foo", 3, "hello", 5, &err); in main()
1565 CheckTxnGet(txn, roptions, "foo", "hello"); in main()
1567 rocksdb_transaction_delete(txn, "foo", 3, &err); in main()
1569 CheckTxnGet(txn, roptions, "foo", NULL); in main()
1571 rocksdb_transaction_put(txn, "foo", 3, "hello", 5, &err); in main()
1578 rocksdb_transaction_commit(txn, &err); in main()
1585 txn = rocksdb_transaction_begin(txn_db, woptions, txn_options, txn); in main()
1601 rocksdb_transaction_put(txn, "bar", 3, "hi", 2, &err); in main()
1602 rocksdb_iterator_t* iter = rocksdb_transaction_create_iterator(txn, roptions); in main()
1612 rocksdb_transaction_rollback(txn, &err); in main()
1617 rocksdb_transaction_put(txn, "foo1", 4, "hi1", 3, &err); in main()
1618 rocksdb_transaction_set_savepoint(txn); in main()
1619 CheckTxnGet(txn, roptions, "foo1", "hi1"); in main()
1620 rocksdb_transaction_put(txn, "foo2", 4, "hi2", 3, &err); in main()
1621 CheckTxnGet(txn, roptions, "foo2", "hi2"); in main()
1624 rocksdb_transaction_rollback_to_savepoint(txn, &err); in main()
1626 CheckTxnGet(txn, roptions, "foo2", NULL); in main()
1627 CheckTxnGet(txn, roptions, "foo1", "hi1"); in main()
1630 rocksdb_transaction_commit(txn, &err); in main()
1653 rocksdb_transaction_destroy(txn); in main()
1691 txn = rocksdb_optimistictransaction_begin(otxn_db, woptions, otxn_options, in main()
1693 rocksdb_transaction_put_cf(txn, cfh1, "key_cf1", 7, "val_cf1", 7, &err); in main()
1695 rocksdb_transaction_put_cf(txn, cfh2, "key_cf2", 7, "val_cf2", 7, &err); in main()
1697 rocksdb_transaction_commit(txn, &err); in main()
1699 txn = rocksdb_optimistictransaction_begin(otxn_db, woptions, otxn_options, in main()
1700 txn); in main()
1702 CheckTxnGetCF(txn, roptions, cfh1, "key_cf1", "val_cf1"); in main()
1705 rocksdb_transaction_put_cf(txn, cfh1, "key1_cf", 7, "val1_cf", 7, &err); in main()
1708 rocksdb_transaction_create_iterator_cf(txn, roptions, cfh1); in main()
1717 rocksdb_transaction_destroy(txn); in main()