Lines Matching refs:txn
36 MDB_txn *txn; member
46 MDB_txn *txn; in DBA_OPEN_FUNC() local
68 rc = mdb_txn_begin(env, NULL, 0, &txn); in DBA_OPEN_FUNC()
82 rc = mdb_dbi_open(txn, NULL, 0, &LMDB_IT(dbi)); in DBA_OPEN_FUNC()
91 LMDB_IT(txn) = txn; in DBA_OPEN_FUNC()
93 mdb_txn_abort(LMDB_IT(txn)); in DBA_OPEN_FUNC()
113 rc = mdb_txn_renew(LMDB_IT(txn)); in DBA_FETCH_FUNC()
115 rc = mdb_txn_begin(LMDB_IT(env), NULL, MDB_RDONLY, &LMDB_IT(txn)); in DBA_FETCH_FUNC()
125 rc = mdb_get(LMDB_IT(txn), LMDB_IT(dbi), &k, &v); in DBA_FETCH_FUNC()
130 mdb_txn_abort(LMDB_IT(txn)); in DBA_FETCH_FUNC()
140 mdb_txn_reset(LMDB_IT(txn)); in DBA_FETCH_FUNC()
142 mdb_txn_abort(LMDB_IT(txn)); in DBA_FETCH_FUNC()
153 rc = mdb_txn_begin(LMDB_IT(env), NULL, 0, &LMDB_IT(txn)); in DBA_UPDATE_FUNC()
164 rc = mdb_put(LMDB_IT(txn), LMDB_IT(dbi), &k, &v, mode == 1 ? MDB_NOOVERWRITE : 0); in DBA_UPDATE_FUNC()
169 mdb_txn_abort(LMDB_IT(txn)); in DBA_UPDATE_FUNC()
173 rc = mdb_txn_commit(LMDB_IT(txn)); in DBA_UPDATE_FUNC()
176 mdb_txn_abort(LMDB_IT(txn)); in DBA_UPDATE_FUNC()
189 rc = mdb_txn_renew(LMDB_IT(txn)); in DBA_EXISTS_FUNC()
191 rc = mdb_txn_begin(LMDB_IT(env), NULL, MDB_RDONLY, &LMDB_IT(txn)); in DBA_EXISTS_FUNC()
201 rc = mdb_get(LMDB_IT(txn), LMDB_IT(dbi), &k, &v); in DBA_EXISTS_FUNC()
206 mdb_txn_abort(LMDB_IT(txn)); in DBA_EXISTS_FUNC()
211 mdb_txn_reset(LMDB_IT(txn)); in DBA_EXISTS_FUNC()
213 mdb_txn_abort(LMDB_IT(txn)); in DBA_EXISTS_FUNC()
224 rc = mdb_txn_begin(LMDB_IT(env), NULL, 0, &LMDB_IT(txn)); in DBA_DELETE_FUNC()
233 rc = mdb_del(LMDB_IT(txn), LMDB_IT(dbi), &k, NULL); in DBA_DELETE_FUNC()
235 rc = mdb_txn_commit(LMDB_IT(txn)); in DBA_DELETE_FUNC()
238 mdb_txn_abort(LMDB_IT(txn)); in DBA_DELETE_FUNC()
255 rc = mdb_txn_begin(LMDB_IT(env), NULL, MDB_RDONLY, &LMDB_IT(txn)); in DBA_FIRSTKEY_FUNC()
261 rc = mdb_cursor_open(LMDB_IT(txn), LMDB_IT(dbi), &LMDB_IT(cur)); in DBA_FIRSTKEY_FUNC()
263 mdb_txn_abort(LMDB_IT(txn)); in DBA_FIRSTKEY_FUNC()
270 mdb_txn_abort(LMDB_IT(txn)); in DBA_FIRSTKEY_FUNC()
284 mdb_txn_reset(LMDB_IT(txn)); in DBA_FIRSTKEY_FUNC()
295 rc = mdb_txn_renew(LMDB_IT(txn)); in DBA_NEXTKEY_FUNC()
303 mdb_txn_abort(LMDB_IT(txn)); in DBA_NEXTKEY_FUNC()
317 mdb_txn_reset(LMDB_IT(txn)); in DBA_NEXTKEY_FUNC()
