#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: txn_rec.c,v 1.2 2004/03/30 01:24:47 jtownsen Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <string.h>
#endif
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/txn.h"
#include "dbinc/db_am.h"
#define IS_XA_TXN(R) (R->xid.size != 0)
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;
#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)
(void)__db_txnlist_remove(dbenv, info, argp->txnid->txnid);
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)) {
ret = __db_txnlist_update(dbenv,
info, argp->txnid->txnid, TXN_ABORT, NULL);
if (ret == TXN_IGNORE)
ret = TXN_OK;
else if (ret == TXN_NOTFOUND)
ret = __db_txnlist_add(dbenv,
info, argp->txnid->txnid, TXN_IGNORE, NULL);
else if (ret != TXN_OK)
goto err;
} else {
ret = __db_txnlist_update(dbenv,
info, argp->txnid->txnid, argp->opcode, lsnp);
if (ret == TXN_IGNORE)
ret = TXN_OK;
else if (ret == TXN_NOTFOUND)
ret = __db_txnlist_add(dbenv,
info, argp->txnid->txnid,
argp->opcode == TXN_ABORT ?
TXN_IGNORE : argp->opcode, lsnp);
else if (ret != TXN_OK)
goto err;
}
if (ret == 0)
*lsnp = argp->prev_lsn;
if (0) {
err: __db_err(dbenv,
"txnid %lx commit record found, already on commit list",
(u_long)argp->txnid->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;
{
__txn_xa_regop_args *argp;
int ret;
#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;
}
ret = __db_txnlist_find(dbenv, info, argp->txnid->txnid);
if (op == DB_TXN_FORWARD_ROLL) {
if ((ret = __db_txnlist_remove(dbenv,
info, argp->txnid->txnid)) != TXN_OK)
goto txn_err;
} else if (op == DB_TXN_BACKWARD_ROLL && ret == TXN_PREPARE) {
if (argp->opcode == TXN_ABORT) {
if ((ret = __db_txnlist_update(dbenv,
info, argp->txnid->txnid,
TXN_ABORT, NULL)) != TXN_PREPARE)
goto txn_err;
ret = 0;
}
else if ((ret = __db_txnlist_remove(dbenv,
info, argp->txnid->txnid)) != TXN_OK) {
txn_err: __db_err(dbenv,
"Transaction not in list %x", argp->txnid->txnid);
ret = DB_NOTFOUND;
} else if ((ret = __db_txnlist_add(dbenv,
info, argp->txnid->txnid, TXN_COMMIT, lsnp)) == 0)
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;
{
DB_REP *db_rep;
REP *rep;
__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);
if (op == DB_TXN_FORWARD_ROLL) {
if (REP_ON(dbenv)) {
db_rep = dbenv->rep_handle;
rep = db_rep->region;
if (argp->rep_gen > rep->recover_gen)
rep->recover_gen = argp->rep_gen;
}
}
*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 c_stat, p_stat, ret;
#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) {
ret = __db_txnlist_lsnadd(dbenv,
info, &argp->c_lsn, TXNLIST_NEW);
} else if (op == DB_TXN_BACKWARD_ROLL) {
c_stat = __db_txnlist_find(dbenv, info, argp->child);
p_stat = __db_txnlist_find(dbenv, info, argp->txnid->txnid);
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);
if (ret > 0)
ret = 0;
} else if (c_stat == TXN_UNEXPECTED) {
ret = __db_txnlist_update(dbenv, info, argp->child,
p_stat == TXN_COMMIT ? TXN_COMMIT : TXN_IGNORE,
NULL);
if (ret > 0)
ret = 0;
} else if (c_stat != TXN_IGNORE) {
switch (p_stat) {
case TXN_COMMIT:
c_stat = TXN_COMMIT;
break;
case TXN_IGNORE:
c_stat = TXN_IGNORE;
break;
default:
c_stat = TXN_ABORT;
}
ret = __db_txnlist_add(dbenv,
info, argp->child, c_stat, NULL);
}
} else if (op == DB_TXN_OPENFILES) {
c_stat = __db_txnlist_find(dbenv, info, argp->child);
if (c_stat == TXN_NOTFOUND) {
p_stat =
__db_txnlist_find(dbenv, info, argp->txnid->txnid);
if (p_stat == TXN_NOTFOUND)
ret = __db_txnlist_add(dbenv, info,
argp->txnid->txnid, TXN_IGNORE, NULL);
else
ret = __db_txnlist_update(dbenv, info,
argp->txnid->txnid, TXN_IGNORE, NULL);
}
} else if (DB_REDO(op)) {
if ((ret =
__db_txnlist_remove(dbenv, info, argp->child)) != TXN_OK) {
__db_err(dbenv,
"Transaction not in list %x", argp->child);
ret = DB_NOTFOUND;
}
}
if (ret == 0)
*lsnp = argp->prev_lsn;
__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;
R_LOCK(dbenv, &mgr->reginfo);
if ((ret =
__db_shalloc(mgr->reginfo.addr, sizeof(TXN_DETAIL), 0, &td)) != 0) {
R_UNLOCK(dbenv, &mgr->reginfo);
return (ret);
}
SH_TAILQ_INSERT_HEAD(®ion->active_txn, td, links, __txn_detail);
td->txnid = argp->txnid->txnid;
td->begin_lsn = argp->begin_lsn;
td->last_lsn = *lsnp;
td->parent = 0;
td->status = TXN_PREPARED;
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->flags = 0;
F_SET(td, TXN_DTL_RESTORED);
region->stat.st_nrestores++;
region->stat.st_nactive++;
if (region->stat.st_nactive > region->stat.st_maxnactive)
region->stat.st_maxnactive = region->stat.st_nactive;
R_UNLOCK(dbenv, &mgr->reginfo);
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);
}