Lines Matching refs:txn_db

400         rocksdb_transactiondb_t* txn_db,  in CheckTxnDBGet()  argument
407 val = rocksdb_transactiondb_get(txn_db, options, key, strlen(key), &val_len, &err); in CheckTxnDBGet()
413 static void CheckTxnDBGetCF(rocksdb_transactiondb_t* txn_db, in CheckTxnDBGetCF() argument
420 val = rocksdb_transactiondb_get_cf(txn_db, options, column_family, key, in CheckTxnDBGetCF()
441 rocksdb_transactiondb_t* txn_db; in main() local
1535 txn_db = rocksdb_transactiondb_open(options, txn_db_options, dbname, &err); in main()
1539 rocksdb_transactiondb_put(txn_db, woptions, "foo", 3, "hello", 5, &err); in main()
1541 CheckTxnDBGet(txn_db, roptions, "foo", "hello"); in main()
1544 rocksdb_transactiondb_delete(txn_db, woptions, "foo", 3, &err); in main()
1546 CheckTxnDBGet(txn_db, roptions, "foo", NULL); in main()
1555 rocksdb_transactiondb_write(txn_db, woptions, wb, &err); in main()
1557 CheckTxnDBGet(txn_db, roptions, "box", "c"); in main()
1561 txn = rocksdb_transaction_begin(txn_db, woptions, txn_options, NULL); in main()
1575 CheckTxnDBGet(txn_db, roptions, "foo", NULL); in main()
1582 CheckTxnDBGet(txn_db, roptions, "foo", "hello"); in main()
1585 txn = rocksdb_transaction_begin(txn_db, woptions, txn_options, txn); in main()
1589 snapshot = rocksdb_transactiondb_create_snapshot(txn_db); in main()
1592 rocksdb_transactiondb_put(txn_db, woptions, "foo", 3, "hey", 3, &err); in main()
1595 CheckTxnDBGet(txn_db, roptions, "foo", "hello"); in main()
1597 rocksdb_transactiondb_release_snapshot(txn_db, snapshot); in main()
1598 CheckTxnDBGet(txn_db, roptions, "foo", "hey"); in main()
1614 CheckTxnDBGet(txn_db, roptions, "bar", NULL); in main()
1628 CheckTxnDBGet(txn_db, roptions, "foo1", NULL); in main()
1629 CheckTxnDBGet(txn_db, roptions, "foo2", NULL); in main()
1632 CheckTxnDBGet(txn_db, roptions, "foo1", "hi1"); in main()
1633 CheckTxnDBGet(txn_db, roptions, "foo2", NULL); in main()
1637 cfh = rocksdb_transactiondb_create_column_family(txn_db, options, in main()
1641 rocksdb_transactiondb_put_cf(txn_db, woptions, cfh, "cf_foo", 6, "cf_hello", in main()
1644 CheckTxnDBGetCF(txn_db, roptions, cfh, "cf_foo", "cf_hello"); in main()
1646 rocksdb_transactiondb_delete_cf(txn_db, woptions, cfh, "cf_foo", 6, &err); in main()
1648 CheckTxnDBGetCF(txn_db, roptions, cfh, "cf_foo", NULL); in main()
1654 rocksdb_transactiondb_close(txn_db); in main()