Lines Matching full:txn
332 MDB_txn *txn = NULL; in fetch_lockout() local
338 err = mdb_txn_begin(dbc->lockout_env, NULL, MDB_RDONLY, &txn); in fetch_lockout()
340 err = mdb_get(txn, dbc->lockout_db, key, &val); in fetch_lockout()
343 mdb_txn_abort(txn); in fetch_lockout()
359 MDB_txn *temp_txn = NULL, *txn; in put() local
364 txn = dbc->load_txn; in put()
369 txn = temp_txn; in put()
372 if (must_overwrite && mdb_get(txn, db, &key, &dummy) == MDB_NOTFOUND) { in put()
377 err = mdb_put(txn, db, &key, &val, putflags); in put()
404 MDB_txn *txn = NULL; in del() local
408 err = mdb_txn_begin(env, NULL, 0, &txn); in del()
410 err = mdb_del(txn, db, &key, NULL); in del()
412 err = mdb_txn_commit(txn); in del()
413 txn = NULL; in del()
421 mdb_txn_abort(txn); in del()
508 MDB_txn *txn = NULL; in klmdb_open() local
532 err = mdb_txn_begin(dbc->env, NULL, MDB_RDONLY, &txn); in klmdb_open()
535 err = mdb_dbi_open(txn, "principal", 0, &dbc->princ_db); in klmdb_open()
538 err = mdb_dbi_open(txn, "policy", 0, &dbc->policy_db); in klmdb_open()
541 err = mdb_txn_commit(txn); in klmdb_open()
542 txn = NULL; in klmdb_open()
552 err = mdb_txn_begin(dbc->lockout_env, NULL, MDB_RDONLY, &txn); in klmdb_open()
555 err = mdb_dbi_open(txn, "lockout", 0, &dbc->lockout_db); in klmdb_open()
558 err = mdb_txn_commit(txn); in klmdb_open()
559 txn = NULL; in klmdb_open()
569 mdb_txn_abort(txn); in klmdb_open()
579 MDB_txn *txn = NULL; in klmdb_create() local
609 err = mdb_txn_begin(dbc->env, NULL, 0, &txn); in klmdb_create()
612 err = mdb_dbi_open(txn, "principal", MDB_CREATE, &dbc->princ_db); in klmdb_create()
615 err = mdb_dbi_open(txn, "policy", MDB_CREATE, &dbc->policy_db); in klmdb_create()
618 err = mdb_txn_commit(txn); in klmdb_create()
619 txn = NULL; in klmdb_create()
624 err = mdb_txn_begin(dbc->lockout_env, NULL, 0, &txn); in klmdb_create()
627 err = mdb_dbi_open(txn, "lockout", MDB_CREATE, &dbc->lockout_db); in klmdb_create()
630 err = mdb_txn_commit(txn); in klmdb_create()
631 txn = NULL; in klmdb_create()
661 mdb_txn_abort(txn); in klmdb_create()
753 MDB_txn *txn = NULL; in klmdb_put_principal() local
794 err = mdb_txn_begin(dbc->lockout_env, NULL, 0, &txn); in klmdb_put_principal()
797 if (mdb_get(txn, dbc->lockout_db, &key, &dummy) == 0) in klmdb_put_principal()
801 err = mdb_put(txn, dbc->lockout_db, &key, &val, 0); in klmdb_put_principal()
803 err = mdb_txn_commit(txn); in klmdb_put_principal()
804 txn = NULL; in klmdb_put_principal()
813 mdb_txn_abort(txn); in klmdb_put_principal()
848 MDB_txn *txn = NULL; in klmdb_iterate() local
857 err = mdb_txn_begin(dbc->env, NULL, MDB_RDONLY, &txn); in klmdb_iterate()
860 err = mdb_cursor_open(txn, dbc->princ_db, &cursor); in klmdb_iterate()
886 mdb_txn_abort(txn); in klmdb_iterate()
955 MDB_txn *txn = NULL; in klmdb_iter_policy() local
963 err = mdb_txn_begin(dbc->env, NULL, MDB_RDONLY, &txn); in klmdb_iter_policy()
966 err = mdb_cursor_open(txn, dbc->policy_db, &cursor); in klmdb_iter_policy()
989 mdb_txn_abort(txn); in klmdb_iter_policy()
1063 MDB_txn *txn = NULL; in klmdb_update_lockout() local
1081 err = mdb_txn_begin(dbc->lockout_env, NULL, 0, &txn); in klmdb_update_lockout()
1084 /* Fetch base lockout info within txn so we update transactionally. */ in klmdb_update_lockout()
1085 err = mdb_get(txn, dbc->lockout_db, &key, &val); in klmdb_update_lockout()
1106 err = mdb_put(txn, dbc->lockout_db, &key, &val, 0); in klmdb_update_lockout()
1109 err = mdb_txn_commit(txn); in klmdb_update_lockout()
1110 txn = NULL; in klmdb_update_lockout()
1119 mdb_txn_abort(txn); in klmdb_update_lockout()