Lines Matching defs:txn
32 MDB_txn *txn;
54 E(mdb_txn_begin(env, NULL, 0, &txn));
55 E(mdb_dbi_open(txn, NULL, 0, &dbi));
66 if (RES(MDB_KEYEXIST, mdb_put(txn, dbi, &key, &data, MDB_NOOVERWRITE))) {
73 E(mdb_txn_commit(txn));
76 E(mdb_txn_begin(env, NULL, MDB_RDONLY, &txn));
77 E(mdb_cursor_open(txn, dbi, &cursor));
85 mdb_txn_abort(txn);
91 txn=NULL;
92 E(mdb_txn_begin(env, NULL, 0, &txn));
94 if (RES(MDB_NOTFOUND, mdb_del(txn, dbi, &key, NULL))) {
96 mdb_txn_abort(txn);
98 E(mdb_txn_commit(txn));
105 E(mdb_txn_begin(env, NULL, MDB_RDONLY, &txn));
106 E(mdb_cursor_open(txn, dbi, &cursor));
137 mdb_txn_abort(txn);
140 E(mdb_txn_begin(env, NULL, 0, &txn));
141 E(mdb_cursor_open(txn, dbi, &cur2));
148 E(mdb_del(txn, dbi, &key, NULL));
151 printf("Restarting cursor in txn\n");
160 E(mdb_txn_commit(txn));
162 printf("Restarting cursor outside txn\n");
163 E(mdb_txn_begin(env, NULL, 0, &txn));
164 E(mdb_cursor_open(txn, dbi, &cursor));
173 mdb_txn_abort(txn);