#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/lock.h"
#include "dbinc/txn.h"
#include "dbinc/db_am.h"
int
__txn_regop_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
DB_TXNHEAD *headp;
__txn_regop_args *argp;
int ret;
u_int32_t status;
#ifdef DEBUG_RECOVER
(void)__txn_regop_print(dbenv, dbtp, lsnp, op, info);
#endif
if ((ret = __txn_regop_read(dbenv, dbtp->data, &argp)) != 0)
return (ret);
headp = info;
if (op == DB_TXN_FORWARD_ROLL) {
if ((ret = __db_txnlist_remove(dbenv,
info, argp->txnp->txnid)) != DB_NOTFOUND && ret != 0)
goto err;
} else if ((dbenv->tx_timestamp != 0 &&
argp->timestamp > (int32_t)dbenv->tx_timestamp) ||
(!IS_ZERO_LSN(headp->trunc_lsn) &&
LOG_COMPARE(&headp->trunc_lsn, lsnp) < 0)) {
if ((ret = __db_txnlist_update(dbenv, info,
argp->txnp->txnid, TXN_ABORT, NULL, &status, 1)) != 0)
goto err;
else if (status != TXN_IGNORE && status != TXN_OK)
goto err;
} else {
if ((ret = __db_txnlist_update(dbenv,
info, argp->txnp->txnid, argp->opcode, lsnp,
&status, 0)) == DB_NOTFOUND) {
if ((ret = __db_txnlist_add(dbenv,
info, argp->txnp->txnid,
argp->opcode == TXN_ABORT ?
TXN_IGNORE : argp->opcode, lsnp)) != 0)
goto err;
} else if (ret != 0 ||
(status != TXN_IGNORE && status != TXN_OK))
goto err;
}
if (ret == 0)
*lsnp = argp->prev_lsn;
if (0) {
err: __db_errx(dbenv,
"txnid %lx commit record found, already on commit list",
(u_long)argp->txnp->txnid);
ret = EINVAL;
}
__os_free(dbenv, argp);
return (ret);
}
int
__txn_xa_regop_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
DBT *lock_dbt;
DB_TXNHEAD *headp;
DB_LOCKTAB *lt;
__txn_xa_regop_args *argp;
int ret;
u_int32_t status;
#ifdef DEBUG_RECOVER
(void)__txn_xa_regop_print(dbenv, dbtp, lsnp, op, info);
#endif
if ((ret = __txn_xa_regop_read(dbenv, dbtp->data, &argp)) != 0)
return (ret);
if (argp->opcode != TXN_PREPARE && argp->opcode != TXN_ABORT) {
ret = EINVAL;
goto err;
}
headp = info;
ret = __db_txnlist_find(dbenv, info, argp->txnp->txnid, &status);
if (op == DB_TXN_FORWARD_ROLL) {
if ((ret = __db_txnlist_remove(dbenv,
info, argp->txnp->txnid)) != 0)
goto txn_err;
} else if (op == DB_TXN_BACKWARD_ROLL && status == TXN_PREPARE) {
if (argp->opcode == TXN_ABORT) {
if ((ret = __db_txnlist_update(dbenv,
info, argp->txnp->txnid,
TXN_ABORT, NULL, &status, 0)) != 0 &&
status != TXN_PREPARE)
goto txn_err;
ret = 0;
}
else if ((ret = __db_txnlist_remove(dbenv,
info, argp->txnp->txnid)) != 0) {
txn_err: __db_errx(dbenv,
"transaction not in list %lx",
(u_long)argp->txnp->txnid);
ret = DB_NOTFOUND;
} else if (IS_ZERO_LSN(headp->trunc_lsn) ||
LOG_COMPARE(&headp->trunc_lsn, lsnp) >= 0) {
if ((ret = __db_txnlist_add(dbenv,
info, argp->txnp->txnid, TXN_COMMIT, lsnp)) == 0) {
lock_dbt = &argp->locks;
if (LOCKING_ON(dbenv)) {
lt = dbenv->lk_handle;
if ((ret = __lock_getlocker(lt,
argp->txnp->txnid, 1,
&argp->txnp->locker)) != 0)
goto err;
if ((ret = __lock_get_list(dbenv,
argp->txnp->locker, 0,
DB_LOCK_WRITE, lock_dbt)) != 0)
goto err;
}
ret = __txn_restore_txn(dbenv, lsnp, argp);
}
}
} else
ret = 0;
if (ret == 0)
*lsnp = argp->prev_lsn;
err: __os_free(dbenv, argp);
return (ret);
}
int
__txn_ckp_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__txn_ckp_args *argp;
int ret;
#ifdef DEBUG_RECOVER
__txn_ckp_print(dbenv, dbtp, lsnp, op, info);
#endif
if ((ret = __txn_ckp_read(dbenv, dbtp->data, &argp)) != 0)
return (ret);
if (op == DB_TXN_BACKWARD_ROLL)
__db_txnlist_ckp(dbenv, info, lsnp);
*lsnp = argp->last_ckp;
__os_free(dbenv, argp);
return (DB_TXN_CKP);
}
int
__txn_child_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__txn_child_args *argp;
int ret, t_ret;
u_int32_t c_stat, p_stat, tmpstat;
#ifdef DEBUG_RECOVER
(void)__txn_child_print(dbenv, dbtp, lsnp, op, info);
#endif
if ((ret = __txn_child_read(dbenv, dbtp->data, &argp)) != 0)
return (ret);
if (op == DB_TXN_ABORT) {
*lsnp = argp->c_lsn;
ret = __db_txnlist_lsnadd(dbenv, info, &argp->prev_lsn);
goto out;
} else if (op == DB_TXN_BACKWARD_ROLL) {
ret = __db_txnlist_find(dbenv, info, argp->child, &c_stat);
t_ret =
__db_txnlist_find(dbenv, info, argp->txnp->txnid, &p_stat);
if (ret != 0 && ret != DB_NOTFOUND)
goto out;
if (t_ret != 0 && t_ret != DB_NOTFOUND) {
ret = t_ret;
goto out;
}
if (ret == DB_NOTFOUND ||
c_stat == TXN_OK || c_stat == TXN_COMMIT) {
if (t_ret == DB_NOTFOUND ||
(p_stat != TXN_COMMIT && p_stat != TXN_IGNORE))
c_stat = TXN_ABORT;
else
c_stat = p_stat;
if (ret == DB_NOTFOUND)
ret = __db_txnlist_add(dbenv,
info, argp->child, c_stat, NULL);
else
ret = __db_txnlist_update(dbenv, info,
argp->child, c_stat, NULL, &tmpstat, 0);
} else if (c_stat == TXN_EXPECTED) {
switch (p_stat) {
case TXN_COMMIT:
case TXN_IGNORE:
c_stat = TXN_IGNORE;
break;
default:
c_stat = TXN_ABORT;
}
ret = __db_txnlist_update(dbenv,
info, argp->child, c_stat, NULL, &tmpstat, 0);
} else if (c_stat == TXN_UNEXPECTED) {
ret = __db_txnlist_update(dbenv, info, argp->child,
p_stat == TXN_COMMIT ? TXN_COMMIT : TXN_IGNORE,
NULL, &tmpstat, 0);
}
} else if (op == DB_TXN_OPENFILES) {
if ((ret = __db_txnlist_find(dbenv,
info, argp->child, &c_stat)) == DB_NOTFOUND)
ret = __db_txnlist_update(dbenv, info,
argp->txnp->txnid, TXN_IGNORE,
NULL, &p_stat, 1);
} else if (DB_REDO(op)) {
if ((ret =
__db_txnlist_remove(dbenv, info, argp->child)) != 0)
__db_errx(dbenv,
"Transaction not in list %x", argp->child);
}
if (ret == 0)
*lsnp = argp->prev_lsn;
out: __os_free(dbenv, argp);
return (ret);
}
int
__txn_restore_txn(dbenv, lsnp, argp)
DB_ENV *dbenv;
DB_LSN *lsnp;
__txn_xa_regop_args *argp;
{
DB_TXNMGR *mgr;
TXN_DETAIL *td;
DB_TXNREGION *region;
int ret;
if (argp->xid.size == 0)
return (0);
mgr = dbenv->tx_handle;
region = mgr->reginfo.primary;
TXN_SYSTEM_LOCK(dbenv);
if ((ret = __env_alloc(&mgr->reginfo, sizeof(TXN_DETAIL), &td)) != 0) {
TXN_SYSTEM_UNLOCK(dbenv);
return (ret);
}
SH_TAILQ_INSERT_HEAD(®ion->active_txn, td, links, __txn_detail);
td->txnid = argp->txnp->txnid;
__os_id(dbenv, &td->pid, &td->tid);
td->last_lsn = *lsnp;
td->begin_lsn = argp->begin_lsn;
td->parent = INVALID_ROFF;
td->name = INVALID_ROFF;
SH_TAILQ_INIT(&td->kids);
MAX_LSN(td->read_lsn);
MAX_LSN(td->visible_lsn);
td->mvcc_ref = 0;
td->mvcc_mtx = MUTEX_INVALID;
td->status = TXN_PREPARED;
td->flags = TXN_DTL_RESTORED;
td->xa_status = TXN_XA_PREPARED;
memcpy(td->xid, argp->xid.data, argp->xid.size);
td->bqual = argp->bqual;
td->gtrid = argp->gtrid;
td->format = argp->formatID;
td->nlog_dbs = 0;
td->nlog_slots = TXN_NSLOTS;
td->log_dbs = R_OFFSET(&mgr->reginfo, td->slots);
region->stat.st_nrestores++;
#ifdef HAVE_STATISTICS
region->stat.st_nactive++;
if (region->stat.st_nactive > region->stat.st_maxnactive)
region->stat.st_maxnactive = region->stat.st_nactive;
#endif
TXN_SYSTEM_UNLOCK(dbenv);
return (0);
}
int
__txn_recycle_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__txn_recycle_args *argp;
int ret;
#ifdef DEBUG_RECOVER
(void)__txn_child_print(dbenv, dbtp, lsnp, op, info);
#endif
if ((ret = __txn_recycle_read(dbenv, dbtp->data, &argp)) != 0)
return (ret);
COMPQUIET(lsnp, NULL);
if ((ret = __db_txnlist_gen(dbenv, info,
DB_UNDO(op) ? -1 : 1, argp->min, argp->max)) != 0)
return (ret);
__os_free(dbenv, argp);
return (0);
}
int
__txn_regop_42_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
DB_TXNHEAD *headp;
__txn_regop_42_args *argp;
int ret;
u_int32_t status;
#ifdef DEBUG_RECOVER
(void)__txn_regop_42_print(dbenv, dbtp, lsnp, op, info);
#endif
if ((ret = __txn_regop_42_read(dbenv, dbtp->data, &argp)) != 0)
return (ret);
headp = info;
if (op == DB_TXN_FORWARD_ROLL) {
if ((ret = __db_txnlist_remove(dbenv,
info, argp->txnp->txnid)) != DB_NOTFOUND && ret != 0)
goto err;
} else if ((dbenv->tx_timestamp != 0 &&
argp->timestamp > (int32_t)dbenv->tx_timestamp) ||
(!IS_ZERO_LSN(headp->trunc_lsn) &&
LOG_COMPARE(&headp->trunc_lsn, lsnp) < 0)) {
if ((ret = __db_txnlist_update(dbenv, info,
argp->txnp->txnid, TXN_ABORT, NULL, &status, 1)) != 0)
goto err;
else if (status != TXN_IGNORE && status != TXN_OK)
goto err;
} else {
if ((ret = __db_txnlist_update(dbenv,
info, argp->txnp->txnid, argp->opcode, lsnp,
&status, 0)) == DB_NOTFOUND) {
if ((ret = __db_txnlist_add(dbenv,
info, argp->txnp->txnid,
argp->opcode == TXN_ABORT ?
TXN_IGNORE : argp->opcode, lsnp)) != 0)
goto err;
} else if (ret != 0 ||
(status != TXN_IGNORE && status != TXN_OK))
goto err;
}
if (ret == 0)
*lsnp = argp->prev_lsn;
if (0) {
err: __db_errx(dbenv,
"txnid %lx commit record found, already on commit list",
(u_long)argp->txnp->txnid);
ret = EINVAL;
}
__os_free(dbenv, argp);
return (ret);
}
int
__txn_ckp_42_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__txn_ckp_42_args *argp;
int ret;
#ifdef DEBUG_RECOVER
__txn_ckp_42_print(dbenv, dbtp, lsnp, op, info);
#endif
if ((ret = __txn_ckp_42_read(dbenv, dbtp->data, &argp)) != 0)
return (ret);
if (op == DB_TXN_BACKWARD_ROLL)
__db_txnlist_ckp(dbenv, info, lsnp);
*lsnp = argp->last_ckp;
__os_free(dbenv, argp);
return (DB_TXN_CKP);
}