Lines Matching defs:txnp
73 __xa_get_txn(env, txnp, do_init)
75 DB_TXN **txnp;
91 *txnp = NULL;
108 *txnp = t;
113 *txnp = t;
120 if (*txnp == NULL) {
124 __os_malloc(env, sizeof(DB_TXN), txnp)) == 0) {
125 (*txnp)->tid = tid;
127 TAILQ_INSERT_HEAD(&env->xa_txn, *txnp, xalinks);
134 *txnp = TAILQ_FIRST(&env->xa_txn);
135 if (*txnp == NULL &&
136 (ret = __os_calloc(env, 1, sizeof(DB_TXN), txnp)) == 0) {
137 (*txnp)->txnid = TXN_INVALID;
138 TAILQ_INSERT_HEAD(&env->xa_txn, *txnp, xalinks);
146 __xa_put_txn(env, txnp)
148 DB_TXN *txnp;
155 TAILQ_REMOVE(&env->xa_txn, txnp, xalinks);
157 __os_free(env, txnp);
160 txnp->txnid = TXN_INVALID;
343 DB_TXN *txnp;
389 if (__xa_get_txn(env, &txnp, 1) != 0)
391 if (__xa_txn_continue(env, txnp, td) != 0)
395 if (__xa_get_txn(env, &txnp, 1) != 0)
397 if (__txn_xa_begin(env, txnp))
399 (void)__db_map_xid(env, xid, txnp->td);
400 td = txnp->td;
473 DB_TXN *txnp;
505 if (__xa_get_txn(env, &txnp, 0) != 0)
507 if (__xa_txn_continue(env, txnp, td) != 0)
510 if (txnp->prepare(txnp, (u_int8_t *)xid->data) != 0)
519 (void)__xa_put_txn(env, txnp);
533 DB_TXN *txnp;
573 if (__xa_get_txn(env, &txnp, 0) != 0)
575 if (__xa_txn_continue(env, txnp, td) != 0)
578 if (txnp->commit(txnp, 0) != 0)
585 (void)__xa_put_txn(env, txnp);
636 DB_TXN *txnp;
668 if (__xa_get_txn(env, &txnp, 0) != 0)
670 if (__xa_txn_continue(env, txnp, td) != 0)
672 if (txnp->abort(txnp) != 0)
679 (void)__xa_put_txn(env, txnp);