Lines Matching refs:txn
17 #include "dbinc/txn.h"
75 __bam_compact(dbp, ip, txn, start, stop, c_data, flags, end)
78 DB_TXN *txn;
121 if (IS_DB_AUTO_COMMIT(dbp, txn))
132 if (txn_local && (ret = __txn_begin(env, ip, NULL, &txn, 0)) != 0)
136 txn, flags, c_data, &list, &nelems, &last_pgno)) != 0) {
153 /* Commit the txn and release the meta page lock. */
155 if ((t_ret = __txn_commit(txn, DB_TXN_NOSYNC)) != 0 && ret == 0)
157 txn = NULL;
195 if ((ret = __txn_begin(env, ip, NULL, &txn, 0)) != 0)
199 (ret = __txn_set_timeout(txn,
204 if ((ret = __db_cursor(dbp, ip, txn, &dbc, 0)) != 0)
223 err: if (txn_local && txn != NULL) {
225 ret = __txn_commit(txn, DB_TXN_NOSYNC);
226 else if ((t_ret = __txn_abort(txn)) != 0 && ret == 0)
228 txn = NULL;
254 __memp_fget(dbp->mpf, &pgno, ip, txn, 0, &meta)) == 0) {
260 ret = __bam_truncate_internal(dbp, ip, txn, c_data);
267 __memp_fget(dbp->mpf, &pgno, ip, txn, 0, &meta)) == 0) {
277 __bam_free_freelist(dbp, ip, txn)) != 0 && ret == 0)
414 dbc, (dbc)->txn, location, &__trace, start, f) \
486 if ((ret = __db_ret(dbp, dbc->thread_info, dbc->txn, pg,
528 dbc->thread_info, dbc->txn, 0, &pg)) != 0)
551 (ret = __db_ret(dbp, dbc->thread_info, dbc->txn, pg,
673 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
685 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
762 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
829 dbc->thread_info, dbc->txn, DB_MPOOL_DIRTY, &npg)) != 0)
834 dbc->thread_info, dbc->txn, 0, &ppg)) != 0)
913 dbc->thread_info, dbc->txn, 0, &pg)) != 0)
929 if (dbc->txn != NULL && ret != 0)
1213 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0 ||
1215 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
1340 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0 ||
1342 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
1356 dbc->txn, &LSN(pg), 0, PGNO(pg),
1415 dbc->thread_info, dbc->txn, 0, &npg)) != 0)
1501 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0 ||
1503 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
1710 dbc->thread_info, dbc->txn, 0, &npg)) != 0)
1786 dbc->txn, dbc->priority, 0)) != 0)
1809 dbc->thread_info, dbc->txn, 0, &dpg)) != 0)
1826 dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
1908 &newpage, dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
1923 if ((ret = __bam_merge_log(dbp, dbc->txn,
1938 pgp, dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
1982 &epg->page, dbc->thread_info, dbc->txn, dbc->priority, 0)) != 0)
1997 if ((ret = __bam_pgno_log(dbp, dbc->txn, &LSN(epg->page),
2037 dbc->thread_info, dbc->txn, 0, &page)) != 0)
2045 dbc->thread_info, dbc->txn, 0, &page)) != 0)
2108 dbc->thread_info, dbc->txn, 0, &page)) != 0)
2120 if ((ret = __db_goff(dbp, dbc->thread_info, dbc->txn, &orig,
2139 dbc->txn, &LSN(pg), 0, PGNO(pg),
2217 if ((ret = __bam_cmp(dbc->dbp, dbc->thread_info, dbc->txn,
2288 dbc->thread_info, dbc->txn, 0, &pg)) != 0)
2314 ret = __db_goff(dbp, dbc->thread_info, dbc->txn, start,
2334 __bam_truncate_internal(dbp, ip, txn, c_data)
2337 DB_TXN *txn;
2351 if (IS_DB_AUTO_COMMIT(dbp, txn)) {
2353 txn = NULL;
2362 (ret = __txn_begin(dbp->env, ip, NULL, &txn, 0)) != 0)
2365 if ((ret = __db_cursor(dbp, ip, txn, &dbc, 0)) != 0)
2426 if ((ret = __txn_commit(txn, DB_TXN_NOSYNC)) != 0)
2428 txn = NULL;
2433 err: if (txn != NULL && ret != 0)
2442 txn != NULL && (t_ret = __txn_abort(txn)) != 0 && ret == 0)
2471 __bam_free_freelist(dbp, ip, txn)
2474 DB_TXN *txn;
2490 if (IS_DB_AUTO_COMMIT(dbp, txn)) {
2497 if (__txn_begin(dbp->env, ip, NULL, &txn, 0) == 0) {
2499 txn->locker, 0, DB_SET_TXN_TIMEOUT);
2501 txn->locker, 0, DB_SET_LOCK_TIMEOUT);
2505 if ((ret = __db_cursor(dbp, ip, txn, &dbc, 0)) != 0)
2521 if (auto_commit && __txn_abort(txn) != 0 && ret == 0)